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

Merge pull request #1331 from pikasTech/fix/1329-last-trace-summary

Browse Source 
fix(api): keep conversation lastTrace on current turn
This commit is contained in:
Lyon
2026-06-16 15:01:47 +08:00
committed by GitHub
parent 1fea791611 355bfcdc00
commit 917097cc66
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/cloud/access-control.ts
+19 -1
View File
@@ -2757,7 +2757,8 @@ function resolvedConversationLastTraceId(storedTraceId, status, messages = [], s
const snapshotTraceId = textOr(snapshot.lastTraceId, "");
const stored = textOr(storedTraceId, "");
const snapshotStatus = textOr(snapshot.sessionStatus ?? snapshot.status, "").toLowerCase();
if (latestTraceId && (isActiveConversationStatus(latestStatus) || isActiveConversationStatus(status))) return latestTraceId;
const latestTurnTraceId = latestConversationTurnTraceId(messages);
if (latestTurnTraceId && (latestTurnTraceId !== stored || isActiveConversationStatus(status))) return latestTurnTraceId;
if (stored && snapshotStatus && !isActiveConversationStatus(snapshotStatus)) return stored;
if (!isActiveConversationStatus(status)) {
return latestTraceId || snapshotTraceId || stored;
@@ -2773,6 +2774,23 @@ function isTerminalConversationStatus(value) {
return ["completed", "failed", "blocked", "timeout", "canceled", "cancelled", "stale", "thread-resume-failed", "interrupted", "expired"].includes(textOr(value, "").toLowerCase().replace(/_/gu, "-"));
}
function latestConversationTurnTraceId(messages = []) {
if (!Array.isArray(messages)) return "";
for (let index = messages.length - 1; index >= 0; index -= 1) {
const message = messages[index];
if (String(message?.role ?? "").toLowerCase() !== "agent") continue;
const traceId = textOr(message?.traceId, "");
if (!traceId) return "";
for (let prev = index - 1; prev >= 0; prev -= 1) {
const previous = messages[prev];
if (String(previous?.role ?? "").toLowerCase() !== "user") continue;
return textOr(previous?.traceId, "") === traceId ? traceId : "";
}
return "";
}
return "";
}
function latestAgentConversationMessage(messages = []) {
if (!Array.isArray(messages)) return null;
for (const message of [...messages].reverse()) {