opencode/packages/app/e2e/performance/unit/session-timeline-stream-probe.test.ts

import { expect, test } from "bun:test"
import { streamChunk } from "../timeline/session-timeline-benchmark.fixture"
import { streamProgress } from "../timeline/session-timeline-stream-probe"

test("classifies emitted stream markers using the fixture cycle", () => {
  expect(streamProgress("before stream-17 after stream-18")).toEqual({ index: 18, phase: "boundary" })
  expect(streamProgress("before stream-18 after stream-19")).toEqual({ index: 19, phase: "stream" })
  expect(streamProgress("benchmark-complete stream-36")).toEqual({ index: 36, phase: "complete" })
  expect(streamProgress("no marker")).toEqual({ index: -1, phase: "unknown" })
})

test("emits progress markers at fixture boundaries", () => {
  expect(streamProgress(streamChunk(18, 160))).toEqual({ index: 18, phase: "boundary" })
})