[Durable Functions] Basic "Function Chaining" implementation (#358)

Basic "Function Chaining" implementation

Author: AnatoliB

.gitignore

@@ -64,11 +64,15 @@ StyleCop.Cache
 
 examples/PSCoreApp/Modules
 src/Modules
-!src/Modules/Microsoft.AzureFunctions.PowerShellWorker
+!src/Modules/Microsoft.Azure.Functions.PowerShellWorker
 
 # protobuf
 protobuf/*
 src/Messaging/protobuf
 
 # pulled in for tests
 Azure.Functions.Cli
+
+# Azure Functions artifacts
+appsettings.json
+local.settings.json

examples/durable/FunctionChainingApp/.funcignore

@@ -0,0 +1,3 @@
+.git*
+.vscode
+local.settings.json

examples/durable/FunctionChainingApp/HttpTrigger/function.json

@@ -0,0 +1,29 @@
+{
+  "bindings": [
+    {
+      "authLevel": "function",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "Request",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "Response"
+    },
+    {
+      "name": "starter",
+      "type": "orchestrationClient",
+      "direction": "out"
+    },    
+    {
+      "name": "orchestrationClientIn",
+      "type": "orchestrationClient",
+      "direction": "in"
+    }    
+  ]
+}

examples/durable/FunctionChainingApp/HttpTrigger/run.ps1

@@ -0,0 +1,17 @@
+using namespace System.Net
+
+param($Request, $TriggerMetadata, $orchestrationClientIn)
+
+Write-Host "HttpTrigger started"
+
+$InstanceId = Start-NewOrchestration -FunctionName 'MyOrchestrator' -InputObject 'Hello'
+Write-Host "Started orchestration with ID = '$InstanceId'"
+
+$Response = New-OrchestrationCheckStatusResponse `
+                -Request $Request `
+                -OrchestrationClientData $orchestrationClientIn `
+                -InstanceId $InstanceId
+
+Push-OutputBinding -Name Response -Value $Response
+
+Write-Host "HttpTrigger completed"

examples/durable/FunctionChainingApp/MyOrchestrator/function.json

@@ -0,0 +1,9 @@
+{
+  "bindings": [
+    {
+      "name": "Context",
+      "type": "orchestrationTrigger",
+      "direction": "in"
+    }
+  ]
+}

examples/durable/FunctionChainingApp/MyOrchestrator/run.ps1

@@ -0,0 +1,15 @@
+using namespace System.Net
+
+param($Context)
+
+Write-Host "MyOrchestrator: started. Input: $($Context.Input)"
+
+$output = @()
+
+$output += Invoke-ActivityFunctionAsync -FunctionName "SayHello" -Input "Tokyo"
+$output += Invoke-ActivityFunctionAsync -FunctionName "SayHello" -Input "Seattle" -Verbose
+$output += Invoke-ActivityFunctionAsync -FunctionName "SayHello" -Input "London" -Verbose
+
+Write-Host "MyOrchestrator: finished."
+
+return $output

examples/durable/FunctionChainingApp/SayHello/function.json

@@ -0,0 +1,9 @@
+{
+  "bindings": [
+    {
+      "name": "name",
+      "type": "activityTrigger",
+      "direction": "in"
+    }
+  ]
+}

examples/durable/FunctionChainingApp/SayHello/run.ps1

@@ -0,0 +1,6 @@
+param($name)
+
+Write-Host "SayHello($name) started"
+Start-Sleep -Seconds 5
+Write-Host "SayHello($name) finished"
+return "Hello $name"

examples/durable/FunctionChainingApp/extensions.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+	<WarningsAsErrors></WarningsAsErrors>
+	<DefaultItemExcludes>**</DefaultItemExcludes>
+  </PropertyGroup>
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.DurableTask" Version="1.8.3" />
+    <PackageReference Include="Microsoft.Azure.WebJobs.Script.ExtensionsMetadataGenerator" Version="1.1.0" />
+  </ItemGroup>
+</Project>

examples/durable/FunctionChainingApp/host.json

@@ -0,0 +1,3 @@
+{
+  "version": "2.0"
+}