ultharsoftware/ulthar-framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[fabric/sqlite-store] Refactor event types to use DomainEvent

Browse Source
This commit is contained in:
Pablo Baleztena 2024-10-30 22:41:47 -03:00
parent 60c7bacfb5
commit ce1f0a04f3
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packages/fabric/sqlite-store/events/event-store.test.ts
View File

@ -1,5 +1,5 @@
import { PosixDate } from "@fabric/core"; import { PosixDate } from "@fabric/core";
import { Event } from "@fabric/domain"; import { DomainEvent } from "@fabric/domain";
import { UUIDGeneratorMock } from "@fabric/domain/mocks"; import { UUIDGeneratorMock } from "@fabric/domain/mocks";
import { import {
afterEach, afterEach,
@ -12,9 +12,9 @@ import {
import { SQLiteEventStore } from "./event-store.ts"; import { SQLiteEventStore } from "./event-store.ts";
describe("Event Store", () => { describe("Event Store", () => {
type UserCreated = Event<"UserCreated", { name: string }>; type UserCreated = DomainEvent<"UserCreated", { name: string }>;
type UserUpdated = Event<"UserUpdated", { name: string }>; type UserUpdated = DomainEvent<"UserUpdated", { name: string }>;
type UserDeleted = Event<"UserDeleted", void>; type UserDeleted = DomainEvent<"UserDeleted", void>;
type UserEvents = UserCreated | UserUpdated | UserDeleted; type UserEvents = UserCreated | UserUpdated | UserDeleted;

6
packages/fabric/sqlite-store/events/event-store.ts
View File

@ -8,7 +8,7 @@ import {
VariantTag, VariantTag,
} from "@fabric/core"; } from "@fabric/core";
import { import {
Event, DomainEvent,
EventFromKey, EventFromKey,
EventStore, EventStore,
EventSubscriber, EventSubscriber,
@ -17,7 +17,7 @@ import {
} from "@fabric/domain"; } from "@fabric/domain";
import { SQLiteDatabase } from "../sqlite/sqlite-database.ts"; import { SQLiteDatabase } from "../sqlite/sqlite-database.ts";
export class SQLiteEventStore<TEvents extends Event> export class SQLiteEventStore<TEvents extends DomainEvent>
implements EventStore<TEvents> { implements EventStore<TEvents> {
private db: SQLiteDatabase; private db: SQLiteDatabase;
@ -139,7 +139,7 @@ export class SQLiteEventStore<TEvents extends Event>
); );
} }
private storeEvent<T extends Event>( private storeEvent<T extends DomainEvent>(
streamId: UUID, streamId: UUID,
version: bigint, version: bigint,
event: T, event: T,