let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

auto-reply: surface tool args from rpc start events

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-03 13:31:43 +00:00
parent 3354a68373
commit 3a8d6b80e0
1 changed files with 44 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/auto-reply/command-reply.ts
View File

@@ -414,6 +414,7 @@ export async function runCommandReply(
let pendingToolName: string | undefined; let pendingToolName: string | undefined;
let pendingMetas: string[] = []; let pendingMetas: string[] = [];
let pendingTimer: NodeJS.Timeout | null = null; let pendingTimer: NodeJS.Timeout | null = null;
const toolMetaById = new Map<string, string | undefined>();
const flushPendingTool = () => { const flushPendingTool = () => {
if (!onPartialReply) return; if (!onPartialReply) return;
if (!pendingToolName && pendingMetas.length === 0) return; if (!pendingToolName && pendingMetas.length === 0) return;
@@ -488,15 +489,57 @@ export async function runCommandReply(
content?: unknown[]; content?: unknown[];
details?: Record<string, unknown>; details?: Record<string, unknown>;
arguments?: Record<string, unknown>; arguments?: Record<string, unknown>;
toolCallId?: string;
tool_call_id?: string;
toolName?: string;
name?: string;
}; };
toolCallId?: string;
toolName?: string;
args?: Record<string, unknown>;
}; };
// Capture metadata as soon as the tool starts (from args).
if (ev.type === "tool_execution_start") {
const toolName = ev.toolName;
const meta = inferToolMeta({
toolName,
name: ev.toolName,
arguments: ev.args,
});
if (ev.toolCallId) {
toolMetaById.set(ev.toolCallId, meta);
}
if (meta) {
if (pendingToolName && toolName && toolName !== pendingToolName) {
flushPendingTool();
}
if (!pendingToolName) pendingToolName = toolName;
pendingMetas.push(meta);
if (
TOOL_RESULT_FLUSH_COUNT > 0 &&
pendingMetas.length >= TOOL_RESULT_FLUSH_COUNT
) {
flushPendingTool();
} else {
if (pendingTimer) clearTimeout(pendingTimer);
pendingTimer = setTimeout(
flushPendingTool,
TOOL_RESULT_DEBOUNCE_MS,
);
}
}
}
if ( if (
(ev.type === "message" || ev.type === "message_end") && (ev.type === "message" || ev.type === "message_end") &&
ev.message?.role === "tool_result" && ev.message?.role === "tool_result" &&
Array.isArray(ev.message.content) Array.isArray(ev.message.content)
) { ) {
const toolName = inferToolName(ev.message); const toolName = inferToolName(ev.message);
const meta = inferToolMeta(ev.message); const toolCallId =
ev.message.toolCallId ?? ev.message.tool_call_id;
const meta =
inferToolMeta(ev.message) ??
(toolCallId ? toolMetaById.get(toolCallId) : undefined);
if ( if (
pendingToolName && pendingToolName &&
toolName && toolName &&