Initial commit

Author: JordanMarr

.gitignore

@@ -0,0 +1,54 @@
+build_output
+Directory.Build.props
+*.suo
+*.user
+*.dotCover
+
+
+bin
+obj
+_ReSharper*
+
+*.psess
+*.vspx
+
+*wpftmp.csproj
+*.csproj.user
+*.resharper.user
+*.resharper
+*.ReSharper
+*.cache
+*.g.cs
+*~
+*.swp
+*.bak
+*.orig
+
+*.userprefs
+*.log.txt
+
+.fake
+packages
+TestResults
+run
+
+.vs
+paket-files/
+.paket/paket.bootstrapper.exe
+
+.idea/
+
+deploy/
+
+BenchmarkDotNet.Artifacts/
+
+# Ionide (cross platform F# VS Code tools) working folder
+.ionide/
+
+### VS Code ###
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+*.code-workspace

src/FSharp.DurableExtensions.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.6.33829.357
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{F2A71F9B-5D33-465A-A702-920D77279786}") = "FSharp.DurableExtensions", "FSharp.DurableExtensions\FSharp.DurableExtensions.fsproj", "{B67E280D-5781-4D96-A5B8-4A71755B8359}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{B67E280D-5781-4D96-A5B8-4A71755B8359}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B67E280D-5781-4D96-A5B8-4A71755B8359}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B67E280D-5781-4D96-A5B8-4A71755B8359}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B67E280D-5781-4D96-A5B8-4A71755B8359}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {7CBD21E6-59B7-4ED4-84AE-EF7C6ABB3D22}
+	EndGlobalSection
+EndGlobal

src/FSharp.DurableExtensions/FSharp.DurableExtensions.fsproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <GenerateDocumentationFile>true</GenerateDocumentationFile>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Compile Include="IDurableOrchestrationContext.fs" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.DurableTask" Version="2.10.0" />
+  </ItemGroup>
+
+</Project>

src/FSharp.DurableExtensions/IDurableOrchestrationContext.fs

@@ -0,0 +1,73 @@
+module FSharp.DurableExtensions
+
+open System.Threading.Tasks
+open Microsoft.FSharp.Quotations
+open Microsoft.Azure.WebJobs.Extensions.DurableTask
+
+/// Extension methods for calling Azure Durable Activity Functions with strongly typed inputs and outputs.
+type IDurableOrchestrationContext with 
+        
+    /// Calls a function with no ActivityTrigger input.
+    member ctx.CallActivity<'D1, 'Output> ([<ReflectedDefinition>] azureFn: Expr<'D1 -> Task<'Output>>, ?retry: RetryOptions) : Task<'Output> = 
+        let functionName = 
+            match azureFn with
+            | DerivedPatterns.Lambdas(_, Patterns.Call(_,mi,_)) -> mi.Name
+            | _ -> failwith "Invalid fn"
+
+        match retry with
+        | Some opt -> 
+            ctx.CallActivityWithRetryAsync<'Output>(functionName, opt, null)
+        | None -> 
+            ctx.CallActivityAsync<'Output>(functionName, null)
+
+    /// Calls a function with an ActivityTrigger input parameter and no dependency parameters.
+    member ctx.CallActivity<'Input, 'Output> ([<ReflectedDefinition>] azureFn: Expr<'Input -> Task<'Output>>, req: 'Input, ?retry: RetryOptions) : Task<'Output> = 
+        let functionName = 
+            match azureFn with
+            | DerivedPatterns.Lambdas(_, Patterns.Call(_,mi,_)) -> mi.Name
+            | _ -> failwith "Invalid fn"
+
+        match retry with
+        | Some opt -> 
+            ctx.CallActivityWithRetryAsync<'Output>(functionName, opt, req)
+        | None ->
+            ctx.CallActivityAsync<'Output>(functionName, req)
+
+    /// Calls a function with an ActivityTrigger input parameter and one dependency parameter.
+    member ctx.CallActivity<'Input, 'D1, 'Output> ([<ReflectedDefinition>] azureFn: Expr<'Input * 'D1 -> Task<'Output>>, req: 'Input, ?retry: RetryOptions) : Task<'Output> = 
+        let functionName = 
+            match azureFn with
+            | DerivedPatterns.Lambdas(_, Patterns.Call(_,mi,_)) -> mi.Name
+            | _ -> failwith "Invalid fn"
+
+        match retry with
+        | Some opt -> 
+            ctx.CallActivityWithRetryAsync<'Output>(functionName, opt, req)
+        | None ->
+            ctx.CallActivityAsync<'Output>(functionName, req)
+        
+    /// Calls a function with an ActivityTrigger input parameter and two dependency parameters.
+    member ctx.CallActivity<'Input, 'D1, 'D2, 'Output> ([<ReflectedDefinition>] azureFn: Expr<'Input * 'D1 * 'D2 -> Task<'Output>>, req: 'Input, ?retry: RetryOptions) : Task<'Output> = 
+        let functionName = 
+            match azureFn with
+            | DerivedPatterns.Lambdas(_, Patterns.Call(_,mi,_)) -> mi.Name
+            | _ -> failwith "Invalid fn"
+
+        match retry with
+        | Some opt -> 
+            ctx.CallActivityWithRetryAsync<'Output>(functionName, opt, req)
+        | None ->
+            ctx.CallActivityAsync<'Output>(functionName, req)
+
+    /// Calls a function with an ActivityTrigger input parameter and three dependency parameters.
+    member ctx.CallActivity<'Input, 'D1, 'D2, 'D3, 'Output> ([<ReflectedDefinition>] azureFn: Expr<'Input * 'D1 * 'D2 * 'D3 -> Task<'Output>>, req: 'Input, ?retry: RetryOptions) : Task<'Output> = 
+        let functionName = 
+            match azureFn with
+            | DerivedPatterns.Lambdas(_, Patterns.Call(_,mi,_)) -> mi.Name
+            | _ -> failwith "Invalid fn"
+
+        match retry with
+        | Some opt -> 
+            ctx.CallActivityWithRetryAsync<'Output>(functionName, opt, req)
+        | None ->
+            ctx.CallActivityAsync<'Output>(functionName, req)