iBoss/bolt-diy
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix(chat): rename processedMessage to processedMessages for clarity

Browse Source
This commit is contained in:
Roamin
2025-07-11 04:08:34 +00:00
parent c649e7982e
commit 2b40b8af52
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
app/routes/api.chat.ts
View File

@@ -88,10 +88,10 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
let summary: string | undefined = undefined; let summary: string | undefined = undefined;
let messageSliceId = 0; let messageSliceId = 0;
const processedMessage = await mcpService.processToolInvocations(messages, dataStream); const processedMessages = await mcpService.processToolInvocations(messages, dataStream);
if (processedMessage.length > 3) { if (processedMessages.length > 3) {
messageSliceId = processedMessage.length - 3; messageSliceId = processedMessages.length - 3;
} }
if (filePaths.length > 0 && contextOptimization) { if (filePaths.length > 0 && contextOptimization) {
@@ -105,10 +105,10 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
} satisfies ProgressAnnotation); } satisfies ProgressAnnotation);
// Create a summary of the chat // Create a summary of the chat
console.log(`Messages count: ${processedMessage.length}`); console.log(`Messages count: ${processedMessages.length}`);
summary = await createSummary({ summary = await createSummary({
messages: [...processedMessage], messages: [...processedMessages],
env: context.cloudflare?.env, env: context.cloudflare?.env,
apiKeys, apiKeys,
providerSettings, providerSettings,
@@ -134,7 +134,7 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
dataStream.writeMessageAnnotation({ dataStream.writeMessageAnnotation({
type: 'chatSummary', type: 'chatSummary',
summary, summary,
chatId: processedMessage.slice(-1)?.[0]?.id, chatId: processedMessages.slice(-1)?.[0]?.id,
} as ContextAnnotation); } as ContextAnnotation);
// Update context buffer // Update context buffer
@@ -148,9 +148,9 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
} satisfies ProgressAnnotation); } satisfies ProgressAnnotation);
// Select context files // Select context files
console.log(`Messages count: ${processedMessage.length}`); console.log(`Messages count: ${processedMessages.length}`);
filteredFiles = await selectContext({ filteredFiles = await selectContext({
messages: [...processedMessage], messages: [...processedMessages],
env: context.cloudflare?.env, env: context.cloudflare?.env,
apiKeys, apiKeys,
files, files,
@@ -246,17 +246,17 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
logger.info(`Reached max token limit (${MAX_TOKENS}): Continuing message (${switchesLeft} switches left)`); logger.info(`Reached max token limit (${MAX_TOKENS}): Continuing message (${switchesLeft} switches left)`);
const lastUserMessage = processedMessage.filter((x) => x.role == 'user').slice(-1)[0]; const lastUserMessage = processedMessages.filter((x) => x.role == 'user').slice(-1)[0];
const { model, provider } = extractPropertiesFromMessage(lastUserMessage); const { model, provider } = extractPropertiesFromMessage(lastUserMessage);
processedMessage.push({ id: generateId(), role: 'assistant', content }); processedMessages.push({ id: generateId(), role: 'assistant', content });
processedMessage.push({ processedMessages.push({
id: generateId(), id: generateId(),
role: 'user', role: 'user',
content: `[Model: ${model}]\n\n[Provider: ${provider}]\n\n${CONTINUE_PROMPT}`, content: `[Model: ${model}]\n\n[Provider: ${provider}]\n\n${CONTINUE_PROMPT}`,
}); });
const result = await streamText({ const result = await streamText({
messages: [...processedMessage], messages: [...processedMessages],
env: context.cloudflare?.env, env: context.cloudflare?.env,
options, options,
apiKeys, apiKeys,
@@ -297,7 +297,7 @@ async function chatAction({ context, request }: ActionFunctionArgs) {
} satisfies ProgressAnnotation); } satisfies ProgressAnnotation);
const result = await streamText({ const result = await streamText({
messages: [...processedMessage], messages: [...processedMessages],
env: context.cloudflare?.env, env: context.cloudflare?.env,
options, options,
apiKeys, apiKeys,