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

fix(web-probe): validate stdio session lineage

Browse Source
This commit is contained in:
Codex
2026-07-10 13:12:58 +02:00
parent b45b339855
commit 8c585e3c2f
2 changed files with 27 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/src/hwlab-node-web-observe-runner-realtime-source.ts
+13 -1
View File
@@ -776,7 +776,10 @@ function realtimeValidateTurnEvidence(input) {
const rows = (input.debug.records[stream] || []).filter((item) => item.traceId === input.traceId);
if (rows.length === 0) throw new Error("turn " + input.turn + " " + stream + " has no trace records");
if (!realtimeMonotonicOffsets(rows)) throw new Error("turn " + input.turn + " " + stream + " offsets are not monotonic");
if (rows.some((item) => item.hwlabSessionId !== input.sessionId)) throw new Error("turn " + input.turn + " " + stream + " session missing or mismatched");
const expectedSessionId = realtimeExpectedStreamSessionId(stream, input.sessionId);
if (rows.some((item) => item.hwlabSessionId !== expectedSessionId)) {
throw new Error("turn " + input.turn + " " + stream + " session lineage missing or mismatched");
}
if (rows.some((item) => item.runId !== input.runId)) throw new Error("turn " + input.turn + " " + stream + " runId missing or mismatched");
if (rows.some((item) => item.commandId && item.commandId !== input.commandId)) throw new Error("turn " + input.turn + " " + stream + " commandId mismatched");
const commandBoundRows = stream === "stdio"
@@ -811,6 +814,15 @@ function realtimeValidateTurnEvidence(input) {
}
}
function realtimeExpectedStreamSessionId(stream, hwlabSessionId) {
if (stream !== "stdio") return hwlabSessionId;
const base = String(hwlabSessionId || "")
.replace(/^ses_/u, "")
.replace(/[^A-Za-z0-9_]+/gu, "_")
.replace(/^_+|_+$/gu, "");
return base ? "ses_agentrun_" + base : null;
}
function realtimeAssertEnvelopePassthrough(kafkaRows, productRows, requireAllKafkaRows, label) {
const sameEnvelope = (left, right) => left.envelopeFingerprint && left.envelopeFingerprint === right.envelopeFingerprint
&& left.eventId === right.eventId