Update DeltaStore Trace Explorer Phase 2: replay-core.js

replay-core.js

@@ -1,4 +1,5 @@
 export const SCHEMA_VERSION = "deltastore-replay-trace-v1";
+export const EXCHANGE_SCHEMA_VERSION = "solstice-agent-trace-exchange/v1";
 
 export function parseTrace(value) {
   const trace = typeof value === "string" ? JSON.parse(value) : value;
@@ -15,3 +16,34 @@ export function compareBranch(trace, branchId) {
   const index = trace.original_trajectory.findIndex(event => event.event_id === checkpoint.event_id);
   return { sharedPrefix: trace.original_trajectory.slice(0, index + 1), originalTail: trace.original_trajectory.slice(index + 1), alternate: branch.events, originalOutcome: trace.final_outcome || {}, alternateOutcome: branch.final_outcome || {}, classification: branch.comparison_classification || "outcome_changed" };
 }
+
+export function parseExchange(value) {
+  const packageValue = typeof value === "string" ? JSON.parse(value) : value;
+  if (!packageValue || packageValue.schema_version !== EXCHANGE_SCHEMA_VERSION || !Array.isArray(packageValue.events)) throw new Error("Unsupported or malformed exchange package");
+  const ids = new Set();
+  let previous = -1;
+  for (const event of packageValue.events) {
+    if (!event.event_id || ids.has(event.event_id)) throw new Error("Duplicate or missing exchange event ID");
+    if (!Number.isInteger(event.sequence) || event.sequence <= previous) throw new Error("Invalid exchange event ordering");
+    ids.add(event.event_id); previous = event.sequence;
+  }
+  return packageValue;
+}
+
+export function attachFindings(packageValue, findingsValue) {
+  const packageTrace = parseExchange(packageValue);
+  const findings = Array.isArray(findingsValue) ? findingsValue : findingsValue?.findings;
+  if (!Array.isArray(findings)) throw new Error("Findings must be an array");
+  const eventIds = new Set(packageTrace.events.map(event => event.event_id));
+  for (const finding of findings) {
+    if (finding.trace_id && finding.trace_id !== packageTrace.trace_id) throw new Error("Finding trace ID does not match");
+    for (const ref of finding.evidence_refs || finding.evidence_events || []) if (!eventIds.has(ref)) throw new Error("Finding references an unknown event");
+  }
+  return {...packageTrace, findings};
+}
+
+export function downloadJson(value, filename) {
+  const blob = new Blob([JSON.stringify(value, null, 2)], {type: "application/json"});
+  const link = document.createElement("a"); link.href = URL.createObjectURL(blob); link.download = filename; link.click();
+  URL.revokeObjectURL(link.href);
+}