Dashboard › opencode › Distillation
1d0f7b11-ec3a-400b-a0e7-d2a00192c9a7["lore_tm_v1_y-QwvKEMY5__nOEWrtVnl2cLKOtxK7tM4fN7ePccBOk","lore_tm_v1_4gJl68o92FaJ26kvixcyk-2rMqQG1QxHiJLtxRQXKE8","lore_tm_v1_zUuPhq947tx-pd2ycmFQ3MIzFCr0zzz6DYpjsu9CZFE"]
Date: Sep 14, 2026
packages/core/test/session-execution-local.test.ts, using testEffect(Database.layerFromPath(":memory:")), sessionID = SessionSchema.ID.make("ses_execution_local"), and an in-memory ProjectTable/SessionTable fixture rooted at /project.packages/core/test/session-execution-local.test.ts adds exactly 3 SessionExecutionLocal lifecycle tests: 1. "clears the claim after a successful drain"—execution.resume(sessionID) leaves SessionExecutionTable empty; 2. "preserves the claim when its scope closes"—closing the child Scope with Scope.close(child, Exit.void) leaves exactly 1 claim; 3. "clears the claim after explicit interruption"—execution.interrupt(sessionID) leaves the claims empty.packages/core/test/session-projector.test.ts to import Exit, SessionRecovery, SessionExecutionTable, and SessionRecoveryTable.packages/core/test/session-projector.test.ts defines recoveryExecution = SessionExecution.Service.of({ active: Effect.succeed(new Set()), interrupt: () => Effect.void, resume: () => Effect.void, wake: () => Effect.void }) for recovery tests."never recovers an execution superseded by a newer assistant"; the test invokes SessionRecovery.recover().pipe(Effect.provideService(SessionExecution.Service, recoveryExecution)).dc661f30cb2055ad6248fdc59b14998d834497be, packages/core/src/event.ts:369 defines function publishEvent<D extends Definition>(definition: D, event: Payload<D>, commit?: PublishOptions["commit"]).