LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-03-09 15:35:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Subagents: fallback completion announce to internal session when outbound route is incomplete

Browse Source
This commit is contained in:
Sahil Satralkar
2026-02-23 21:51:28 +05:30
committed by Peter Steinberger
parent 28d658e178
commit f9ffd41cfa
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -731,6 +731,16 @@ async function sendSubagentAnnounceDirectly(params: {
}
const directOrigin = normalizeDeliveryContext(params.directOrigin);
const directChannelRaw =
typeof directOrigin?.channel === "string" ? directOrigin.channel.trim() : "";
const directChannel =
directChannelRaw && isDeliverableMessageChannel(directChannelRaw) ? directChannelRaw : "";
const directTo = typeof directOrigin?.to === "string" ? directOrigin.to.trim() : "";
const hasDeliverableDirectTarget =
!params.requesterIsSubagent && Boolean(directChannel) && Boolean(directTo);
const shouldDeliverExternally =
!params.requesterIsSubagent &&
(!params.expectsCompletionMessage || hasDeliverableDirectTarget);
const threadId =
directOrigin?.threadId != null && directOrigin.threadId !== ""
? String(directOrigin.threadId)
@@ -746,12 +756,12 @@ async function sendSubagentAnnounceDirectly(params: {
params: {
sessionKey: canonicalRequesterSessionKey,
message: params.triggerMessage,
deliver: !params.requesterIsSubagent,
deliver: shouldDeliverExternally,
bestEffortDeliver: params.bestEffortDeliver,
channel: params.requesterIsSubagent ? undefined : directOrigin?.channel,
accountId: params.requesterIsSubagent ? undefined : directOrigin?.accountId,
to: params.requesterIsSubagent ? undefined : directOrigin?.to,
threadId: params.requesterIsSubagent ? undefined : threadId,
channel: shouldDeliverExternally ? directChannel : undefined,
accountId: shouldDeliverExternally ? directOrigin?.accountId : undefined,
to: shouldDeliverExternally ? directTo : undefined,
threadId: shouldDeliverExternally ? threadId : undefined,
idempotencyKey: params.directIdempotencyKey,
},
expectFinal: true,