mirrors/pikasTech-HWLAB
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(workbench): query latest message facts by default (#2016)

Browse Source
This commit is contained in:
Lyon
2026-06-24 05:20:57 +08:00
committed by GitHub
parent 7ad24b56c8
commit 6f02aa095d
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/cloud/server-workbench-http.ts
+7 -4
View File
@@ -1436,7 +1436,13 @@ async function handleWorkbenchSessionDetail(request, response, options, actor, s
async function handleWorkbenchMessagePage(request, response, url, options, actor, sessionId) { async function handleWorkbenchMessagePage(request, response, url, options, actor, sessionId) {
const readModel = workbenchRuntimeFactsReadModel(request, options, actor); const readModel = workbenchRuntimeFactsReadModel(request, options, actor);
const result = await queryFactsByRouteId(readModel, sessionId, { families: WORKBENCH_SESSION_MESSAGE_PAGE_FAMILIES }); const limit = boundedLimit(url.searchParams.get("limit"));
const cursorParam = url.searchParams.get("cursor") ?? url.searchParams.get("after");
const hasCursor = Boolean(textValue(cursorParam));
const result = await queryFactsByRouteId(readModel, sessionId, {
families: WORKBENCH_SESSION_MESSAGE_PAGE_FAMILIES,
...(hasCursor ? {} : { limit, messagesOrder: "updated_desc", partsOrder: "updated_desc", turnsOrder: "updated_desc", checkpointsOrder: "updated_desc" })
});
if (result.error) return sendJson(response, 503, workbenchProjectionStoreError(result.error)); if (result.error) return sendJson(response, 503, workbenchProjectionStoreError(result.error));
const session = visibleFactSessions(result.facts, actor)[0] ?? null; const session = visibleFactSessions(result.facts, actor)[0] ?? null;
if (!session) { if (!session) {
@@ -1445,9 +1451,6 @@ async function handleWorkbenchMessagePage(request, response, url, options, actor
return sendJson(response, 404, body); return sendJson(response, 404, body);
} }
const messages = factMessagesForSession(session, result.facts); const messages = factMessagesForSession(session, result.facts);
const limit = boundedLimit(url.searchParams.get("limit"));
const cursorParam = url.searchParams.get("cursor") ?? url.searchParams.get("after");
const hasCursor = Boolean(textValue(cursorParam));
const offset = hasCursor ? cursorOffset(cursorParam) : Math.max(0, messages.length - limit); const offset = hasCursor ? cursorOffset(cursorParam) : Math.max(0, messages.length - limit);
const page = messages.slice(offset, offset + limit); const page = messages.slice(offset, offset + limit);
const nextOffset = offset + page.length; const nextOffset = offset + page.length;