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

Merge pull request #2202 from pikasTech/fix/2194-workbench-terminal-timing

Browse Source 
fix: seal terminal Workbench projection timing
This commit is contained in:
Lyon
2026-06-26 17:05:03 +08:00
committed by GitHub
parent 2b10e38eb0 3708bb3653
commit 9a367582d5
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
web/hwlab-cloud-web/src/stores/workbench.ts
+21
View File
@@ -1951,6 +1951,7 @@ function messageTimingPatchForMerge(message: ChatMessage, value: unknown): Parti
function messageTimingSealPatchForProjectionMerge(message: ChatMessage, previous: ChatMessage | null): Partial<ChatMessage> {
if (previous && isProjectionRunningAgentMessageForTiming(previous) && isProjectionRunningAgentMessageForTiming(message)) return messageRunningSealPatchForProjectionMerge(message, previous);
if (previous && isProjectionRunningAgentMessageForTiming(previous) && isTerminalMessageStatus(message.status)) return messageTerminalFromRunningSealPatchForProjectionMerge(message, previous);
return messageTerminalSealPatchForProjectionMerge(message, previous);
}
@@ -1987,6 +1988,26 @@ function isProjectionRunningAgentMessageForTiming(message: ChatMessage): boolean
return status === null || isTraceActiveStatus(status) || message.traceAutoLifecycle === "running";
}
function messageTerminalFromRunningSealPatchForProjectionMerge(message: ChatMessage, previous: ChatMessage): Partial<ChatMessage> {
const incomingPatch = terminalMessageTimingPatchForNormalize(message);
const incomingTiming = normalizeTimingProjection(incomingPatch) ?? normalizeTimingProjection(message);
const previousTiming = normalizeTimingProjection(previous);
const runningDuration = runningDurationFromTiming(previousTiming);
if (runningDuration === null) return incomingPatch;
const incomingDuration = firstPositiveFiniteNumber(incomingTiming?.durationMs) ?? positiveDurationBetween(incomingTiming?.startedAt, incomingTiming?.finishedAt) ?? positiveDurationBetween(incomingTiming?.startedAt, incomingTiming?.lastEventAt);
const durationMs = Math.max(incomingDuration ?? 0, runningDuration);
const finishedAt = incomingTiming?.finishedAt ?? incomingTiming?.lastEventAt ?? new Date().toISOString();
const timing = {
...(incomingTiming ?? {}),
startedAt: previousTiming?.startedAt ?? incomingTiming?.startedAt ?? null,
lastEventAt: incomingTiming?.lastEventAt ?? finishedAt,
finishedAt,
durationMs,
valuesRedacted: incomingTiming?.valuesRedacted !== false && previousTiming?.valuesRedacted !== false,
} as WorkbenchTurnTimingProjection;
return messageTimingPatchFromProjection(timing);
}
function messageTerminalSealPatchForProjectionMerge(message: ChatMessage, previous: ChatMessage | null): Partial<ChatMessage> {
const incomingTimingPatch = messageTimingPatch(message);
if (!previous || !isTerminalMessageStatus(previous.status)) return incomingTimingPatch;