fix: pass sessionKey to deliverOutboundPayloads for message:sent hook dispatch

Lucas Teixeira Campos Araujo · steipete · commit a4408a917eab · 2026-02-26T19:56:27.000Z
Several call sites of deliverOutboundPayloads() were not passing the
sessionKey parameter, causing the internal message:sent hook to never
fire (the guard `if (!sessionKeyForInternalHooks) return` in deliver.ts
silently skipped the triggerInternalHook call).

Fixed call sites:
- commands/agent/delivery.ts (agent loop replies — main fix)
- infra/heartbeat-runner.ts (heartbeat OK + alert delivery)
- infra/outbound/message.ts (message tool sends)
- cron/isolated-agent/delivery-dispatch.ts (cron job delivery)
- gateway/server-node-events.ts (node event forwarding)

The sessionKey parameter already existed in DeliverOutboundPayloadsCoreParams
and was used by deliver.ts to emit the message:sent internal hook event,
but was simply not being passed from most callers.
diff --git a/src/commands/agent/delivery.ts b/src/commands/agent/delivery.ts
@@ -230,6 +230,7 @@ export async function deliverAgentCommandResult(params: {
         onError: (err) => logDeliveryError(err),
         onPayload: logPayload,
         deps: createOutboundSendDeps(deps),
+        sessionKey: opts.sessionKey,
       });
     }
   }
diff --git a/src/cron/isolated-agent/delivery-dispatch.ts b/src/cron/isolated-agent/delivery-dispatch.ts
@@ -182,6 +182,7 @@ export async function dispatchCronDelivery(
         bestEffort: params.deliveryBestEffort,
         deps: createOutboundSendDeps(params.deps),
         abortSignal: params.abortSignal,
+        sessionKey: params.agentSessionKey,
       });
       delivered = deliveryResults.length > 0;
       return null;
diff --git a/src/gateway/server-node-events.ts b/src/gateway/server-node-events.ts
@@ -241,6 +241,7 @@ async function sendReceiptAck(params: {
     agentId,
     bestEffort: true,
     deps: createOutboundSendDeps(params.deps),
+    sessionKey: params.sessionKey,
   });
 }
 
diff --git a/src/infra/heartbeat-runner.ts b/src/infra/heartbeat-runner.ts
@@ -723,6 +723,7 @@ export async function runHeartbeatOnce(opts: {
       payloads: [{ text: heartbeatOkText }],
       agentId,
       deps: opts.deps,
+      sessionKey,
     });
     return true;
   };
@@ -928,6 +929,7 @@ export async function runHeartbeatOnce(opts: {
             ]),
       ],
       deps: opts.deps,
+      sessionKey,
     });
 
     // Record last delivered heartbeat payload for dedupe.
diff --git a/src/infra/outbound/message.ts b/src/infra/outbound/message.ts
@@ -233,6 +233,7 @@ export async function sendMessage(params: MessageSendParams): Promise<MessageSen
             mediaUrls: mirrorMediaUrls.length ? mirrorMediaUrls : undefined,
           }
         : undefined,
+      sessionKey: params.mirror?.sessionKey,
     });
 
     return {

Original file line number	Diff line number	Diff line change
`@@ -230,6 +230,7 @@ export async function deliverAgentCommandResult(params: {`
`230`	`230`	`onError: (err) => logDeliveryError(err),`
`231`	`231`	`onPayload: logPayload,`
`232`	`232`	`deps: createOutboundSendDeps(deps),`
	`233`	`+ sessionKey: opts.sessionKey,`
`233`	`234`	`});`
`234`	`235`	`}`
`235`	`236`	`}`
Original file line number	Diff line number	Diff line change
`@@ -241,6 +241,7 @@ async function sendReceiptAck(params: {`
`241`	`241`	`agentId,`
`242`	`242`	`bestEffort: true,`
`243`	`243`	`deps: createOutboundSendDeps(params.deps),`
	`244`	`+ sessionKey: params.sessionKey,`
`244`	`245`	`});`
`245`	`246`	`}`
`246`	`247`
Original file line number	Diff line number	Diff line change
`@@ -233,6 +233,7 @@ export async function sendMessage(params: MessageSendParams): Promise<MessageSen`
`233`	`233`	`mediaUrls: mirrorMediaUrls.length ? mirrorMediaUrls : undefined,`
`234`	`234`	`}`
`235`	`235`	`: undefined,`
	`236`	`+ sessionKey: params.mirror?.sessionKey,`
`236`	`237`	`});`
`237`	`238`
`238`	`239`	`return {`