Distillation

Date: Sep 16, 2026

• 🔴 (13:29) packages/core/src/event.ts exports EventV2 from "./event" and re-exports Data, Definition, and Payload from @opencode-ai/schema/event; it aliases ID to Event.ID.
• 🔴 (13:29) packages/core/src/event.ts imports Effect primitives Cause, Context, Effect, Layer, Option, PubSub, Queue, Schema, and Stream, plus Drizzle operators and, asc, eq, gt, and inArray.
• 🔴 (13:29) packages/core/src/event.ts uses EventSequenceTable and EventTable from ./event/sql, Database from ./database/database, Location from ./location, makeGlobalNode from ./effect/app-node, isDeepStrictEqual from node:util, and Durable from @opencode-ai/schema/durable-event-manifest.
• 🔴 (13:29) The event implementation defines Subscriber<D extends Definition = Definition> as (event: Payload<D>) => Effect.Effect<void> and Unsubscribe as Effect.Effect<void>.
• 🔴 (13:29) latestSequence is declared with Effect.fn("EventV2.latestSequence") and accepts db: Database.Interface["db"] plus aggregateID: string.
• 🔴 (13:29) Durable-event processing obtains the event definition with Durable.get(event.type).
• 🔴 (13:29) Event pagination computes page with rows.slice(0, input.limit).
• 🔴 (13:29) versionedType is directly aliased to Event.versionedType.
• 🔴 (13:29) The event service exposes replay/listening behavior, including replayAll and listener unsubscription through events.listen(...); listeners are stored as new Array<Subscriber>().
• 🔴 (13:29) Durable event sequencing derives latest as row?.seq ?? -1, checks if (input && input.seq <= latest), and can fail with InvalidDurableEventError.
• 🔴 (13:29) Event-sequence persistence inserts values shaped as { aggregate_id: aggregateID, seq, owner_id: input?.ownerID }, preserving an optional owner ID alongside the aggregate sequence.