mirror of
https://github.com/anomalyco/opencode.git
synced 2026-11-13 19:46:16 +03:00
Kit Langton
55 lines
2.3 KiB
TypeScript
55 lines
2.3 KiB
TypeScript
import { expect, test } from "bun:test"
|
|
import { decide, type LocalService } from "../src/service-probe"
|
|
|
|
const protocolError =
|
|
"Background service uses an incompatible health protocol. Update this client or explicitly restart the service."
|
|
|
|
function service(input: Pick<LocalService, "state" | "compatible" | "version">) {
|
|
return {
|
|
info: { url: "http://127.0.0.1:4096", pid: 4242, version: input.version },
|
|
endpoint: { url: "http://127.0.0.1:4096" },
|
|
...input,
|
|
} satisfies LocalService
|
|
}
|
|
|
|
test("a missing health endpoint fails unless the caller requires a different version", () => {
|
|
const missing = service({ version: "2.0.0", state: "ready", compatible: false })
|
|
expect(decide(missing, {})).toEqual({ _tag: "fail", error: new Error(protocolError) })
|
|
expect(decide(missing, { version: "2.0.0" })).toEqual({ _tag: "fail", error: new Error(protocolError) })
|
|
expect(decide(missing, { version: (version) => version.startsWith("2.") })).toEqual({
|
|
_tag: "fail",
|
|
error: new Error(protocolError),
|
|
})
|
|
expect(decide(missing, { version: "3.0.0" })).toEqual({ _tag: "replace", pty: "handoff" })
|
|
expect(decide(service({ state: "ready", compatible: false }), { version: "3.0.0" })).toEqual({
|
|
_tag: "replace",
|
|
pty: "handoff",
|
|
})
|
|
})
|
|
|
|
test("a compatible service is reused when ready, awaited while starting, and fails when it failed", () => {
|
|
expect(decide(service({ version: "2.0.0", state: "ready", compatible: true }), {})).toEqual({ _tag: "reuse" })
|
|
expect(decide(service({ version: "2.0.0", state: "waiting", compatible: true }), { version: "2.0.0" })).toEqual({
|
|
_tag: "wait",
|
|
})
|
|
expect(decide(service({ version: "2.0.0", state: "failed", compatible: true }), {})).toEqual({
|
|
_tag: "fail",
|
|
error: new Error("Background service failed to start"),
|
|
})
|
|
})
|
|
|
|
test("a version mismatch replaces the service, handing off terminals only when it is ready", () => {
|
|
expect(decide(service({ version: "1.0.0", state: "ready", compatible: true }), { version: "2.0.0" })).toEqual({
|
|
_tag: "replace",
|
|
pty: "handoff",
|
|
})
|
|
expect(decide(service({ version: "1.0.0", state: "waiting", compatible: true }), { version: "2.0.0" })).toEqual({
|
|
_tag: "replace",
|
|
pty: "clear",
|
|
})
|
|
expect(decide(service({ version: "1.0.0", state: "failed", compatible: true }), { version: "2.0.0" })).toEqual({
|
|
_tag: "replace",
|
|
pty: "clear",
|
|
})
|
|
})
|