2 // BinaryMessageEncoder.cs
4 // Author: Atsushi Enomoto (atsushi@ximian.com)
6 // Copyright (C) 2005,2009 Novell, Inc (http://www.novell.com)
8 // Permission is hereby granted, free of charge, to any person obtaining
9 // a copy of this software and associated documentation files (the
10 // "Software"), to deal in the Software without restriction, including
11 // without limitation the rights to use, copy, modify, merge, publish,
12 // distribute, sublicense, and/or sell copies of the Software, and to
13 // permit persons to whom the Software is furnished to do so, subject to
14 // the following conditions:
16 // The above copyright notice and this permission notice shall be
17 // included in all copies or substantial portions of the Software.
19 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
20 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
21 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
22 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
23 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
24 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
25 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 using System.Collections.ObjectModel;
30 using System.ServiceModel;
34 namespace System.ServiceModel.Channels
36 internal class BinaryMessageEncoder : MessageEncoder
38 public BinaryMessageEncoder ()
42 public BinaryMessageEncoder (BinaryMessageEncoderFactory owner, bool session)
45 this.session = session;
48 BinaryMessageEncoderFactory owner;
51 internal bool UseSession {
52 get { return session; }
55 public override string ContentType {
56 get { return MediaType; }
59 public override string MediaType {
60 get { return session ? "application/soap+msbinsession1" : "application/soap+msbin1"; }
63 public override MessageVersion MessageVersion {
64 get { return MessageVersion.Default; }
68 public override Message ReadMessage (ArraySegment<byte> buffer,
69 BufferManager bufferManager, string contentType)
71 if (contentType != null && contentType != ContentType)
72 throw new ProtocolException ("Only content type 'application/soap+msbin1' is allowed.");
74 // FIXME: retrieve reader session and message body.
76 throw new NotImplementedException ();
79 // FIXME: use bufferManager
80 return Message.CreateMessage (
81 XmlDictionaryReader.CreateBinaryReader (
82 buffer.Array, buffer.Offset, buffer.Count,
84 owner != null ? owner.Owner.ReaderQuotas : new XmlDictionaryReaderQuotas ()),
85 int.MaxValue, MessageVersion);
89 // It is sort of nasty hack, but there is no other way to provide reader/writer session from TCP stream.
90 internal XmlBinaryReaderSession CurrentReaderSession { get; set; }
91 internal XmlBinaryWriterSession CurrentWriterSession { get; set; }
93 public override Message ReadMessage (Stream stream,
94 int maxSizeOfHeaders, string contentType)
96 if (contentType != null && contentType != ContentType)
97 throw new ProtocolException ("Only content type 'application/soap+msbin1' is allowed.");
99 // FIXME: remove this extraneous buffering. It is somehow required for HTTP + binary encoding binding. The culprit is probably in binary xml reader or writer, but not sure.
100 if (!stream.CanSeek) {
101 var tmpms = new MemoryStream ();
102 var bytes = new byte [4096];
105 len = stream.Read (bytes, 0, bytes.Length);
106 tmpms.Write (bytes, 0, len);
108 tmpms.Seek (0, SeekOrigin.Begin);
112 var ret = Message.CreateMessage (
113 XmlDictionaryReader.CreateBinaryReader (stream, Constants.SoapDictionary, owner != null ? owner.Owner.ReaderQuotas : new XmlDictionaryReaderQuotas (), session ? CurrentReaderSession : null),
114 maxSizeOfHeaders, MessageVersion);
115 ret.Properties.Encoder = this;
119 public override void WriteMessage (Message message, Stream stream)
121 VerifyMessageVersion (message);
123 using (var xw = XmlDictionaryWriter.CreateBinaryWriter (stream, Constants.SoapDictionary, session ? CurrentWriterSession : null))
124 message.WriteMessage (xw);
128 public override ArraySegment<byte> WriteMessage (
129 Message message, int maxMessageSize,
130 BufferManager bufferManager, int messageOffset)
132 VerifyMessageVersion (message);
134 throw new NotImplementedException ();