43 lines
1.0 KiB
TypeScript
43 lines
1.0 KiB
TypeScript
import type {
|
|
AsyncResult,
|
|
MaybePromise,
|
|
PosixDate,
|
|
UUID,
|
|
VariantFromTag,
|
|
VariantTag,
|
|
} from "@fabric/core";
|
|
import type { StoreQueryError } from "../errors/query-error.ts";
|
|
import type { Event } from "./event.ts";
|
|
import type { StoredEvent } from "./stored-event.ts";
|
|
|
|
export interface EventStore<TEvents extends Event> {
|
|
/**
|
|
* Store a new event in the event store.
|
|
*/
|
|
append<T extends TEvents>(
|
|
event: T,
|
|
): AsyncResult<StoredEvent<T>, StoreQueryError>;
|
|
|
|
getEventsFromStream(
|
|
streamId: UUID,
|
|
): AsyncResult<StoredEvent<TEvents>[], StoreQueryError>;
|
|
|
|
subscribe<TEventKey extends TEvents[VariantTag]>(
|
|
events: TEventKey[],
|
|
subscriber: EventSubscriber<VariantFromTag<TEvents, TEventKey>>,
|
|
): void;
|
|
}
|
|
|
|
export type EventSubscriber<TEvents extends Event = Event> = (
|
|
event: StoredEvent<TEvents>,
|
|
) => MaybePromise<void>;
|
|
|
|
export interface EventFilterOptions {
|
|
fromDate?: PosixDate;
|
|
toDate?: PosixDate;
|
|
fromVersion?: bigint;
|
|
toVersion?: bigint;
|
|
limit?: number;
|
|
offset?: number;
|
|
}
|