Update-with-start

packages/client/src/helpers.ts

@@ -1,5 +1,6 @@
 import { ServiceError as GrpcServiceError } from '@grpc/grpc-js';
 import {
+  CustomGrpcServiceError as CustomGrpcServiceError,
   LoadedDataConverter,
   mapFromPayloads,
   NamespaceNotFoundError,
@@ -103,6 +104,7 @@ export function decodeCountWorkflowExecutionsResponse(
 }
 
 type ErrorDetailsName = `temporal.api.errordetails.v1.${keyof typeof temporal.api.errordetails.v1}`;
+type FailureName = `temporal.api.failure.v1.${keyof typeof temporal.api.failure.v1}`;
 
 /**
  * If the error type can be determined based on embedded grpc error details,
@@ -123,6 +125,27 @@ export function rethrowKnownErrorTypes(err: GrpcServiceError): void {
         const { namespace } = temporal.api.errordetails.v1.NamespaceNotFoundFailure.decode(entry.value);
         throw new NamespaceNotFoundError(namespace);
       }
+      case 'temporal.api.errordetails.v1.MultiOperationExecutionFailure': {
+        // MultiOperationExecutionFailure contains error statuses for multiple
+        // operations. A MultiOperationExecutionAborted error status means that
+        // the corresponding operation was aborted due to an error in one of the
+        // other operations. We rethrow the first operation error that is not
+        // MultiOperationExecutionAborted.
+        const { statuses } = temporal.api.errordetails.v1.MultiOperationExecutionFailure.decode(entry.value);
+        for (const status of statuses) {
+          const detail = status.details?.[0];
+          const statusType = detail?.type_url?.replace(/^type.googleapis.com\//, '') as FailureName | undefined;
+          if (statusType === 'temporal.api.failure.v1.MultiOperationExecutionAborted') {
+            continue;
+          }
+          throw new CustomGrpcServiceError(
+            status.message || err.message,
+            status.code || err.code,
+            detail?.value?.toString() || err.details,
+            err.metadata.getMap()
+          );
+        }
+      }
     }
   }
 }

packages/client/src/interceptors.ts

@@ -42,6 +42,24 @@ export interface WorkflowStartUpdateOutput {
   readonly outcome?: temporal.api.update.v1.IOutcome;
 }
 
+/** Input for WorkflowClientInterceptor.startUpdateWithStart */
+export interface WorkflowStartUpdateWithStartInput {
+  readonly workflowType: string;
+  readonly workflowStartOptions: CompiledWorkflowOptions;
+  readonly workflowStartHeaders: Headers;
+  readonly updateName: string;
+  readonly updateArgs: unknown[];
+  readonly updateOptions: WorkflowUpdateOptions;
+  readonly updateHeaders: Headers;
+}
+
+/** Output for WorkflowClientInterceptor.startUpdateWithStart */
+export interface WorkflowStartUpdateWithStartOutput {
+  readonly updateId: string;
+  readonly workflowRunId: string;
+  readonly outcome?: temporal.api.update.v1.IOutcome;
+}
+
 /** Input for WorkflowClientInterceptor.signal */
 export interface WorkflowSignalInput {
   readonly signalName: string;
@@ -107,6 +125,15 @@ export interface WorkflowClientInterceptor {
     input: WorkflowStartUpdateInput,
     next: Next<this, 'startUpdate'>
   ) => Promise<WorkflowStartUpdateOutput>;
+  /**
+   * Intercept a service call to startUpdateWithStart
+   *
+   * @experimental startUpdateWithStart is an experimental feature.
+   */
+  startUpdateWithStart?: (
+    input: WorkflowStartUpdateWithStartInput,
+    next: Next<this, 'startUpdateWithStart'>
+  ) => Promise<WorkflowStartUpdateWithStartOutput>;
   /**
    * Intercept a service call to signalWorkflowExecution
    *