mirrors/opencode
1
0
Fork 0
mirror of https://github.com/anomalyco/opencode.git synced 2026-11-14 03:56:55 +03:00
Code Issues Packages Projects Releases Wiki Activity

test(core): refresh test vocabulary (#45714)

Browse Source
This commit is contained in:
Kit Langton
2026-08-27 23:26:45 -04:00
committed by GitHub
Unverified
parent 3c9e5adefa
commit 1d3308d904
3 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/core/test/bus.test.ts
+2 -2
View File
@@ -228,10 +228,10 @@ describe("Bus", () => {
)
const event = yield* bus.publish(SyncMessage, { id: "one", text: "hello" })
yield* bus.publish(SyncMessage, { id: "one", text: "after unsubscribe" })
yield* bus.publish(SyncMessage, { id: "one", text: "second event" })
expect(received[0]).toEqual(event)
expect(received[1]?.data).toEqual({ id: "one", text: "after unsubscribe" })
expect(received[1]?.data).toEqual({ id: "one", text: "second event" })
}),
)
packages/core/test/permission.test.ts
+1 -1
View File
@@ -122,7 +122,7 @@ describe("Permission", () => {
}),
)
it.effect("evaluates against an explicit provider-turn agent", () =>
it.effect("evaluates against an explicit agent", () =>
Effect.gen(function* () {
yield* setup([{ action: "read", resource: "*", effect: "allow" }])
const agents = yield* Agent.Service
packages/core/test/session-runner.test.ts
+18 -18
View File
@@ -4241,15 +4241,15 @@ describe("SessionRunnerLLM", () => {
expect((yield* Fiber.join(run).pipe(Effect.flip)).message).toBe("Provider blocked the response")
const assistant = requireAssistant(yield* s.context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => event.type)).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => event.type)).toEqual([
"session.step.started.1",
"session.tool.called.1",
"session.tool.success.2",
"session.step.failed.1",
])
expect(
bus.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
events.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
).toHaveLength(1)
})
@@ -5145,14 +5145,14 @@ describe("SessionRunnerLLM", () => {
const context = yield* s.context
const assistant = requireAssistant(context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => event.type)).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => event.type)).toEqual([
"session.step.started.1",
"session.tool.called.1",
"session.tool.failed.2",
"session.step.failed.1",
])
expect(bus[2]?.data.error).toMatchObject({ type: "unknown", message: "unexpected tool defect" })
expect(events[2]?.data.error).toMatchObject({ type: "unknown", message: "unexpected tool defect" })
})
scenario("preserves the provider failure when tool output persistence also fails", function* (s) {
@@ -5179,15 +5179,15 @@ describe("SessionRunnerLLM", () => {
"Provider did not return a tool result",
)
const assistant = requireAssistant(yield* s.context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => event.type)).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => event.type)).toEqual([
"session.step.started.1",
"session.tool.called.1",
"session.tool.failed.2",
"session.step.failed.1",
])
expect(
bus.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
events.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
).toHaveLength(1)
yield* replaySessionProjection(sessionID)
@@ -5205,15 +5205,15 @@ describe("SessionRunnerLLM", () => {
yield* s.runPrompt("Settle hosted tool before ending")
const assistant = requireAssistant(yield* s.context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => event.type)).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => event.type)).toEqual([
"session.step.started.1",
"session.tool.called.1",
"session.tool.failed.2",
"session.step.ended.1",
])
expect(
bus.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
events.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
).toHaveLength(1)
})
@@ -5239,8 +5239,8 @@ describe("SessionRunnerLLM", () => {
expect(yield* Fiber.join(run).pipe(Effect.flip)).toBe(failure)
const assistant = requireAssistant(yield* s.context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => ({ type: event.type, id: event.data.id }))).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => ({ type: event.type, id: event.data.id }))).toEqual([
{ type: "session.step.started.1", id: undefined },
{ type: "session.tool.called.1", id: "call-local-raw-failure" },
{ type: "session.tool.called.1", id: "call-hosted-raw-failure-pair" },
@@ -5249,7 +5249,7 @@ describe("SessionRunnerLLM", () => {
{ type: "session.step.failed.1", id: undefined },
])
expect(
bus.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
events.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
).toHaveLength(1)
})
@@ -5265,15 +5265,15 @@ describe("SessionRunnerLLM", () => {
expect(yield* s.runPrompt("Fail hosted tool on raw failure").pipe(Effect.flip)).toBe(failure)
expect(s.requests).toHaveLength(1)
const assistant = requireAssistant(yield* s.context)
const bus = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(bus.map((event) => event.type)).toEqual([
const events = yield* recordedStepSettlementEvents(sessionID, assistant.id)
expect(events.map((event) => event.type)).toEqual([
"session.step.started.1",
"session.tool.called.1",
"session.tool.failed.2",
"session.step.failed.1",
])
expect(
bus.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
events.filter((event) => event.type.startsWith("session.step.") && event.type !== "session.step.started.1"),
).toHaveLength(1)
yield* replaySessionProjection(sessionID)
expect(yield* s.context).toMatchObject([