opencode-agent[bot]
51 lines
1.5 KiB
TypeScript
51 lines
1.5 KiB
TypeScript
import { NodeServices } from "@effect/platform-node"
|
|
import { expect, it } from "@effect/vitest"
|
|
import { Effect, Exit, Option, Scope } from "effect"
|
|
import * as Process from "../../src/instance/process.js"
|
|
|
|
it.live("does not let an interrupted waiter poison process completion", () =>
|
|
Effect.scoped(
|
|
Effect.gen(function* () {
|
|
const process = yield* Process.spawn([
|
|
globalThis.process.execPath,
|
|
"-e",
|
|
"setTimeout(() => process.exit(0), 100)",
|
|
])
|
|
|
|
const early = yield* process.exitCode.pipe(Effect.timeoutOption(5))
|
|
expect(Option.isNone(early)).toBe(true)
|
|
expect(yield* process.exitCode).toBe(0)
|
|
}),
|
|
).pipe(Effect.provide(NodeServices.layer)),
|
|
)
|
|
|
|
it.live("collects finite command output and status", () =>
|
|
Process.run([globalThis.process.execPath, "-e", 'console.log("stdout"); console.error("stderr")']).pipe(
|
|
Effect.provide(NodeServices.layer),
|
|
Effect.tap((output) =>
|
|
Effect.sync(() => {
|
|
expect(output).toEqual({
|
|
status: 0,
|
|
stdout: "stdout\n",
|
|
stderr: "stderr\n",
|
|
})
|
|
}),
|
|
),
|
|
),
|
|
)
|
|
|
|
it.live("keeps exit observation alive after detachment", () =>
|
|
Effect.gen(function* () {
|
|
const scope = yield* Scope.make()
|
|
const process = yield* Process.spawn([
|
|
globalThis.process.execPath,
|
|
"-e",
|
|
"setTimeout(() => process.exit(7), 100)",
|
|
]).pipe(Scope.provide(scope))
|
|
|
|
yield* process.detach
|
|
yield* Scope.close(scope, Exit.void)
|
|
expect(yield* process.exitCode).toBe(7)
|
|
}).pipe(Effect.provide(NodeServices.layer)),
|
|
)
|