+
+ server scanned={{ serverCounts.scanned ?? "-" }} · matched={{ serverCounts.matched ?? "-" }} · delivered={{ serverCounts.delivered ?? "-" }}
+ client local overlay received={{ clientReceived }} · decoded={{ clientDecoded }} · applied={{ state.appliedCount }}
+
+
+
+
+
+ 产品 SSE 原始帧
+
+ received={{ rawIngress.receivedCount }} · retained={{ rawIngress.rows.length }} · decoded={{ rawIngress.decodedCount }} · rejected={{ rawIngress.rejectedCount }} · evicted={{ rawIngress.evictedCount }} · bytes={{ rawIngress.retainedBytes }}
+
+
+
+
@@ -172,7 +266,8 @@ function cleanTraceId(value: string | null): string | null {
.isolated-debug-header,
.isolated-debug-actions,
.isolated-debug-contract,
-.isolated-debug-log header {
+.isolated-debug-log header,
+.raw-hwlab-event-window header {
display: flex;
align-items: center;
}
@@ -200,6 +295,34 @@ function cleanTraceId(value: string | null): string | null {
gap: 6px;
}
+.raw-ingress-status {
+ color: #6d28d9;
+ font-family: ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, monospace;
+ font-size: 11px;
+}
+
+.isolated-debug-tabs {
+ display: flex;
+ gap: 4px;
+ border-bottom: 1px solid #ddd6fe;
+}
+
+.isolated-debug-tabs button {
+ border: 0;
+ border-bottom: 2px solid transparent;
+ background: transparent;
+ padding: 5px 9px;
+ color: #6d28d9;
+ cursor: pointer;
+ font-size: 12px;
+ font-weight: 700;
+}
+
+.isolated-debug-tabs button[aria-selected="true"] {
+ border-bottom-color: #7c3aed;
+ color: #2e1065;
+}
+
.isolated-debug-contract {
min-width: 0;
flex-wrap: wrap;
@@ -302,6 +425,40 @@ function cleanTraceId(value: string | null): string | null {
padding: 7px;
}
+.raw-hwlab-event-window {
+ display: grid;
+ min-width: 0;
+ min-height: 0;
+ grid-template-rows: auto minmax(0, 1fr);
+ gap: 6px;
+}
+
+.raw-hwlab-event-window header {
+ justify-content: space-between;
+ gap: 8px;
+ color: #4c1d95;
+ font-size: 12px;
+}
+
+.raw-hwlab-event-window header span {
+ color: #6d28d9;
+ font-family: ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, monospace;
+ font-size: 10px;
+}
+
+.raw-hwlab-event-window textarea {
+ width: 100%;
+ min-height: 0;
+ resize: none;
+ border: 1px solid #ddd6fe;
+ border-radius: 7px;
+ background: #111827;
+ padding: 9px;
+ color: #e5e7eb;
+ font: 11px/1.5 ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, monospace;
+ white-space: pre;
+}
+
@media (max-width: 900px) {
.isolated-debug-body {
grid-template-columns: minmax(0, 1fr);
diff --git a/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.test.ts b/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.test.ts
index 5c1d9765..e78123d8 100644
--- a/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.test.ts
+++ b/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.test.ts
@@ -66,3 +66,34 @@ test("mergeRunnerTrace accumulates live Kafka deltas with an honest source and e
assert.equal(merged.eventCount, 2);
assert.deepEqual(merged.events?.map((event) => event.sourceSeq), [1, 2]);
});
+
+test("mergeRunnerTrace deduplicates live Kafka by sourceEventId and retains terminal events", () => {
+ const previous = trace({
+ traceId: "trc_live_identity",
+ eventSource: "hwlab-kafka-sse",
+ status: "running",
+ eventCount: 1,
+ events: [{ sourceEventId: "evt_assistant", runId: "run_live_identity", sourceSeq: 1, type: "assistant", message: "answer" }]
+ });
+ const duplicate = trace({
+ traceId: "trc_live_identity",
+ eventSource: "hwlab-kafka-sse",
+ status: "running",
+ eventCount: 1,
+ events: [{ sourceEventId: "evt_assistant", runId: "run_live_identity", sourceSeq: 99, type: "assistant", message: "duplicate" }]
+ });
+ const deduplicated = mergeRunnerTrace(previous, duplicate);
+ const terminal = mergeRunnerTrace(deduplicated, trace({
+ traceId: "trc_live_identity",
+ eventSource: "hwlab-kafka-sse",
+ status: "completed",
+ eventCount: 1,
+ events: [{ sourceEventId: "evt_terminal", runId: "run_live_identity", sourceSeq: 2, type: "result", terminal: true, status: "completed" }]
+ }));
+
+ assert.equal(deduplicated.eventCount, 1);
+ assert.equal(deduplicated.events?.[0]?.message, "answer");
+ assert.equal(terminal.status, "completed");
+ assert.equal(terminal.eventCount, 2);
+ assert.deepEqual(terminal.events?.map((event) => event.sourceEventId), ["evt_assistant", "evt_terminal"]);
+});
diff --git a/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.ts b/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.ts
index 80ee4d03..47c14a4b 100644
--- a/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.ts
+++ b/web/hwlab-cloud-web/src/composables/workbench-trace-snapshot.ts
@@ -270,8 +270,12 @@ function traceEventIdentity(event: TraceEvent): string | null {
const seqValue = event.projectedSeq;
const seq = typeof seqValue === "number" || typeof seqValue === "string" ? String(seqValue) : "";
if (seq) return `projected:${seq}:${label || "event"}`;
- const source = typeof event.source === "string" ? event.source : "";
+ const sourceEventId = firstNonEmptyString(event.sourceEventId);
+ if (sourceEventId) return `source-event:${sourceEventId}`;
+ const runId = firstNonEmptyString(event.runId);
const sourceSeq = typeof event.sourceSeq === "number" || typeof event.sourceSeq === "string" ? String(event.sourceSeq) : "";
+ if (runId && sourceSeq) return `run-source:${runId}:${sourceSeq}`;
+ const source = typeof event.source === "string" ? event.source : "";
if (source && sourceSeq) return `source:${source}:${sourceSeq}:${label || "event"}`;
return null;
}
diff --git a/web/hwlab-cloud-web/src/config/runtime.ts b/web/hwlab-cloud-web/src/config/runtime.ts
index 95825f41..628cb730 100644
--- a/web/hwlab-cloud-web/src/config/runtime.ts
+++ b/web/hwlab-cloud-web/src/config/runtime.ts
@@ -17,6 +17,13 @@ export interface WorkbenchRealtimeCapabilities {
export interface WorkbenchDebugCapabilities {
isolatedKafka: boolean;
+ rawHwlabEventWindow: WorkbenchRawHwlabEventWindowCapability;
+}
+
+export interface WorkbenchRawHwlabEventWindowCapability {
+ enabled: boolean;
+ maxEntries: number;
+ maxRetainedBytes: number;
}
const DEFAULT_DISPLAY_DATE_TIME_OPTIONS: Intl.DateTimeFormatOptions = {
@@ -99,10 +106,23 @@ export function workbenchRealtimeCapabilities(): WorkbenchRealtimeCapabilities {
export function workbenchDebugCapabilities(): WorkbenchDebugCapabilities {
const features = window.HWLAB_CLOUD_WEB_CONFIG?.workbench?.debugCapabilities;
- if (typeof features?.isolatedKafka !== "boolean") {
- throw new Error("HWLAB Cloud Web workbench.debugCapabilities.isolatedKafka is required");
+ const rawWindow = features?.rawHwlabEventWindow;
+ if (
+ typeof features?.isolatedKafka !== "boolean" ||
+ typeof rawWindow?.enabled !== "boolean" ||
+ !Number.isInteger(rawWindow.maxEntries) || Number(rawWindow.maxEntries) <= 0 ||
+ !Number.isInteger(rawWindow.maxRetainedBytes) || Number(rawWindow.maxRetainedBytes) <= 0
+ ) {
+ throw new Error("HWLAB Cloud Web workbench.debugCapabilities and rawHwlabEventWindow policy are required");
}
- return { isolatedKafka: features.isolatedKafka };
+ return {
+ isolatedKafka: features.isolatedKafka,
+ rawHwlabEventWindow: {
+ enabled: rawWindow.enabled,
+ maxEntries: Number(rawWindow.maxEntries),
+ maxRetainedBytes: Number(rawWindow.maxRetainedBytes)
+ }
+ };
}
export function traceExplorerHref(traceId: string | null | undefined): string | null {
diff --git a/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.test.ts b/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.test.ts
new file mode 100644
index 00000000..b55369be
--- /dev/null
+++ b/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.test.ts
@@ -0,0 +1,68 @@
+import assert from "node:assert/strict";
+import { test } from "bun:test";
+
+import type { WorkbenchKafkaDebugReplayResult } from "@/api/workbench-debug";
+import { classifyWorkbenchKafkaDebugLocalResult } from "./workbench-kafka-debug-local-result";
+
+test("local replay classification reports transport_failed below server delivered", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 2, decoded: 2, applied: 2 });
+ assert.equal(result.ok, false);
+ assert.equal(result.phase, "client");
+ assert.equal(result.code, "transport_failed");
+ assert.deepEqual(result.counts, { delivered: 3, clientReceived: 2, decoded: 2, applied: 2 });
+});
+
+test("local replay classification reports transport_failed above server delivered", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 4, decoded: 4, applied: 4 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "transport_failed");
+});
+
+test("local replay classification reports contract_invalid when server delivered is missing", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(), { clientReceived: 0, decoded: 0, applied: 0 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "contract_invalid");
+});
+
+test("local replay classification reports decoder_rejected below client received", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 3, decoded: 2, applied: 2 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "decoder_rejected");
+});
+
+test("local replay classification reports decoder_rejected above client received", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 3, decoded: 4, applied: 4 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "decoder_rejected");
+});
+
+test("local replay classification reports reducer_rejected below decoded", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 3, decoded: 3, applied: 2 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "reducer_rejected");
+});
+
+test("local replay classification reports reducer_rejected above decoded", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 3, decoded: 3, applied: 4 });
+ assert.equal(result.ok, false);
+ assert.equal(result.code, "reducer_rejected");
+});
+
+test("local replay classification preserves terminal_complete when every client stage agrees", () => {
+ const result = classifyWorkbenchKafkaDebugLocalResult(terminalResult(3), { clientReceived: 3, decoded: 3, applied: 3 });
+ assert.equal(result.ok, true);
+ assert.equal(result.phase, "terminal");
+ assert.equal(result.code, "terminal_complete");
+ assert.equal(result.localOverlay, true);
+});
+
+function terminalResult(delivered?: number): WorkbenchKafkaDebugReplayResult {
+ return {
+ contractVersion: "workbench-kafka-debug-replay-v2",
+ ok: true,
+ phase: "terminal",
+ code: "terminal_complete",
+ terminalObserved: true,
+ counts: { ...(delivered === undefined ? {} : { delivered }), clientReceived: null, decoded: null, applied: null }
+ };
+}
diff --git a/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.ts b/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.ts
new file mode 100644
index 00000000..9067c47c
--- /dev/null
+++ b/web/hwlab-cloud-web/src/stores/workbench-kafka-debug-local-result.ts
@@ -0,0 +1,45 @@
+// Responsibility: reclassify a server-terminal debug replay with browser-local transport, decode, and reducer counts.
+
+import type { WorkbenchKafkaDebugReplayResult } from "@/api/workbench-debug";
+
+export interface WorkbenchKafkaDebugClientCounts {
+ clientReceived: number;
+ decoded: number;
+ applied: number;
+}
+
+export type WorkbenchKafkaDebugClientFailureCode = "contract_invalid" | "transport_failed" | "decoder_rejected" | "reducer_rejected";
+
+export function classifyWorkbenchKafkaDebugLocalResult(
+ serverResult: WorkbenchKafkaDebugReplayResult,
+ clientCounts: WorkbenchKafkaDebugClientCounts
+): WorkbenchKafkaDebugReplayResult {
+ const counts = { ...(serverResult.counts ?? {}), ...clientCounts };
+ const overlaid = { ...serverResult, counts, localOverlay: true };
+ if (serverResult.code !== "terminal_complete") return overlaid;
+
+ const delivered = nonNegativeInteger(serverResult.counts?.delivered);
+ if (delivered === null) {
+ return clientFailure(overlaid, "contract_invalid", "服务端 terminal_complete 缺少有效的 delivered 计数。");
+ }
+ if (clientCounts.clientReceived !== delivered) {
+ return clientFailure(overlaid, "transport_failed", `浏览器收到 ${clientCounts.clientReceived} 条，与服务端已投递的 ${delivered} 条不一致。`);
+ }
+ if (clientCounts.decoded !== clientCounts.clientReceived) {
+ return clientFailure(overlaid, "decoder_rejected", `浏览器收到 ${clientCounts.clientReceived} 条，但解码计数为 ${clientCounts.decoded} 条。`);
+ }
+ if (clientCounts.applied !== clientCounts.decoded) {
+ return clientFailure(overlaid, "reducer_rejected", `浏览器解码 ${clientCounts.decoded} 条，但生产 reducer 应用计数为 ${clientCounts.applied} 条。`);
+ }
+ return { ...overlaid, ok: true, phase: "terminal", code: "terminal_complete" };
+}
+
+function clientFailure(result: WorkbenchKafkaDebugReplayResult, code: WorkbenchKafkaDebugClientFailureCode, message: string): WorkbenchKafkaDebugReplayResult {
+ return { ...result, ok: false, phase: "client", code, message };
+}
+
+function nonNegativeInteger(value: unknown): number | null {
+ if (value === null || value === undefined || (typeof value === "string" && value.trim() === "")) return null;
+ const parsed = Number(value);
+ return Number.isSafeInteger(parsed) && parsed >= 0 ? parsed : null;
+}
diff --git a/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.test.ts b/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.test.ts
new file mode 100644
index 00000000..f07118f4
--- /dev/null
+++ b/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.test.ts
@@ -0,0 +1,56 @@
+import assert from "node:assert/strict";
+import { test } from "bun:test";
+
+import type { WorkbenchRawHwlabEventWindowCapability } from "@/config/runtime";
+import { appendRawHwlabIngressFrame, createRawHwlabIngressState } from "./workbench-raw-hwlab-ingress";
+
+const capability: WorkbenchRawHwlabEventWindowCapability = {
+ enabled: true,
+ maxEntries: 2,
+ maxRetainedBytes: 32
+};
+
+test("raw HWLAB ingress retains complete frames in arrival order and exposes decode rejection", () => {
+ let state = createRawHwlabIngressState("ses_raw");
+ const roomyCapability = { ...capability, maxRetainedBytes: 128 };
+ state = appendRawHwlabIngressFrame(state, frame('{"schema":"hwlab.event.v1"}', "accepted"), roomyCapability, () => 1);
+ state = appendRawHwlabIngressFrame(state, frame("not-json", "invalid-json"), roomyCapability, () => 2);
+
+ assert.equal(state.receivedCount, 2);
+ assert.equal(state.decodedCount, 1);
+ assert.equal(state.rejectedCount, 1);
+ assert.deepEqual(state.rows.map((row) => [row.arrivalSeq, row.rawText, row.decodeStatus]), [
+ [1, '{"schema":"hwlab.event.v1"}', "accepted"],
+ [2, "not-json", "invalid-json"]
+ ]);
+});
+
+test("raw HWLAB ingress evicts whole envelopes by YAML-owned entry and byte capacities", () => {
+ let state = createRawHwlabIngressState("ses_raw");
+ state = appendRawHwlabIngressFrame(state, frame("1234567890", "accepted"), capability, () => 1);
+ state = appendRawHwlabIngressFrame(state, frame("abcdefghij", "accepted"), capability, () => 2);
+ state = appendRawHwlabIngressFrame(state, frame("ABCDEFGHIJ", "accepted"), capability, () => 3);
+
+ assert.equal(state.receivedCount, 3);
+ assert.equal(state.evictedCount, 1);
+ assert.equal(state.retainedBytes, 20);
+ assert.deepEqual(state.rows.map((row) => row.rawText), ["abcdefghij", "ABCDEFGHIJ"]);
+
+ const oversized = appendRawHwlabIngressFrame(state, frame("x".repeat(40), "accepted"), capability, () => 4);
+ assert.equal(oversized.receivedCount, 4);
+ assert.equal(oversized.evictedCount, 4);
+ assert.equal(oversized.retainedBytes, 0);
+ assert.deepEqual(oversized.rows, []);
+});
+
+test("raw HWLAB ingress ignores non-product events and disabled capability", () => {
+ const state = createRawHwlabIngressState("ses_raw");
+ const connected = appendRawHwlabIngressFrame(state, { eventName: "workbench.connected", rawText: "{}", decodeStatus: "accepted" }, capability);
+ const disabled = appendRawHwlabIngressFrame(state, frame("{}", "accepted"), { ...capability, enabled: false });
+ assert.equal(connected, state);
+ assert.equal(disabled, state);
+});
+
+function frame(rawText: string, decodeStatus: "accepted" | "invalid-json" | "not-object") {
+ return { eventName: "hwlab.event.v1", rawText, decodeStatus } as const;
+}
diff --git a/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.ts b/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.ts
new file mode 100644
index 00000000..d92aed19
--- /dev/null
+++ b/web/hwlab-cloud-web/src/stores/workbench-raw-hwlab-ingress.ts
@@ -0,0 +1,71 @@
+// Responsibility: bounded, memory-only observation of the existing product hwlab.event.v1 SSE ingress.
+
+import type { WorkbenchSseIngressFrame } from "@/api/workbench-events";
+import type { WorkbenchRawHwlabEventWindowCapability } from "@/config/runtime";
+
+export interface RawHwlabIngressRow {
+ arrivalSeq: number;
+ receivedAt: string;
+ eventName: "hwlab.event.v1";
+ rawText: string;
+ decodeStatus: WorkbenchSseIngressFrame["decodeStatus"];
+ byteLength: number;
+}
+
+export interface RawHwlabIngressState {
+ scopeKey: string;
+ receivedCount: number;
+ decodedCount: number;
+ rejectedCount: number;
+ evictedCount: number;
+ retainedBytes: number;
+ rows: RawHwlabIngressRow[];
+}
+
+export function createRawHwlabIngressState(scopeKey = ""): RawHwlabIngressState {
+ return {
+ scopeKey,
+ receivedCount: 0,
+ decodedCount: 0,
+ rejectedCount: 0,
+ evictedCount: 0,
+ retainedBytes: 0,
+ rows: []
+ };
+}
+
+export function appendRawHwlabIngressFrame(
+ state: RawHwlabIngressState,
+ frame: WorkbenchSseIngressFrame,
+ capability: WorkbenchRawHwlabEventWindowCapability,
+ now: () => number = Date.now
+): RawHwlabIngressState {
+ if (!capability.enabled || frame.eventName !== "hwlab.event.v1") return state;
+ const byteLength = new TextEncoder().encode(frame.rawText).byteLength;
+ const row: RawHwlabIngressRow = {
+ arrivalSeq: state.receivedCount + 1,
+ receivedAt: new Date(now()).toISOString(),
+ eventName: "hwlab.event.v1",
+ rawText: frame.rawText,
+ decodeStatus: frame.decodeStatus,
+ byteLength
+ };
+ const rows = [...state.rows, row];
+ let retainedBytes = state.retainedBytes + byteLength;
+ let evictedCount = state.evictedCount;
+ while (rows.length > capability.maxEntries || retainedBytes > capability.maxRetainedBytes) {
+ const evicted = rows.shift();
+ if (!evicted) break;
+ retainedBytes -= evicted.byteLength;
+ evictedCount += 1;
+ }
+ return {
+ ...state,
+ receivedCount: state.receivedCount + 1,
+ decodedCount: state.decodedCount + (frame.decodeStatus === "accepted" ? 1 : 0),
+ rejectedCount: state.rejectedCount + (frame.decodeStatus === "accepted" ? 0 : 1),
+ evictedCount,
+ retainedBytes,
+ rows
+ };
+}
diff --git a/web/hwlab-cloud-web/src/stores/workbench.ts b/web/hwlab-cloud-web/src/stores/workbench.ts
index 05ca500a..8f54590f 100644
--- a/web/hwlab-cloud-web/src/stores/workbench.ts
+++ b/web/hwlab-cloud-web/src/stores/workbench.ts
@@ -4,7 +4,7 @@
import { computed, nextTick, ref } from "vue";
import { defineStore } from "pinia";
import { api } from "@/api";
-import { workbenchRealtimeCapabilities } from "@/config/runtime";
+import { workbenchDebugCapabilities, workbenchRealtimeCapabilities } from "@/config/runtime";
import { workbenchRuntimePolicy } from "@/config/workbench-runtime-policy";
import { createKeyedSingleflight } from "@/utils/scheduler/keyed-singleflight";
import { createWorkbenchHealthProbeCache } from "@/utils/workbench-health";
@@ -74,6 +74,7 @@ import { useWorkbenchColadaQueries } from "./workbench-colada-queries";
import { useWorkbenchColadaReducer } from "./workbench-colada-reducer";
import { projectionMergeCommitSummary, traceEventsAutoReadDecision, workbenchSessionDetailReadKey, workbenchSessionMessagesReadKey, workbenchTraceEventsReadKey, type TraceEventsReadRangeRecord } from "./workbench-session-messages-read-budget";
import { realtimeSnapshotToTraceSnapshot, terminalSealResultWithoutTraceEvents, traceDetailProjectedSeq, traceNextProjectedSeq } from "./workbench-trace-detail";
+import { appendRawHwlabIngressFrame, createRawHwlabIngressState } from "./workbench-raw-hwlab-ingress";
const WORKBENCH_SESSION_PROJECTION_SIGNAL_CHANNEL = "hwlab.workbench.sessionProjection.v1";
const WORKBENCH_SESSION_PROJECTION_SIGNAL_KEY = "hwlab.workbench.sessionProjectionSignal.v1";
@@ -109,6 +110,7 @@ interface RealtimeTurnProjectionItem {
export const useWorkbenchStore = defineStore("workbench", () => {
const runtimePolicy = workbenchRuntimePolicy();
const realtimeCapabilities = workbenchRealtimeCapabilities();
+ const debugCapabilities = workbenchDebugCapabilities();
const workbenchColadaReducer = useWorkbenchColadaReducer();
const workbenchColadaQueries = useWorkbenchColadaQueries();
const workbenchColadaMutations = useWorkbenchColadaMutations();
@@ -135,6 +137,7 @@ export const useWorkbenchStore = defineStore("workbench", () => {
const sessionListLoadMoreError = ref
(null);
const chatPending = ref(false);
const liveRealtimeReadySessionId = ref(null);
+ const rawHwlabIngress = ref(createRawHwlabIngressState());
const error = ref(null);
const activityRef = ref({ lastActivityAt: Date.now(), lastActivityIso: new Date().toISOString(), waitingFor: "idle", lastEventLabel: null as string | null });
const currentRequest = ref<{ traceId: string; sessionId: string | null; threadId: string | null; status?: string | null } | null>(null);
@@ -1119,8 +1122,10 @@ export const useWorkbenchStore = defineStore("workbench", () => {
const traceId = realtimeTraceId();
const sessionId = selectedSessionId.value ?? null;
void reason;
- const scopeChanged = realtimeTransport.currentKey() !== workbenchRealtimeScopeKey(sessionId, traceId);
+ const realtimeScopeKey = workbenchRealtimeScopeKey(sessionId, traceId);
+ const scopeChanged = realtimeTransport.currentKey() !== realtimeScopeKey;
if (realtimeCapabilities.liveKafkaSse && scopeChanged) liveRealtimeReadySessionId.value = null;
+ if (debugCapabilities.rawHwlabEventWindow.enabled && scopeChanged) rawHwlabIngress.value = createRawHwlabIngressState(realtimeScopeKey);
realtimeTransport.restart({
realtimeCapabilities,
sessionId,
@@ -1129,6 +1134,9 @@ export const useWorkbenchStore = defineStore("workbench", () => {
flushMaxItemsPerChunk: runtimePolicy.workbenchRealtimeFlushMaxItemsPerChunk,
flushMaxChunkMs: runtimePolicy.workbenchRealtimeFlushMaxChunkMs,
flushYieldMs: runtimePolicy.workbenchRealtimeFlushYieldMs,
+ onIngress: debugCapabilities.rawHwlabEventWindow.enabled
+ ? (frame) => { rawHwlabIngress.value = appendRawHwlabIngressFrame(rawHwlabIngress.value, frame, debugCapabilities.rawHwlabEventWindow); }
+ : undefined,
onOpen: () => undefined,
onError: () => {
if (realtimeCapabilities.liveKafkaSse) liveRealtimeReadySessionId.value = null;
@@ -1943,10 +1951,14 @@ export const useWorkbenchStore = defineStore("workbench", () => {
return typeof performance !== "undefined" && typeof performance.now === "function" ? performance.now() : Date.now();
}
+ function clearRawHwlabIngress(): void {
+ rawHwlabIngress.value = createRawHwlabIngressState(rawHwlabIngress.value.scopeKey);
+ }
+
installRealtimeVisibilityHandler();
installWorkbenchProjectionSignalHandler();
- return { sessions, messages, activeMessages, activeSession, providerProfile, providerOptions, recentDrafts, codeAgentTimeoutMs, gatewayShellTimeoutMs, live, loading, sessionListLoading, sessionDetailLoading, sessionListLoadedCount, sessionListHasMore, sessionListNextCursor, sessionListLoadingMore, sessionListLoadMoreError, chatPending, error, activeSessionId, activeSessionSelectionSource, selectedSessionId, selectedThreadId, sessionTabs, composer, hydrate, refreshLive, createSession, selectSession, selectSessionById, deleteCurrentSession, refreshSessions, loadMoreSessions, submitMessage, cancelAgentMessage, cancelRunningTrace, retryAgentMessage, setProviderProfile, refreshProviderOptions, pickDraft, clearRecentDrafts, clearSessionMessages, recordActivity };
+ return { sessions, messages, activeMessages, activeSession, providerProfile, providerOptions, recentDrafts, codeAgentTimeoutMs, gatewayShellTimeoutMs, live, loading, sessionListLoading, sessionDetailLoading, sessionListLoadedCount, sessionListHasMore, sessionListNextCursor, sessionListLoadingMore, sessionListLoadMoreError, chatPending, error, rawHwlabIngress, activeSessionId, activeSessionSelectionSource, selectedSessionId, selectedThreadId, sessionTabs, composer, hydrate, refreshLive, createSession, selectSession, selectSessionById, deleteCurrentSession, refreshSessions, loadMoreSessions, submitMessage, cancelAgentMessage, cancelRunningTrace, retryAgentMessage, setProviderProfile, refreshProviderOptions, pickDraft, clearRecentDrafts, clearSessionMessages, clearRawHwlabIngress, recordActivity };
});
function workbenchSessionsFromPayload(payload: unknown): WorkbenchSessionRecord[] {
diff --git a/web/hwlab-cloud-web/src/types/global.d.ts b/web/hwlab-cloud-web/src/types/global.d.ts
index 7336bbb3..b3ff42a3 100644
--- a/web/hwlab-cloud-web/src/types/global.d.ts
+++ b/web/hwlab-cloud-web/src/types/global.d.ts
@@ -14,6 +14,11 @@ declare global {
};
debugCapabilities?: {
isolatedKafka?: boolean;
+ rawHwlabEventWindow?: {
+ enabled?: boolean;
+ maxEntries?: number;
+ maxRetainedBytes?: number;
+ };
};
traceTimeline?: {
autoExpandRunning?: boolean;
diff --git a/web/hwlab-cloud-web/src/utils/workbench-stream-transport.ts b/web/hwlab-cloud-web/src/utils/workbench-stream-transport.ts
index 7a558a1e..5609c29a 100644
--- a/web/hwlab-cloud-web/src/utils/workbench-stream-transport.ts
+++ b/web/hwlab-cloud-web/src/utils/workbench-stream-transport.ts
@@ -7,7 +7,7 @@
// - OpenCode stream.transport.ts:391-443 stream acquire/subscribe.
// - OpenCode stream.transport.ts:504-530 reduce output/trace.
-import { connectWorkbenchEvents, type WorkbenchEventStream, type WorkbenchRealtimeEvent } from "@/api/workbench-events";
+import { connectWorkbenchEvents, type WorkbenchEventStream, type WorkbenchRealtimeEvent, type WorkbenchSseIngressFrame } from "@/api/workbench-events";
import type { WorkbenchRealtimeCapabilities } from "@/config/runtime";
import { workbenchRealtimeScopeKey } from "@/utils/workbench-key";
@@ -22,6 +22,7 @@ export interface WorkbenchStreamTransportRestartInput {
flushMaxItemsPerChunk?: number | null;
flushMaxChunkMs?: number | null;
flushYieldMs?: number | null;
+ onIngress?: (frame: WorkbenchSseIngressFrame) => void;
onOpen?: () => void;
onError?: (event: Event) => void;
onState?: (state: WorkbenchStreamTransportState) => void;
@@ -117,6 +118,7 @@ export class WorkbenchStreamTransportRuntime {
flushMaxItemsPerChunk: input.flushMaxItemsPerChunk,
flushMaxChunkMs: input.flushMaxChunkMs,
flushYieldMs: input.flushYieldMs,
+ onIngress: input.onIngress,
onOpen: () => {
this.markLive(key);
this.emitState(input, "open", null);
diff --git a/web/hwlab-cloud-web/src/views/workbench/CodeWorkbenchView.vue b/web/hwlab-cloud-web/src/views/workbench/CodeWorkbenchView.vue
index 3a6d0e72..094b59cd 100644
--- a/web/hwlab-cloud-web/src/views/workbench/CodeWorkbenchView.vue
+++ b/web/hwlab-cloud-web/src/views/workbench/CodeWorkbenchView.vue
@@ -30,7 +30,7 @@ const routeReflectionTarget = computed(() => routeRequestId.value ?? (rawRouteSe
const applyingRouteSession = ref(Boolean(rawRouteSessionId.value));
const componentActive = ref(false);
const isolatedDebugOpen = ref(false);
-const isolatedDebugAvailable = computed(() => debugCapabilities.isolatedKafka && auth.isAdmin);
+const isolatedDebugAvailable = computed(() => auth.isAdmin && (debugCapabilities.isolatedKafka || debugCapabilities.rawHwlabEventWindow.enabled));
const isolatedDebugTraceId = computed(() => workbenchCurrentDebugTraceId(workbench.activeMessages, workbench.activeSession?.lastTraceId));
type LaunchContextRecord = {
sourceId?: string | null;
@@ -135,12 +135,19 @@ async function reflectActiveSessionInUrl(value: string | null): Promise {
{{ isolatedDebugTraceId ? `当前 trace ${isolatedDebugTraceId}` : "等待当前 traceId" }}
-
+