[fabric/domain] Refactor event store and event stream interfaces

packages/fabric/domain/src/events/event-store.ts

@@ -1,36 +1,26 @@
-import { AsyncResult, MaybePromise, PosixDate } from "@fabric/core";
+import { AsyncResult, PosixDate } from "@fabric/core";
 import { StoreQueryError } from "../errors/query-error.js";
-import { UUID } from "../types/uuid.js";
+import { EventsFromStream, EventStream } from "./event-stream.js";
-import { Event, StoredEvent } from "./event.js";
+import { StoredEvent } from "./stored-event.js";
 
-export interface EventStore<TEvent extends Event = Event> {
+export interface EventStore<TEventStream extends EventStream> {
-  getStream<TEventStreamEvent extends TEvent>(
+  /**
-    streamId: UUID,
+   * Store a new event in the event store.
-  ): AsyncResult<EventStream<TEventStreamEvent>, StoreQueryError>;
+   */
-
+  append<
-  appendToStream<TEvent extends Event>(
+    TStreamKey extends TEventStream["name"],
-    streamId: UUID,
+    T extends EventsFromStream<TEventStream, TStreamKey>,
-    events: TEvent,
+  >(
-  ): AsyncResult<void, StoreQueryError>;
+    streamName: TStreamKey,
-}
+    event: T,
-
+  ): AsyncResult<StoredEvent<T>, StoreQueryError>;
-export interface EventStream<TEvent extends Event = Event> {
-  getCurrentVersion(): bigint;
-
-  append(events: TEvent): AsyncResult<StoredEvent<TEvent>, StoreQueryError>;
-
-  subscribe(callback: (event: StoredEvent<TEvent>) => MaybePromise<void>): void;
-
-  getEvents(
-    opts?: EventFilterOptions,
-  ): AsyncResult<StoredEvent<TEvent>[], StoreQueryError>;
 }
 
 export interface EventFilterOptions {
   fromDate?: PosixDate;
   toDate?: PosixDate;
-  fromVersion?: number;
+  fromVersion?: bigint;
-  toVersion?: number;
+  toVersion?: bigint;
   limit?: number;
   offset?: number;
 }

packages/fabric/domain/src/events/event-stream.ts

@@ -0,0 +1,16 @@
+import { AsyncResult } from "@fabric/core";
+import { UUID } from "../types/uuid.js";
+import { Event } from "./event.js";
+import { StoredEvent } from "./stored-event.js";
+
+export interface EventStream<
+  TName extends string = string,
+  TEvent extends Event = Event,
+> {
+  id: UUID;
+  name: TName;
+  append<T extends TEvent>(event: Event): AsyncResult<StoredEvent<T>>;
+}
+
+export type EventsFromStream<T extends EventStream, TKey extends string> =
+  T extends EventStream<TKey, infer TEvent> ? TEvent : never;

packages/fabric/domain/src/events/event.ts

@@ -1,20 +1,12 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { PosixDate, TaggedVariant } from "@fabric/core";
 import { UUID } from "../types/uuid.js";
 
 /**
  * An event is a tagged variant with a payload and a timestamp.
  */
-export interface Event<TTag extends string = string, TPayload = any>
+export interface Event<TTag extends string = string, TPayload = any> {
-  extends TaggedVariant<TTag> {
+  readonly type: TTag;
-  streamId: UUID;
+  readonly id: UUID;
-  payload: TPayload;
+  readonly streamId: UUID;
+  readonly payload: TPayload;
 }
-
-/**
- * A stored event is an inmutable event, already stored, with it's version in the stream and timestamp.
- */
-export type StoredEvent<TEvent extends Event> = Readonly<TEvent> & {
-  readonly version: number;
-  readonly timestamp: PosixDate;
-};

packages/fabric/domain/src/events/index.ts

@@ -1,2 +1,4 @@
 export * from "./event-store.js";
+export * from "./event-stream.js";
 export * from "./event.js";
+export * from "./stored-event.js";

packages/fabric/domain/src/events/stored-event.ts

@@ -0,0 +1,10 @@
+import { PosixDate } from "@fabric/core";
+import { Event } from "./event.js";
+
+/**
+ * A stored event is an inmutable event, already stored, with it's version in the stream and timestamp.
+ */
+export type StoredEvent<TEvent extends Event> = TEvent & {
+  readonly version: bigint;
+  readonly timestamp: PosixDate;
+};