Distillation

Date: Sep 14, 2026

• 🔴 (23:21) packages/core/src/event.ts exports EventV2 from "./event" and defines ID = Event.ID, type ID = import("@opencode-ai/schema/event").ID, Subscriber<D extends Definition = Definition> = (event: Payload<D>) => Effect.Effect<void>, and Unsubscribe = Effect.Effect<void>.
• 🔴 (23:21) packages/core/src/event.ts imports Cause, Context, Effect, Layer, Option, PubSub, Queue, Schema, and Stream from "effect"; Event, Data, Definition, and Payload from @opencode-ai/schema/event; Durable from @opencode-ai/schema/durable-event-manifest; and, asc, eq, gt, and inArray from "drizzle-orm"; isDeepStrictEqual from "node:util"; and local modules Database, EventSequenceTable, EventTable, Location, and makeGlobalNode.
• 🔴 (23:21) packages/core/src/event.ts defines latestSequence as Effect.fn("EventV2.latestSequence"), accepting db: Database.Interface["db"] and aggregateID: string.
• 🔴 (23:21) packages/core/src/event.ts documents a local operational projection as: "Local operational projection committed atomically with a new durable event. Not replayed or serialized."
• 🔴 (23:21) The event service interface in packages/core/src/event.ts includes claim: (aggregateID: string, ownerID: string) => Effect.Effect<void>.
• 🔴 (23:21) Reported file line counts: packages/core/test/session-runner.test.ts — 3475; packages/core/test/session-runner-tool-events.test.ts — 138; packages/core/schema.json — 2418; .lore.md — 607.