Add support for requests with body

HttpDisassembler currently assumes that no message body exists when the message is received.
This is fine for HTTP GET but will not work for PUT and PATCH that often contains both uri parameters and a body.
Added functionality in HttpDisassembler to determine if the incomming message has a body and if that is the case, create a new message part with the uri parameters.

Author: robinhultman

Src/HttpDisassembler/BizTalkComponents.PipelineComponents.HttpDisassembler.csproj

@@ -43,6 +43,10 @@
       <SpecificVersion>False</SpecificVersion>
       <HintPath>..\..\..\..\..\Windows\assembly\GAC_MSIL\Microsoft.BizTalk.Pipeline\3.0.1.0__31bf3856ad364e35\Microsoft.BizTalk.Pipeline.dll</HintPath>
     </Reference>
+    <Reference Include="Microsoft.BizTalk.Streaming, Version=3.0.1.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
+      <SpecificVersion>False</SpecificVersion>
+      <HintPath>..\..\..\..\..\..\..\Program Files (x86)\Microsoft BizTalk Server 2013\Microsoft.BizTalk.Streaming.dll</HintPath>
+    </Reference>
     <Reference Include="Microsoft.XLANGs.RuntimeTypes, Version=3.0.1.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL" />
     <Reference Include="System" />
     <Reference Include="System.ComponentModel.DataAnnotations" />

Src/HttpDisassembler/HttpDisassembler.cs

@@ -9,6 +9,7 @@
 using Microsoft.BizTalk.Message.Interop;
 using Microsoft.XLANGs.RuntimeTypes;
 using BizTalkComponents.Utils;
+using Microsoft.BizTalk.Streaming;
 
 namespace BizTalkComponents.PipelineComponents.HttpDisassembler
 {
@@ -34,6 +35,11 @@ public void Disassemble(IPipelineContext pContext, IBaseMessage pInMsg)
                 throw new ArgumentException(errorMessage);
             }
 
+            var data = pInMsg.BodyPart.GetOriginalDataStream();
+
+            //Determine of the request body has any data. GET request will not have any body.
+            var hasData = HasData(data);
+
             //Get a reference to the BizTalk schema.
             var documentSpec = (DocumentSpec)pContext.GetDocumentSpecByName(DocumentSpecName);
 
@@ -64,14 +70,28 @@ public void Disassemble(IPipelineContext pContext, IBaseMessage pInMsg)
             ms.Seek(0, SeekOrigin.Begin);
 
             var outMsg = pInMsg;
-            outMsg.BodyPart.Data = ms;
 
-            //Promote message type and SchemaStrongName
-            outMsg.Context.Promote(new ContextProperty(SystemProperties.MessageType), documentSpec.DocType);
-            outMsg.Context.Promote(new ContextProperty(SystemProperties.SchemaStrongName), documentSpec.DocSpecStrongName);
+            //If the request has a body it should be preserved an the query parameters should be written to it's own message part.
+            if (hasData)
+            {
+                outMsg = pInMsg;
+                outMsg.BodyPart.Data = pInMsg.BodyPart.Data;
+                outMsg.Context = PipelineUtil.CloneMessageContext(pInMsg.Context);
+                var factory = pContext.GetMessageFactory();
+                var queryPart = factory.CreateMessagePart();
+                queryPart.Data = ms;
+
+                outMsg.AddPart("querypart", queryPart, false);
+            }
+            else
+            {
+                outMsg.BodyPart.Data = ms;
+                //Promote message type and SchemaStrongName
+                outMsg.Context.Promote(new ContextProperty(SystemProperties.MessageType), documentSpec.DocType);
+                outMsg.Context.Promote(new ContextProperty(SystemProperties.SchemaStrongName), documentSpec.DocSpecStrongName);
+            }
 
             _outputQueue.Enqueue(outMsg);
-
         }
 
         public void Load(IPropertyBag propertyBag, int errorLog)
@@ -93,5 +113,23 @@ public IBaseMessage GetNext(IPipelineContext pContext)
 
             return null;
         }
+
+        private bool HasData(Stream data)
+        {
+            byte[] buffer= new byte[10];
+            const int bufferSize = 0x280;
+            const int thresholdSize = 0x100000;
+
+            if (!data.CanSeek || !data.CanRead)
+            {
+                data = new ReadOnlySeekableStream(data, new VirtualStream(bufferSize, thresholdSize), bufferSize);
+            }
+
+            int num = data.Read(buffer, 0, buffer.Length);
+            data.Seek(0, SeekOrigin.Begin);
+            data.Position = 0;
+
+            return num > 0;
+        }
     }
 }