Skip to content

Commit 1cdd831

Browse files
nits
1 parent dbf2739 commit 1cdd831

File tree

2 files changed

+17
-13
lines changed

2 files changed

+17
-13
lines changed

packages/web/src/app/api/(server)/chat/blocking/route.ts

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ export const POST = apiHandler(async (request: NextRequest) => {
135135
parts: [{ type: 'text', text: query }],
136136
};
137137

138-
const selectedSearchScopes = await Promise.all(repos.map(async (repo) => {
138+
const selectedRepos = (await Promise.all(repos.map(async (repo) => {
139139
const repoDB = await prisma.repo.findFirst({
140140
where: {
141141
name: repo,
@@ -156,24 +156,26 @@ export const POST = apiHandler(async (request: NextRequest) => {
156156
name: repoDB.displayName ?? repoDB.name.split('/').pop() ?? repoDB.name,
157157
codeHostType: repoDB.external_codeHostType,
158158
} satisfies SearchScope;
159-
}));
159+
})));
160160

161161
// We'll capture the final messages and usage from the stream
162162
let finalMessages: SBChatMessage[] = [];
163163

164-
const expandedRepos = selectedSearchScopes.map(s => s.value);
165-
166164
await captureEvent('wa_chat_message_sent', {
167165
chatId: chat.id,
168166
messageCount: 1,
169-
...(env.EXPERIMENT_ASK_GH_ENABLED === 'true' ? { selectedRepos: expandedRepos } : {}),
167+
...(env.EXPERIMENT_ASK_GH_ENABLED === 'true' ? {
168+
selectedRepos: selectedRepos.map(r => r.value)
169+
} : {}),
170170
});
171171

172172
const stream = await createMessageStream({
173173
chatId: chat.id,
174174
messages: [userMessage],
175-
selectedSearchScopes,
176-
selectedRepos: expandedRepos,
175+
metadata: {
176+
selectedSearchScopes: selectedRepos,
177+
},
178+
selectedRepos: selectedRepos.map(r => r.value),
177179
model,
178180
modelName,
179181
modelProviderOptions: providerOptions,

packages/web/src/app/api/(server)/chat/route.ts

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { sew } from "@/actions";
22
import { _getConfiguredLanguageModelsFull, _getAISDKLanguageModelAndOptions, _updateChatMessages, _isOwnerOfChat } from "@/features/chat/actions";
33
import { createAgentStream } from "@/features/chat/agent";
4-
import { additionalChatRequestParamsSchema, LanguageModelInfo, SBChatMessage, SearchScope } from "@/features/chat/types";
4+
import { additionalChatRequestParamsSchema, LanguageModelInfo, SBChatMessage, SBChatMessageMetadata, SearchScope } from "@/features/chat/types";
55
import { getAnswerPartFromAssistantMessage, getLanguageModelKey } from "@/features/chat/utils";
66
import { apiHandler } from "@/lib/apiHandler";
77
import { ErrorCode } from "@/lib/errorCodes";
@@ -109,7 +109,9 @@ export const POST = apiHandler(async (req: NextRequest) => {
109109
const stream = await createMessageStream({
110110
chatId: id,
111111
messages,
112-
selectedSearchScopes,
112+
metadata: {
113+
selectedSearchScopes,
114+
},
113115
selectedRepos: expandedRepos,
114116
model,
115117
modelName: languageModelConfig.displayName ?? languageModelConfig.model,
@@ -163,19 +165,19 @@ const mergeStreamAsync = async (stream: StreamTextResult<any, any>, writer: UIMe
163165
interface CreateMessageStreamResponseProps {
164166
chatId: string;
165167
messages: SBChatMessage[];
166-
selectedSearchScopes: SearchScope[];
167168
selectedRepos: string[];
168169
model: AISDKLanguageModelV2;
169170
modelName: string;
170-
modelProviderOptions?: Record<string, Record<string, JSONValue>>;
171171
onFinish: UIMessageStreamOnFinishCallback<SBChatMessage>;
172172
onError: (error: unknown) => string;
173+
modelProviderOptions?: Record<string, Record<string, JSONValue>>;
174+
metadata?: Partial<SBChatMessageMetadata>;
173175
}
174176

175177
export const createMessageStream = async ({
176178
chatId,
177179
messages,
178-
selectedSearchScopes,
180+
metadata,
179181
selectedRepos,
180182
model,
181183
modelName,
@@ -252,8 +254,8 @@ export const createMessageStream = async ({
252254
totalOutputTokens: totalUsage.outputTokens,
253255
totalResponseTimeMs: new Date().getTime() - startTime.getTime(),
254256
modelName,
255-
selectedSearchScopes,
256257
traceId,
258+
...metadata,
257259
}
258260
});
259261

0 commit comments

Comments
 (0)