skip interceptors for future internal updates/signals

Author: THardy98

packages/workflow/src/internals.ts

@@ -724,6 +724,13 @@ export class Activator implements ActivationHandler {
       throw new TypeError(`Cannot use update name: '${name}', with reserved prefix: '${TEMPORAL_RESERVED_PREFIX}'`);
     }
 
+    // Skip interceptors if it's an internal update.
+    const isInternalUpdate =
+      queryType.startsWith(TEMPORAL_RESERVED_PREFIX) ||
+      queryType === STACK_TRACE_RESERVED_NAME ||
+      queryType === ENHANCED_STACK_TRACE_RESERVED_NAME;
+    const interceptors = isInternalUpdate ? [] : this.interceptors.inbound;
+
     const entry =
       this.updateHandlers.get(name) ??
       (this.defaultUpdateHandler
@@ -780,7 +787,7 @@ export class Activator implements ActivationHandler {
       try {
         if (runValidator && entry.validator) {
           const validate = composeInterceptors(
-            this.interceptors.inbound,
+            interceptors,
             'validateUpdate',
             this.validateUpdateNextHandler.bind(this, entry.validator)
           );
@@ -793,7 +800,7 @@ export class Activator implements ActivationHandler {
       }
       this.acceptUpdate(protocolInstanceId);
       const execute = composeInterceptors(
-        this.interceptors.inbound,
+        interceptors,
         'handleUpdate',
         this.updateNextHandler.bind(this, entry.handler)
       );
@@ -883,6 +890,13 @@ export class Activator implements ActivationHandler {
       );
     }
 
+    // Skip interceptors if it's an internal signal.
+    const isInternalSignal =
+      queryType.startsWith(TEMPORAL_RESERVED_PREFIX) ||
+      queryType === STACK_TRACE_RESERVED_NAME ||
+      queryType === ENHANCED_STACK_TRACE_RESERVED_NAME;
+    const interceptors = isInternalSignal ? [] : this.interceptors.inbound;
+
     if (!this.signalHandlers.has(signalName) && !this.defaultSignalHandler) {
       this.bufferedSignals.push(activation);
       return;
@@ -897,7 +911,7 @@ export class Activator implements ActivationHandler {
     const signalExecutionNum = this.signalHandlerExecutionSeq++;
     this.inProgressSignals.set(signalExecutionNum, { name: signalName, unfinishedPolicy });
     const execute = composeInterceptors(
-      this.interceptors.inbound,
+      interceptors,
       'handleSignal',
       this.signalWorkflowNextHandler.bind(this)
     );