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 public override string ContentType
{
52 get { return MediaType; }
55 public override string MediaType
{
56 get { return session ? "application/soap+msbinsession1" : "application/soap+msbin1"; }
59 public override MessageVersion MessageVersion
{
60 get { return MessageVersion.Default; }
64 public override Message
ReadMessage (ArraySegment
<byte> buffer
,
65 BufferManager bufferManager
, string contentType
)
67 if (contentType
!= ContentType
)
68 throw new ProtocolException ("Only content type 'application/soap+msbin1' is allowed.");
70 // FIXME: retrieve reader session and message body.
72 throw new NotImplementedException ();
75 // FIXME: use bufferManager
76 return Message.CreateMessage (
77 XmlDictionaryReader.CreateBinaryReader (
78 buffer.Array, buffer.Offset, buffer.Count,
80 owner != null ? owner.Owner.ReaderQuotas : new XmlDictionaryReaderQuotas ()),
81 int.MaxValue, MessageVersion);
85 // It is sort of nasty hack, but there is no other way to provide reader/writer session from TCP stream.
86 internal XmlBinaryReaderSession CurrentReaderSession { get; set; }
87 internal XmlBinaryWriterSession CurrentWriterSession { get; set; }
89 public override Message
ReadMessage (Stream stream
,
90 int maxSizeOfHeaders
, string contentType
)
92 if (contentType
!= ContentType
)
93 throw new ProtocolException ("Only content type 'application/soap+msbin1' is allowed.");
95 // 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.
96 if (!stream
.CanSeek
) {
97 var tmpms
= new MemoryStream ();
98 var bytes
= new byte [4096];
101 len
= stream
.Read (bytes
, 0, bytes
.Length
);
102 tmpms
.Write (bytes
, 0, len
);
104 tmpms
.Seek (0, SeekOrigin
.Begin
);
108 return Message
.CreateMessage (
109 XmlDictionaryReader
.CreateBinaryReader (stream
, Constants
.SoapDictionary
, owner
!= null ? owner
.Owner
.ReaderQuotas
: new XmlDictionaryReaderQuotas (), session
? CurrentReaderSession
: null),
110 maxSizeOfHeaders
, MessageVersion
);
113 public override void WriteMessage (Message message
, Stream stream
)
115 VerifyMessageVersion (message
);
117 using (var xw
= XmlDictionaryWriter
.CreateBinaryWriter (stream
, Constants
.SoapDictionary
, session
? CurrentWriterSession
: null))
118 message
.WriteMessage (xw
);
122 public override ArraySegment
<byte> WriteMessage (
123 Message message
, int maxMessageSize
,
124 BufferManager bufferManager
, int messageOffset
)
126 VerifyMessageVersion (message
);
128 throw new NotImplementedException ();