feat: Add versioning support to DurableTaskAzureManagedWorkerBuilder and related tests

Author: YunchuWang

packages/durabletask-js-azuremanaged/src/index.ts

@@ -21,5 +21,8 @@ export { DurableTaskAzureManagedWorkerBuilder, createAzureManagedWorkerBuilder }
 // Logger exports - re-export from core package for convenience
 export { Logger, ConsoleLogger, NoOpLogger } from "@microsoft/durabletask-js";
 
+// Versioning exports - re-export from core package for convenience
+export { VersioningOptions, VersionMatchStrategy, VersionFailureStrategy } from "@microsoft/durabletask-js";
+
 // Azure-specific logger adapter
 export { AzureLoggerAdapter, createAzureLogger } from "./azure-logger-adapter";

packages/durabletask-js-azuremanaged/src/worker-builder.ts

@@ -4,7 +4,16 @@
 import { TokenCredential } from "@azure/identity";
 import * as grpc from "@grpc/grpc-js";
 import { DurableTaskAzureManagedWorkerOptions } from "./options";
-import { TaskHubGrpcWorker, TOrchestrator, TActivity, TInput, TOutput, Logger, ConsoleLogger } from "@microsoft/durabletask-js";
+import {
+  TaskHubGrpcWorker,
+  TOrchestrator,
+  TActivity,
+  TInput,
+  TOutput,
+  Logger,
+  ConsoleLogger,
+  VersioningOptions,
+} from "@microsoft/durabletask-js";
 
 /**
  * Builder for creating DurableTaskWorker instances that connect to Azure-managed Durable Task service.
@@ -17,6 +26,7 @@ export class DurableTaskAzureManagedWorkerBuilder {
   private _activities: { name?: string; fn: TActivity<TInput, TOutput> }[] = [];
   private _logger: Logger = new ConsoleLogger();
   private _shutdownTimeoutMs?: number;
+  private _versioning?: VersioningOptions;
 
   /**
    * Creates a new instance of DurableTaskAzureManagedWorkerBuilder.
@@ -198,6 +208,18 @@ export class DurableTaskAzureManagedWorkerBuilder {
     return this;
   }
 
+  /**
+   * Configures versioning options for the worker.
+   * This allows filtering orchestrations by version using different match strategies.
+   *
+   * @param options The versioning options including version, matchStrategy, and failureStrategy.
+   * @returns This builder instance.
+   */
+  versioning(options: VersioningOptions): DurableTaskAzureManagedWorkerBuilder {
+    this._versioning = options;
+    return this;
+  }
+
   /**
    * Builds and returns a configured TaskHubGrpcWorker.
    *
@@ -219,18 +241,17 @@ export class DurableTaskAzureManagedWorkerBuilder {
       ...this._grpcChannelOptions,
     };
 
-    // Use the core TaskHubGrpcWorker with custom credentials and metadata generator
-    // For insecure connections, metadata is passed via the metadataGenerator parameter
-    // For secure connections, metadata is included in the channel credentials
-    const worker = new TaskHubGrpcWorker(
+    // Use the core TaskHubGrpcWorker with options-based constructor
+    const worker = new TaskHubGrpcWorker({
       hostAddress,
-      combinedOptions,
-      true,
-      channelCredentials,
+      options: combinedOptions,
+      useTLS: true,
+      credentials: channelCredentials,
       metadataGenerator,
-      this._logger,
-      this._shutdownTimeoutMs,
-    );
+      logger: this._logger,
+      shutdownTimeoutMs: this._shutdownTimeoutMs,
+      versioning: this._versioning,
+    });
 
     // Register all orchestrators
     for (const { name, fn } of this._orchestrators) {