wehub-resource-sync
e4dcfc49aa
Tests / Import Check (Python 3.13) (push) Has been cancelled
Tests / Import Check (Python 3.14) (push) Has been cancelled
Tests / Python Tests (Python 3.11) (push) Has been cancelled
Tests / Python Tests (Python 3.12) (push) Has been cancelled
Tests / Python Tests (Python 3.14) (push) Has been cancelled
Tests / Test Summary (push) Has been cancelled
Tests / Lint and Format (push) Has been cancelled
Tests / Web Node Tests (push) Has been cancelled
Tests / Import Check (Python 3.11) (push) Has been cancelled
Tests / Import Check (Python 3.12) (push) Has been cancelled
Tests / Python Tests (Python 3.13) (push) Has been cancelled
62 lines
2.2 KiB
TypeScript
62 lines
2.2 KiB
TypeScript
/**
|
|
* Turn-level timing for the chat status header.
|
|
*
|
|
* Each assistant turn used to surface a duration label on every
|
|
* sub-trace ("Plan for 5s", "Round 3 · 8s", …). That made the
|
|
* trace card noisy and made it hard to tell at a glance how long
|
|
* the whole answer took. The current design hoists timing to the
|
|
* single ``DeepTutor reasoning…`` status row at the top of the
|
|
* answer: one number, ticking up while the turn is in flight and
|
|
* frozen once the turn is done.
|
|
*
|
|
* The clock derives its bounds from the event stream so reconnects
|
|
* keep the duration coherent — we never depend on a transient React
|
|
* state that resets on remount.
|
|
*/
|
|
|
|
import type { StreamEvent } from "@/lib/unified-ws";
|
|
|
|
/**
|
|
* Elapsed seconds for the turn the ``events`` belong to.
|
|
*
|
|
* Returns ``null`` when the stream has not produced any timestamped
|
|
* event yet (e.g. the optimistic assistant placeholder before the
|
|
* first server frame arrives).
|
|
*
|
|
* While ``isStreaming`` is true the upper bound floats to
|
|
* ``nowSeconds`` so the label ticks up in real time; once streaming
|
|
* ends the bound collapses to the latest event timestamp and the
|
|
* duration freezes.
|
|
*/
|
|
export function getTurnDurationSeconds(
|
|
events: StreamEvent[],
|
|
nowSeconds: number,
|
|
isStreaming: boolean,
|
|
): number | null {
|
|
let min = Number.POSITIVE_INFINITY;
|
|
let max = 0;
|
|
for (const event of events) {
|
|
const ts = event.timestamp;
|
|
if (typeof ts !== "number") continue;
|
|
if (ts < min) min = ts;
|
|
if (ts > max) max = ts;
|
|
}
|
|
if (!Number.isFinite(min)) return null;
|
|
const end = isStreaming ? Math.max(nowSeconds, max) : max;
|
|
return Math.max(0, end - min);
|
|
}
|
|
|
|
/** Compact human-readable duration: ``"12s"``, ``"1m 4s"``, ``"1h 2m"``. */
|
|
export function formatTurnDuration(seconds: number): string {
|
|
const total = Math.max(0, Math.round(seconds));
|
|
if (total < 60) return `${total}s`;
|
|
const minutes = Math.floor(total / 60);
|
|
const remSeconds = total % 60;
|
|
if (minutes < 60) {
|
|
return remSeconds === 0 ? `${minutes}m` : `${minutes}m ${remSeconds}s`;
|
|
}
|
|
const hours = Math.floor(minutes / 60);
|
|
const remMinutes = minutes % 60;
|
|
return remMinutes === 0 ? `${hours}h` : `${hours}h ${remMinutes}m`;
|
|
}
|