Merge pull request #26 from escendit/25-add-temporal-runtime

Add Temporal Runtime

Author: snovak7

src/Hosting/HostApplicationBuilderExtensions.Temporal.cs

@@ -8,6 +8,8 @@ namespace Microsoft.Extensions.Hosting;
 using DependencyInjection;
 using Escendit.Extensions.Hosting.Abstractions;
 using Escendit.Extensions.Hosting.Exceptions;
+using Temporalio.Extensions.Hosting;
+using Temporalio.Extensions.OpenTelemetry;
 
 /// <summary>
 /// Provides extension methods for configuring and customizing the <see cref="HostApplicationBuilder"/>.
@@ -111,4 +113,47 @@ public static HostApplicationBuilder AddKeyedTemporalClient(
             .AddKeyedTemporalClient(clientName, temporalHost.Authority, clientNamespace);
         return builder;
     }
+
+    /// <summary>
+    /// Adds a Temporal server runtime to the application builder with the specified configuration settings.
+    /// </summary>
+    /// <param name="builder">The <see cref="HostApplicationBuilder"/> used to configure the application.</param>
+    /// <param name="name">The name of the Temporal server runtime to configure.</param>
+    /// <param name="configureOptions">An action to configure the <see cref="ITemporalWorkerServiceOptionsBuilder"/> for the server runtime.</param>
+    /// <returns>The <see cref="HostApplicationBuilder"/> instance for further configuration.</returns>
+    public static HostApplicationBuilder AddTemporalServerRuntime(
+        this HostApplicationBuilder builder,
+        string name,
+        Action<ITemporalWorkerServiceOptionsBuilder> configureOptions)
+    {
+        ArgumentNullException.ThrowIfNull(builder);
+        ArgumentNullException.ThrowIfNull(name);
+        ArgumentNullException.ThrowIfNull(configureOptions);
+
+        return builder
+            .AddServiceDefaults(tracerProviderBuilder => tracerProviderBuilder
+                .AddSource(
+                    name,
+                    TracingInterceptor.ClientSource.Name,
+                    TracingInterceptor.WorkflowsSource.Name,
+                    TracingInterceptor.ActivitiesSource.Name))
+            .AddTemporalHostedService(name, server => server
+                .ConfigureWorkerOptions(configureOptions));
+    }
+
+    /// <summary>
+    /// Adds a Temporal server runtime to the application builder with the specified configuration settings.
+    /// </summary>
+    /// <param name="builder">The <see cref="HostApplicationBuilder"/> used to configure the application.</param>
+    /// <param name="configureOptions">An action to configure the <see cref="ITemporalWorkerServiceOptionsBuilder"/> for the server runtime.</param>
+    /// <returns>The <see cref="HostApplicationBuilder"/> instance for further configuration.</returns>
+    public static HostApplicationBuilder AddTemporalServerRuntime(
+        this HostApplicationBuilder builder,
+        Action<ITemporalWorkerServiceOptionsBuilder> configureOptions)
+    {
+        ArgumentNullException.ThrowIfNull(builder);
+        ArgumentNullException.ThrowIfNull(configureOptions);
+
+        return builder.AddTemporalServerRuntime(DefaultTemporalServiceName, configureOptions);
+    }
 }

src/Hosting/PublicAPI.Unshipped.txt

@@ -14,4 +14,6 @@ static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddServiceD
 static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddTemporalHostedService(this Microsoft.Extensions.Hosting.HostApplicationBuilder! builder) -> Microsoft.Extensions.Hosting.HostApplicationBuilder!
 static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddTemporalHostedService(this Microsoft.Extensions.Hosting.HostApplicationBuilder! builder, string! name, System.Action<Microsoft.Extensions.DependencyInjection.ITemporalBuilder!>! configureOptions) -> Microsoft.Extensions.Hosting.HostApplicationBuilder!
 static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddTemporalHostedService(this Microsoft.Extensions.Hosting.HostApplicationBuilder! builder, System.Action<Microsoft.Extensions.DependencyInjection.ITemporalBuilder!>! configureOptions) -> Microsoft.Extensions.Hosting.HostApplicationBuilder!
+static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddTemporalServerRuntime(this Microsoft.Extensions.Hosting.HostApplicationBuilder! builder, string! name, System.Action<Temporalio.Extensions.Hosting.ITemporalWorkerServiceOptionsBuilder!>! configureOptions) -> Microsoft.Extensions.Hosting.HostApplicationBuilder!
+static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.AddTemporalServerRuntime(this Microsoft.Extensions.Hosting.HostApplicationBuilder! builder, System.Action<Temporalio.Extensions.Hosting.ITemporalWorkerServiceOptionsBuilder!>! configureOptions) -> Microsoft.Extensions.Hosting.HostApplicationBuilder!
 static Microsoft.Extensions.Hosting.HostApplicationBuilderExtensions.UseUserSecrets<TType>(this Microsoft.Extensions.Hosting.HostApplicationBuilder builder) -> Microsoft.Extensions.Hosting.HostApplicationBuilder