Make schema name dynamically configurable in host.json

Author: cgillum

src/DurableTask.SqlServer.AzureFunctions/SqlDurabilityOptions.cs

@@ -4,7 +4,9 @@
 namespace DurableTask.SqlServer.AzureFunctions
 {
     using System;
+    using Microsoft.Azure.WebJobs;
     using Microsoft.Azure.WebJobs.Extensions.DurableTask;
+    using Microsoft.Azure.WebJobs.Host;
     using Microsoft.Data.SqlClient;
     using Microsoft.Extensions.Configuration;
     using Microsoft.Extensions.Logging;
@@ -35,7 +37,8 @@ class SqlDurabilityOptions
 
         internal SqlOrchestrationServiceSettings GetOrchestrationServiceSettings(
             DurableTaskOptions extensionOptions,
-            IConnectionInfoResolver connectionStringResolver)
+            IConnectionInfoResolver connectionStringResolver,
+            INameResolver nameResolver)
         {
             if (connectionStringResolver == null)
             {
@@ -59,7 +62,9 @@ internal SqlOrchestrationServiceSettings GetOrchestrationServiceSettings(
                 throw new ArgumentException("The provided connection string is invalid.", e);
             }
 
-            var settings = new SqlOrchestrationServiceSettings(connectionStringSection.Value, this.TaskHubName, this.SchemaName)
+            string? resolvedSchemaName = this.SchemaName != null ? nameResolver.ResolveWholeString(this.SchemaName) : null;
+
+            var settings = new SqlOrchestrationServiceSettings(connectionStringSection.Value, this.TaskHubName, resolvedSchemaName)
             {
                 CreateDatabaseIfNotExists = this.CreateDatabaseIfNotExists,
                 LoggerFactory = this.LoggerFactory,

src/DurableTask.SqlServer.AzureFunctions/SqlDurabilityProviderFactory.cs

@@ -5,6 +5,7 @@ namespace DurableTask.SqlServer.AzureFunctions
 {
     using System;
     using System.Collections.Generic;
+    using Microsoft.Azure.WebJobs;
     using Microsoft.Azure.WebJobs.Extensions.DurableTask;
     using Microsoft.Extensions.Logging;
     using Microsoft.Extensions.Options;
@@ -21,6 +22,7 @@ class SqlDurabilityProviderFactory : IDurabilityProviderFactory
         readonly DurableTaskOptions extensionOptions;
         readonly ILoggerFactory loggerFactory;
         readonly IConnectionInfoResolver connectionInfoResolver;
+        readonly INameResolver nameResolver;
 
         SqlDurabilityOptions? defaultOptions;
         SqlDurabilityProvider? defaultProvider;
@@ -37,11 +39,13 @@ class SqlDurabilityProviderFactory : IDurabilityProviderFactory
         public SqlDurabilityProviderFactory(
             IOptions<DurableTaskOptions> extensionOptions,
             ILoggerFactory loggerFactory,
-            IConnectionInfoResolver connectionInfoResolver)
+            IConnectionInfoResolver connectionInfoResolver,
+            INameResolver nameResolver)
         {
             this.extensionOptions = extensionOptions?.Value ?? throw new ArgumentNullException(nameof(extensionOptions));
             this.loggerFactory = loggerFactory ?? throw new ArgumentNullException(nameof(loggerFactory));
             this.connectionInfoResolver = connectionInfoResolver ?? throw new ArgumentNullException(nameof(connectionInfoResolver));
+            this.nameResolver = nameResolver ?? throw new ArgumentNullException(nameof(nameResolver));
         }
 
         // Called by the Durable trigger binding infrastructure
@@ -85,9 +89,10 @@ public DurabilityProvider GetDurabilityProvider(DurableClientAttribute attribute
 
         SqlOrchestrationService GetOrchestrationService(SqlDurabilityOptions clientOptions)
         {
-            return new (clientOptions.GetOrchestrationServiceSettings(
+            return new SqlOrchestrationService(clientOptions.GetOrchestrationServiceSettings(
                 this.extensionOptions,
-                this.connectionInfoResolver));
+                this.connectionInfoResolver,
+                this.nameResolver));
         }
 
         static string GetDurabilityProviderKey(DurableClientAttribute attribute)