File size: 3,670 Bytes
4c76b0d | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 | import { deliveryContextFromConversation } from "../../../channels/route-projection.js";
import {
resolveThreadBindingIntroText,
resolveThreadBindingThreadName,
} from "../../../channels/thread-bindings-messages.js";
import {
resolveThreadBindingIdleTimeoutMsForChannel,
resolveThreadBindingMaxAgeMsForChannel,
} from "../../../channels/thread-bindings-policy.js";
import type { OpenClawConfig } from "../../../config/types.openclaw.js";
import type { DeliveryContext } from "../../../utils/delivery-context.types.js";
import { summarizeSpawnError } from "../../spawn-pipeline.js";
import { prepareSpawnThreadBinding } from "../../spawn-plan.js";
import { getSessionBindingService } from "./subagent-spawn.runtime.js";
import type { SpawnSubagentMode } from "./subagent-spawn.types.js";
export async function bindThreadForSubagentSpawn(params: {
assertActive?: () => void;
cfg: OpenClawConfig;
childSessionKey: string;
agentId: string;
label?: string;
mode: SpawnSubagentMode;
requesterSessionKey?: string;
requester: {
channel?: string;
accountId?: string;
to?: string;
threadId?: string | number;
};
}): Promise<
| { status: "ok"; deliveryOrigin?: DeliveryContext }
| {
status: "error";
error: string;
}
> {
const prepared = prepareSpawnThreadBinding({
cfg: params.cfg,
kind: "subagent",
mode: params.mode,
bindingService: getSessionBindingService(),
requesterSessionKey: params.requesterSessionKey,
channel: params.requester.channel,
accountId: params.requester.accountId,
to: params.requester.to,
threadId: params.requester.threadId,
});
if (!prepared.ok) {
return {
status: "error",
error: prepared.error,
};
}
try {
params.assertActive?.();
const binding = await getSessionBindingService().bind({
targetSessionKey: params.childSessionKey,
targetKind: "subagent",
conversation: {
channel: prepared.binding.channel,
accountId: prepared.binding.accountId,
conversationId: prepared.binding.conversationId,
...(prepared.binding.parentConversationId
? { parentConversationId: prepared.binding.parentConversationId }
: {}),
},
placement: prepared.binding.placement,
metadata: {
threadName: resolveThreadBindingThreadName({
agentId: params.agentId,
label: params.label || params.agentId,
}),
agentId: params.agentId,
label: params.label || undefined,
boundBy: "system",
introText: resolveThreadBindingIntroText({
agentId: params.agentId,
label: params.label || undefined,
idleTimeoutMs: resolveThreadBindingIdleTimeoutMsForChannel({
cfg: params.cfg,
channel: prepared.binding.channel,
accountId: prepared.binding.accountId,
}),
maxAgeMs: resolveThreadBindingMaxAgeMsForChannel({
cfg: params.cfg,
channel: prepared.binding.channel,
accountId: prepared.binding.accountId,
}),
}),
},
});
if (!binding.conversation.conversationId) {
return {
status: "error",
error:
"Unable to create or bind a thread for this subagent session. Session mode is unavailable for this target.",
};
}
const deliveryOrigin = deliveryContextFromConversation(binding.conversation);
return {
status: "ok",
...(deliveryOrigin ? { deliveryOrigin } : {}),
};
} catch (err) {
return {
status: "error",
error: `Thread bind failed: ${summarizeSpawnError(err)}`,
};
}
}
|