yuanyeex
/
openclaw
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: clarify subagent announce origin 

Co-authored-by: adam91holt <adam91holt@users.noreply.github.com>
main
Peter Steinberger 2026-01-17 04:33:12 +00:00
parent 5fcc9b3244
commit 19ee6699d2
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/agents/subagent-announce.ts
View File

@ -114,6 +114,15 @@ type AnnounceQueueState = {
const ANNOUNCE_QUEUES = new Map<string, AnnounceQueueState>(); const ANNOUNCE_QUEUES = new Map<string, AnnounceQueueState>();
type DeliveryContextSource = Parameters<typeof deliveryContextFromSession>[0];
function resolveAnnounceOrigin(
entry?: DeliveryContextSource,
requesterOrigin?: DeliveryContext,
): DeliveryContext | undefined {
return mergeDeliveryContext(deliveryContextFromSession(entry), requesterOrigin);
}
function getAnnounceQueue( function getAnnounceQueue(
key: string, key: string,
settings: { mode: QueueMode; debounceMs?: number; cap?: number; dropPolicy?: QueueDropPolicy }, settings: { mode: QueueMode; debounceMs?: number; cap?: number; dropPolicy?: QueueDropPolicy },
@ -383,7 +392,7 @@ async function maybeQueueSubagentAnnounce(params: {
queueSettings.mode === "steer-backlog" || queueSettings.mode === "steer-backlog" ||
queueSettings.mode === "interrupt"; queueSettings.mode === "interrupt";
if (isActive && (shouldFollowup || queueSettings.mode === "steer")) { if (isActive && (shouldFollowup || queueSettings.mode === "steer")) {
const origin = mergeDeliveryContext(deliveryContextFromSession(entry), params.requesterOrigin); const origin = resolveAnnounceOrigin(entry, params.requesterOrigin);
enqueueAnnounce( enqueueAnnounce(
canonicalKey, canonicalKey,
{ {