Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix on the done tool to get results in before race condition

This commit is contained in:
dal 2025-08-25 15:28:26 -06:00
parent e97ec9c002
commit fb1a49f498
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/ai/src/tools/communication-tools/done-tool/done-tool-start.ts
View File

@ -1,7 +1,8 @@
import { updateChat, updateMessage, updateMessageEntries } from '@buster/database';
import type { ToolCallOptions } from 'ai';
import type { UpdateMessageEntriesParams } from '../../../../../database/src/queries/messages/update-message-entries';
import type { DoneToolContext, DoneToolState } from './done-tool';
import { createRawToolResultEntry } from '../../shared/create-raw-llm-tool-result-entry';
import { DONE_TOOL_NAME, type DoneToolContext, type DoneToolState } from './done-tool';
import {
createFileResponseMessages,
extractAllFilesForChatUpdate,
@ -102,6 +103,14 @@ export function createDoneToolStart(context: DoneToolContext, doneToolState: Don
const doneToolResponseEntry = createDoneToolResponseMessage(doneToolState, options.toolCallId);
const doneToolMessage = createDoneToolRawLlmMessageEntry(doneToolState, options.toolCallId);
// Create the tool result immediately with success: true
// This ensures it's always present even if the stream terminates early
const rawToolResultEntry = createRawToolResultEntry(
options.toolCallId,
DONE_TOOL_NAME,
{ success: true }
);
const entries: UpdateMessageEntriesParams = {
messageId: context.messageId,
};
@ -110,8 +119,16 @@ export function createDoneToolStart(context: DoneToolContext, doneToolState: Don
entries.responseMessages = [doneToolResponseEntry];
}
// Include both the tool call and tool result in raw LLM messages
// Since it's an upsert, sending both together ensures completeness
const rawLlmMessages = [];
if (doneToolMessage) {
entries.rawLlmMessages = [doneToolMessage];
rawLlmMessages.push(doneToolMessage);
}
rawLlmMessages.push(rawToolResultEntry);
if (rawLlmMessages.length > 0) {
entries.rawLlmMessages = rawLlmMessages;
}
try {