[Durable Functions] Basic "Function Chaining" implementation

.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"
+}

examples/durable/FunctionChainingApp/profile.ps1

@@ -0,0 +1,21 @@
+# Azure Functions profile.ps1
+#
+# This profile.ps1 will get executed every "cold start" of your Function App.
+# "cold start" occurs when:
+#
+# * A Function App starts up for the very first time
+# * A Function App starts up after being de-allocated due to inactivity
+#
+# You can define helper functions, run commands, or specify environment variables
+# NOTE: any variables defined that are not environment variables will get reset after the first execution
+
+# Authenticate with Azure PowerShell using MSI.
+# Remove this if you are not planning on using MSI or Azure PowerShell.
+if ($env:MSI_SECRET -and (Get-Module -ListAvailable Az.Accounts)) {
+    Connect-AzAccount -Identity
+}
+
+# Uncomment the next line to enable legacy AzureRm alias in Azure PowerShell.
+# Enable-AzureRmAlias
+
+# You can also define functions or aliases that can be referenced in any of your PowerShell functions.

examples/durable/FunctionChainingApp/proxies.json

@@ -0,0 +1,4 @@
+{
+  "$schema": "http://json.schemastore.org/proxies",
+  "proxies": {}
+}

examples/durable/LongRunningHttpApp/.funcignore

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

examples/durable/LongRunningHttpApp/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/LongRunningHttpApp/HttpTrigger/run.ps1

@@ -0,0 +1,18 @@
+using namespace System.Net
+
+param($Request, $TriggerMetadata, $orchestrationClientIn)
+
+Write-Host "HttpTrigger started"
+
+$InstanceId = Start-NewOrchestration -FunctionName 'MyOrchestrator' -InputObject $Request.Query
+
+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/LongRunningHttpApp/LongRunningActivity/function.json

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

examples/durable/LongRunningHttpApp/LongRunningActivity/run.ps1

@@ -0,0 +1,19 @@
+param($InputData)
+
+$name = $InputData.Name
+$durationSeconds = $InputData.DurationSeconds
+
+$activityTraceHeader = "LongRunningActivity($name, $durationSeconds)"
+Write-Host "$activityTraceHeader started"
+
+$startedAt = Get-Date
+$runUntil = (Get-Date) + (New-TimeSpan -Seconds $durationSeconds)
+Write-Host "$activityTraceHeader will run until $($runUntil.ToUniversalTime())"
+while ((Get-Date) -lt $runUntil) {
+    Start-Sleep -Seconds ([Math]::Min($durationSeconds, 10))
+    Write-Host "$activityTraceHeader is still running: $([Math]::Truncate(((Get-Date) - $startedAt).TotalMinutes)) minute(s)"
+}
+
+Write-Host "$activityTraceHeader finished"
+
+return "Hello $name"

examples/durable/LongRunningHttpApp/MyOrchestrator/function.json

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

examples/durable/LongRunningHttpApp/MyOrchestrator/run.ps1

@@ -0,0 +1,9 @@
+param($Context)
+
+Write-Host "MyOrchestrator: started. Input: $($Context.Input)"
+
+$activityResult = Invoke-ActivityFunctionAsync -FunctionName "LongRunningActivity" -Input $Context.Input
+Write-Host "MyOrchestrator: Returned from LongRunningActivity: '$activityResult'"
+
+Write-Host "MyOrchestrator: finished."
+return $activityResult

examples/durable/LongRunningHttpApp/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/LongRunningHttpApp/host.json

@@ -0,0 +1,4 @@
+{
+  "version": "2.0",
+  "functionTimeout": "02:00:00"
+}

examples/durable/LongRunningHttpApp/profile.ps1

@@ -0,0 +1,21 @@
+# Azure Functions profile.ps1
+#
+# This profile.ps1 will get executed every "cold start" of your Function App.
+# "cold start" occurs when:
+#
+# * A Function App starts up for the very first time
+# * A Function App starts up after being de-allocated due to inactivity
+#
+# You can define helper functions, run commands, or specify environment variables
+# NOTE: any variables defined that are not environment variables will get reset after the first execution
+
+# Authenticate with Azure PowerShell using MSI.
+# Remove this if you are not planning on using MSI or Azure PowerShell.
+if ($env:MSI_SECRET -and (Get-Module -ListAvailable Az.Accounts)) {
+    Connect-AzAccount -Identity
+}
+
+# Uncomment the next line to enable legacy AzureRm alias in Azure PowerShell.
+# Enable-AzureRmAlias
+
+# You can also define functions or aliases that can be referenced in any of your PowerShell functions.

examples/durable/LongRunningHttpApp/proxies.json

@@ -0,0 +1,4 @@
+{
+  "$schema": "http://json.schemastore.org/proxies",
+  "proxies": {}
+}

src/Durable/ActionType.cs

@@ -0,0 +1,48 @@
+//
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+//
+
+namespace Microsoft.Azure.Functions.PowerShellWorker.Durable
+{
+    /// <summary>
+    /// Action types
+    /// </summary>
+    internal enum ActionType
+    {
+        /// <summary>
+        /// Call an activity function.
+        /// </summary>
+        CallActivity = 0,
+
+        /// <summary>
+        /// Call an activity function with retry.
+        /// </summary>
+        CallActivityWithRetry = 1,
+
+        /// <summary>
+        /// Call a sub-orchestration function.
+        /// </summary>
+        CallSubOrchestrator = 2,
+
+        /// <summary>
+        /// Call a sub-orchestration function with retry.
+        /// </summary>
+        CallSubOrchestratorWithRetry = 3,
+
+        /// <summary>
+        /// Run the orchestration function as a loop.
+        /// </summary>
+        ContinueAsNew = 4,
+
+        /// <summary>
+        /// Create a timer.
+        /// </summary>
+        CreateTimer = 5,
+
+        /// <summary>
+        /// Wait for an external event.
+        /// </summary>
+        WaitForExternalEvent = 6,
+    }
+}

src/Durable/CallActivityAction.cs

@@ -0,0 +1,30 @@
+//
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+//
+
+namespace Microsoft.Azure.Functions.PowerShellWorker.Durable
+{
+    /// <summary>
+    /// An orchestration action that represents calling an activity function.
+    /// </summary>
+    internal class CallActivityAction : OrchestrationAction
+    {
+        /// <summary>
+        /// The activity function name.
+        /// </summary>
+        public readonly string FunctionName;
+
+        /// <summary>
+        /// The input to the activity function.
+        /// </summary>
+        public readonly object Input;
+
+        public CallActivityAction(string functionName, object input)
+            : base(ActionType.CallActivity)
+        {
+            FunctionName = functionName;
+            Input = input;
+        }
+    }
+}