import { describe, expect, test } from "bun:test"

import { writeSessionOutput } from "@/cli/cmd/run/stream"

import type { FooterApi, FooterEvent, StreamCommit } from "@/cli/cmd/run/types"

function footer() {

const events: FooterEvent[] = []

const commits: StreamCommit[] = []

const api: FooterApi = {

isClosed: false,

onPrompt: () => () => {},

onQueuedRemove: () => () => {},

onClose: () => () => {},

event: (next) => {

events.push(next)

},

append: (next) => {

commits.push(next)

},

idle: () => Promise.resolve(),

close: () => {},

destroy: () => {},

}

return { api, events, commits }

}

describe("run stream bridge", () => {

test("defaults status patches to running phase", () => {

const out = footer()

writeSessionOutput(

{

footer: out.api,

},

{

commits: [],

footer: {

patch: {

status: "assistant responding",

},

},

},

)

expect(out.events).toEqual([

{

type: "stream.patch",

patch: {

phase: "running",

status: "assistant responding",

},

},

])

})

})