Fixes #787

Author: pragnagopa

src/WebJobs.Script/Binding/FunctionBinding.cs

@@ -213,7 +213,7 @@ internal static async Task BindStreamAsync(BindingContext context, FileAccess ac
             else
             {
                 // Read the value into the context Value converting based on data type
-                object converted = null;
+                object converted = context.Value ?? new MemoryStream();
                 ConvertStreamToValue(stream, context.DataType, ref converted);
                 context.Value = converted;
             }

test/WebJobs.Script.Tests/PhpEndToEndTests.cs

@@ -1,6 +1,11 @@
 // Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
+using System;
+using System.Threading.Tasks;
+using Microsoft.WindowsAzure.Storage.Blob;
+using Xunit;
+
 namespace Microsoft.Azure.WebJobs.Script.Tests
 {
     public class PhpEndToEndTests : EndToEndTestsBase<PhpEndToEndTests.TestFixture>
@@ -10,11 +15,51 @@ public PhpEndToEndTests(TestFixture fixture)
         {
         }
 
+        [Fact]
+        public async Task BlobTriggerToBlobTest()
+        {
+            // the trigger blob was written by the fixture init code
+            // here we just wait for the output blob
+            CloudBlobContainer outputContainer = Fixture.BlobClient.GetContainerReference("test-output-php");
+            var resultBlob = outputContainer.GetBlockBlobReference(Fixture.TestBlobName);
+            await TestHelpers.WaitForBlobAsync(resultBlob);
+
+            string resultContents = resultBlob.DownloadText();
+            Assert.Equal(Fixture.TestBlobTriggerContents + "_" + Fixture.TestBlobContents, resultContents.Trim());
+        }
+
         public class TestFixture : EndToEndTestFixture
         {
             public TestFixture() : base(@"TestScripts\Php", "php")
             {
             }
+
+            public string TestBlobTriggerContents { get; private set; }
+
+            public string TestBlobContents { get; private set; }
+
+            public string TestBlobName { get; private set; }
+
+            public string TestBlobTriggerName { get; private set; }
+
+            protected override void CreateTestStorageEntities()
+            {
+                // This will ensure the input container is created.
+                base.CreateTestStorageEntities();
+
+                TestBlobTriggerContents = "My Test Blob Trigger";
+                TestBlobContents = "My Test Blob";
+                TestBlobTriggerName = "testBlobTrigger";
+                TestBlobName = "testBlob";
+
+                // write the test blob before the host starts, so it gets picked
+                // up relatively quickly by the blob trigger test               
+                CloudBlockBlob inputBlobTrigger = TestInputContainer.GetBlockBlobReference(TestBlobTriggerName);
+                inputBlobTrigger.UploadText(TestBlobTriggerContents);
+
+                CloudBlockBlob inputBlob = TestInputContainer.GetBlockBlobReference(TestBlobName);
+                inputBlob.UploadText(TestBlobContents);
+            }
         }
     }
 }

test/WebJobs.Script.Tests/TestScripts/Php/BlobTriggerToBlob/function.json

@@ -0,0 +1,22 @@
+{
+  "bindings": [
+    {
+      "type": "blobTrigger",
+      "name": "inputBlobTrigger",
+      "direction": "in",
+      "path": "test-input-php/testBlobTrigger"
+    },
+    {
+      "type": "blob",
+      "name": "inputBlob",
+      "direction": "in",
+      "path": "test-input-php/testBlob"
+    },
+    {
+      "type": "blob",
+      "name": "outputBlob",
+      "direction": "out",
+      "path": "test-output-php/testBlob"
+    }
+  ]
+}

test/WebJobs.Script.Tests/TestScripts/Php/BlobTriggerToBlob/run.php

@@ -0,0 +1,13 @@
+<?php
+  $inputBlobTrigger = file_get_contents(getenv('inputBlobTrigger'));
+  $inputBlobTrigger = rtrim($inputBlobTrigger, "\n\r");
+  fwrite(STDOUT, sprintf("PHP script processed blobTrigger '$inputBlobTrigger'", $string));
+  
+  $inputBlob = file_get_contents(getenv('inputBlob'));
+  $inputBlob = rtrim($inputBlob, "\n\r");
+  fwrite(STDOUT, sprintf("PHP script processed blob '$inputBlob'", $string));
+  
+  $outputBlob = fopen(getenv('outputBlob'), "w");
+  fwrite($outputBlob, $inputBlobTrigger."_".$inputBlob);
+  fclose($outputBlob);
+?>

test/WebJobs.Script.Tests/WebJobs.Script.Tests.csproj

@@ -995,6 +995,9 @@
     <None Include="TestScripts\Node\WebHookTrigger\function.json">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </None>
+    <None Include="TestScripts\Php\BlobTriggerToBlob\function.json">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </None>
     <None Include="TestScripts\Php\host.json">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </None>
@@ -1073,6 +1076,9 @@
     <None Include="TestScripts\Python\TimeoutSync\function.json">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </None>
+    <Content Include="TestScripts\Php\BlobTriggerToBlob\run.php">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </Content>
     <Content Include="TestScripts\Python\TimeoutSync\run.py">
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>
     </Content>