feat: Get rid of experimental AsyncLocalStorage.enterWith call (#1080)

Author: bergundy

packages/client/src/connection.ts

@@ -153,6 +153,7 @@ export interface RPCImplOptions {
   client: grpc.Client;
   callContextStorage: AsyncLocalStorage<CallContext>;
   interceptors?: grpc.Interceptor[];
+  staticMetadata: Metadata;
 }
 
 export interface ConnectionCtorOptions {
@@ -221,27 +222,29 @@ export class Connection {
       optionsWithDefaults.channelArgs
     );
     const callContextStorage = new AsyncLocalStorage<CallContext>();
-    callContextStorage.enterWith({ metadata: optionsWithDefaults.metadata });
 
     const workflowRpcImpl = this.generateRPCImplementation({
       serviceName: 'temporal.api.workflowservice.v1.WorkflowService',
       client,
       callContextStorage,
       interceptors: optionsWithDefaults?.interceptors,
+      staticMetadata: optionsWithDefaults.metadata,
     });
     const workflowService = WorkflowService.create(workflowRpcImpl, false, false);
     const operatorRpcImpl = this.generateRPCImplementation({
       serviceName: 'temporal.api.operatorservice.v1.OperatorService',
       client,
       callContextStorage,
       interceptors: optionsWithDefaults?.interceptors,
+      staticMetadata: optionsWithDefaults.metadata,
     });
     const operatorService = OperatorService.create(operatorRpcImpl, false, false);
     const healthRpcImpl = this.generateRPCImplementation({
       serviceName: 'grpc.health.v1.Health',
       client,
       callContextStorage,
       interceptors: optionsWithDefaults?.interceptors,
+      staticMetadata: optionsWithDefaults.metadata,
     });
     const healthService = HealthService.create(healthRpcImpl, false, false);
 
@@ -329,10 +332,14 @@ export class Connection {
     client,
     callContextStorage,
     interceptors,
+    staticMetadata,
   }: RPCImplOptions): RPCImpl {
     return (method: { name: string }, requestData: any, callback: grpc.requestCallback<any>) => {
       const metadataContainer = new grpc.Metadata();
       const { metadata, deadline } = callContextStorage.getStore() ?? {};
+      for (const [k, v] of Object.entries(staticMetadata)) {
+        metadataContainer.set(k, v);
+      }
       if (metadata != null) {
         for (const [k, v] of Object.entries(metadata)) {
           metadataContainer.set(k, v);

packages/testing/src/connection.ts

@@ -24,6 +24,7 @@ export class Connection extends BaseConnection {
       client: ctorOptions.client,
       callContextStorage: ctorOptions.callContextStorage,
       interceptors: ctorOptions.options.interceptors,
+      staticMetadata: ctorOptions.options.metadata,
     });
     const testService = TestService.create(rpcImpl, false, false);
     return { ...ctorOptions, testService };