* docs: thread-bound subagents plan * docs: add exact thread-bound subagent implementation touchpoints * Docs: prioritize auto thread-bound subagent flow * Docs: add ACP harness thread-binding extensions * Discord: add thread-bound session routing and auto-bind spawn flow * Subagents: add focus commands and ACP/session binding lifecycle hooks * Tests: cover thread bindings, focus commands, and ACP unbind hooks * Docs: add plugin-hook appendix for thread-bound subagents * Plugins: add subagent lifecycle hook events * Core: emit subagent lifecycle hooks and decouple Discord bindings * Discord: handle subagent bind lifecycle via plugin hooks * Subagents: unify completion finalizer and split registry modules * Add subagent lifecycle events module * Hooks: fix subagent ended context key * Discord: share thread bindings across ESM and Jiti * Subagents: add persistent sessions_spawn mode for thread-bound sessions * Subagents: clarify thread intro and persistent completion copy * test(subagents): stabilize sessions_spawn lifecycle cleanup assertions * Discord: add thread-bound session TTL with auto-unfocus * Subagents: fail session spawns when thread bind fails * Subagents: cover thread session failure cleanup paths * Session: add thread binding TTL config and /session ttl controls * Tests: align discord reaction expectations * Agent: persist sessionFile for keyed subagent sessions * Discord: normalize imports after conflict resolution * Sessions: centralize sessionFile resolve/persist helper * Discord: harden thread-bound subagent session routing * Rebase: resolve upstream/main conflicts * Subagents: move thread binding into hooks and split bindings modules * Docs: add channel-agnostic subagent routing hook plan * Agents: decouple subagent routing from Discord * Discord: refactor thread-bound subagent flows * Subagents: prevent duplicate end hooks and orphaned failed sessions * Refactor: split subagent command and provider phases * Subagents: honor hook delivery target overrides * Discord: add thread binding kill switches and refresh plan doc * Discord: fix thread bind channel resolution * Routing: centralize account id normalization * Discord: clean up thread bindings on startup failures * Discord: add startup cleanup regression tests * Docs: add long-term thread-bound subagent architecture * Docs: split session binding plan and dedupe thread-bound doc * Subagents: add channel-agnostic session binding routing * Subagents: stabilize announce completion routing tests * Subagents: cover multi-bound completion routing * Subagents: suppress lifecycle hooks on failed thread bind * tests: fix discord provider mock typing regressions * docs/protocol: sync slash command aliases and delete param models * fix: add changelog entry for Discord thread-bound subagents (#21805) (thanks @onutc) --------- Co-authored-by: Shadow <hi@shadowing.dev>
159 lines
4.3 KiB
TypeScript
159 lines
4.3 KiB
TypeScript
import fs from "node:fs";
|
|
import path from "node:path";
|
|
import { CURRENT_SESSION_VERSION, SessionManager } from "@mariozechner/pi-coding-agent";
|
|
import { emitSessionTranscriptUpdate } from "../../sessions/transcript-events.js";
|
|
import { resolveDefaultSessionStorePath } from "./paths.js";
|
|
import { resolveAndPersistSessionFile } from "./session-file.js";
|
|
import { loadSessionStore } from "./store.js";
|
|
import type { SessionEntry } from "./types.js";
|
|
|
|
function stripQuery(value: string): string {
|
|
const noHash = value.split("#")[0] ?? value;
|
|
return noHash.split("?")[0] ?? noHash;
|
|
}
|
|
|
|
function extractFileNameFromMediaUrl(value: string): string | null {
|
|
const trimmed = value.trim();
|
|
if (!trimmed) {
|
|
return null;
|
|
}
|
|
const cleaned = stripQuery(trimmed);
|
|
try {
|
|
const parsed = new URL(cleaned);
|
|
const base = path.basename(parsed.pathname);
|
|
if (!base) {
|
|
return null;
|
|
}
|
|
try {
|
|
return decodeURIComponent(base);
|
|
} catch {
|
|
return base;
|
|
}
|
|
} catch {
|
|
const base = path.basename(cleaned);
|
|
if (!base || base === "/" || base === ".") {
|
|
return null;
|
|
}
|
|
return base;
|
|
}
|
|
}
|
|
|
|
export function resolveMirroredTranscriptText(params: {
|
|
text?: string;
|
|
mediaUrls?: string[];
|
|
}): string | null {
|
|
const mediaUrls = params.mediaUrls?.filter((url) => url && url.trim()) ?? [];
|
|
if (mediaUrls.length > 0) {
|
|
const names = mediaUrls
|
|
.map((url) => extractFileNameFromMediaUrl(url))
|
|
.filter((name): name is string => Boolean(name && name.trim()));
|
|
if (names.length > 0) {
|
|
return names.join(", ");
|
|
}
|
|
return "media";
|
|
}
|
|
|
|
const text = params.text ?? "";
|
|
const trimmed = text.trim();
|
|
return trimmed ? trimmed : null;
|
|
}
|
|
|
|
async function ensureSessionHeader(params: {
|
|
sessionFile: string;
|
|
sessionId: string;
|
|
}): Promise<void> {
|
|
if (fs.existsSync(params.sessionFile)) {
|
|
return;
|
|
}
|
|
await fs.promises.mkdir(path.dirname(params.sessionFile), { recursive: true });
|
|
const header = {
|
|
type: "session",
|
|
version: CURRENT_SESSION_VERSION,
|
|
id: params.sessionId,
|
|
timestamp: new Date().toISOString(),
|
|
cwd: process.cwd(),
|
|
};
|
|
await fs.promises.writeFile(params.sessionFile, `${JSON.stringify(header)}\n`, {
|
|
encoding: "utf-8",
|
|
mode: 0o600,
|
|
});
|
|
}
|
|
|
|
export async function appendAssistantMessageToSessionTranscript(params: {
|
|
agentId?: string;
|
|
sessionKey: string;
|
|
text?: string;
|
|
mediaUrls?: string[];
|
|
/** Optional override for store path (mostly for tests). */
|
|
storePath?: string;
|
|
}): Promise<{ ok: true; sessionFile: string } | { ok: false; reason: string }> {
|
|
const sessionKey = params.sessionKey.trim();
|
|
if (!sessionKey) {
|
|
return { ok: false, reason: "missing sessionKey" };
|
|
}
|
|
|
|
const mirrorText = resolveMirroredTranscriptText({
|
|
text: params.text,
|
|
mediaUrls: params.mediaUrls,
|
|
});
|
|
if (!mirrorText) {
|
|
return { ok: false, reason: "empty text" };
|
|
}
|
|
|
|
const storePath = params.storePath ?? resolveDefaultSessionStorePath(params.agentId);
|
|
const store = loadSessionStore(storePath, { skipCache: true });
|
|
const entry = store[sessionKey] as SessionEntry | undefined;
|
|
if (!entry?.sessionId) {
|
|
return { ok: false, reason: `unknown sessionKey: ${sessionKey}` };
|
|
}
|
|
|
|
let sessionFile: string;
|
|
try {
|
|
const resolvedSessionFile = await resolveAndPersistSessionFile({
|
|
sessionId: entry.sessionId,
|
|
sessionKey,
|
|
sessionStore: store,
|
|
storePath,
|
|
sessionEntry: entry,
|
|
agentId: params.agentId,
|
|
sessionsDir: path.dirname(storePath),
|
|
});
|
|
sessionFile = resolvedSessionFile.sessionFile;
|
|
} catch (err) {
|
|
return {
|
|
ok: false,
|
|
reason: err instanceof Error ? err.message : String(err),
|
|
};
|
|
}
|
|
|
|
await ensureSessionHeader({ sessionFile, sessionId: entry.sessionId });
|
|
|
|
const sessionManager = SessionManager.open(sessionFile);
|
|
sessionManager.appendMessage({
|
|
role: "assistant",
|
|
content: [{ type: "text", text: mirrorText }],
|
|
api: "openai-responses",
|
|
provider: "openclaw",
|
|
model: "delivery-mirror",
|
|
usage: {
|
|
input: 0,
|
|
output: 0,
|
|
cacheRead: 0,
|
|
cacheWrite: 0,
|
|
totalTokens: 0,
|
|
cost: {
|
|
input: 0,
|
|
output: 0,
|
|
cacheRead: 0,
|
|
cacheWrite: 0,
|
|
total: 0,
|
|
},
|
|
},
|
|
stopReason: "stop",
|
|
timestamp: Date.now(),
|
|
});
|
|
|
|
emitSessionTranscriptUpdate(sessionFile);
|
|
return { ok: true, sessionFile };
|
|
}
|