Compare commits
No commits in common. "8c6f043f865b9894e545d9e79a7c5294b3397e99" and "4ea00f515b05eddaf620af5712d24424ce6276be" have entirely different histories.
8c6f043f86
...
4ea00f515b
@ -3,15 +3,14 @@ import { TaggedVariant, VariantTag } from "../variant/index.js";
|
||||
/**
|
||||
* A TaggedError is a tagged variant with an error message.
|
||||
*/
|
||||
export abstract class TaggedError<Tag extends string = string>
|
||||
export class TaggedError<Tag extends string = string>
|
||||
extends Error
|
||||
implements TaggedVariant<Tag>
|
||||
{
|
||||
readonly [VariantTag]: Tag;
|
||||
|
||||
constructor(tag: Tag, message?: string) {
|
||||
super(message);
|
||||
constructor(tag: Tag) {
|
||||
super();
|
||||
this[VariantTag] = tag;
|
||||
this.name = tag;
|
||||
}
|
||||
}
|
||||
|
||||
@ -8,7 +8,12 @@ import { TaggedError } from "./tagged-error.js";
|
||||
* we must be prepared to handle.
|
||||
*/
|
||||
export class UnexpectedError extends TaggedError<"UnexpectedError"> {
|
||||
constructor(message?: string) {
|
||||
super("UnexpectedError", message);
|
||||
constructor(readonly context: Record<string, unknown> = {}) {
|
||||
super("UnexpectedError");
|
||||
this.message = "An unexpected error occurred";
|
||||
}
|
||||
|
||||
toString() {
|
||||
return `UnexpectedError: ${this.message}\n${JSON.stringify(this.context, null, 2)}`;
|
||||
}
|
||||
}
|
||||
|
||||
@ -5,5 +5,4 @@ export * from "./result/index.js";
|
||||
export * from "./run/index.js";
|
||||
export * from "./time/index.js";
|
||||
export * from "./types/index.js";
|
||||
export * from "./utils/index.js";
|
||||
export * from "./variant/index.js";
|
||||
|
||||
@ -3,4 +3,3 @@ export * from "./fn.js";
|
||||
export * from "./keyof.js";
|
||||
export * from "./maybe-promise.js";
|
||||
export * from "./optional.js";
|
||||
export * from "./record.js";
|
||||
|
||||
@ -1,8 +0,0 @@
|
||||
import { UnexpectedError } from "../error/unexpected-error.js";
|
||||
|
||||
export function ensureValue<T>(value?: T): T {
|
||||
if (!value) {
|
||||
throw new UnexpectedError("Value is undefined");
|
||||
}
|
||||
return value;
|
||||
}
|
||||
@ -1 +0,0 @@
|
||||
export * from "./ensure-value.js";
|
||||
@ -1,21 +1,17 @@
|
||||
import { Fn } from "../types/fn.js";
|
||||
import { TaggedVariant, VariantFromTag, VariantTag } from "./variant.js";
|
||||
|
||||
export type VariantMatcher<TVariant extends TaggedVariant<string>, T> = {
|
||||
[K in TVariant[VariantTag]]: Fn<VariantFromTag<TVariant, K>, T>;
|
||||
export type VariantMatcher<TVariant extends TaggedVariant<string>> = {
|
||||
[K in TVariant[VariantTag]]: Fn<VariantFromTag<TVariant, K>>;
|
||||
};
|
||||
|
||||
export function match<const TVariant extends TaggedVariant<string>>(
|
||||
v: TVariant,
|
||||
) {
|
||||
return {
|
||||
case<
|
||||
const TReturnType,
|
||||
const TMatcher extends VariantMatcher<
|
||||
TVariant,
|
||||
TReturnType
|
||||
> = VariantMatcher<TVariant, TReturnType>,
|
||||
>(cases: TMatcher): TReturnType {
|
||||
case<const TMatcher extends VariantMatcher<TVariant>>(
|
||||
cases: TMatcher,
|
||||
): ReturnType<TMatcher[TVariant[VariantTag]]> {
|
||||
if (!(v[VariantTag] in cases)) {
|
||||
throw new Error("Non-exhaustive pattern match");
|
||||
}
|
||||
|
||||
@ -7,7 +7,7 @@ export interface TaggedVariant<TTag extends string> {
|
||||
|
||||
export type VariantFromTag<
|
||||
TVariant extends TaggedVariant<string>,
|
||||
TTag extends TVariant[VariantTag],
|
||||
TTag extends TVariant[typeof VariantTag],
|
||||
> = Extract<TVariant, { [VariantTag]: TTag }>;
|
||||
|
||||
export namespace Variant {
|
||||
|
||||
@ -1,7 +1,12 @@
|
||||
/* eslint-disable @typescript-eslint/no-explicit-any */
|
||||
|
||||
import { TaggedError } from "@fabric/core";
|
||||
|
||||
export class StoreQueryError extends TaggedError<"StoreQueryError"> {
|
||||
constructor(public message: string) {
|
||||
super("StoreQueryError", message);
|
||||
constructor(
|
||||
public message: string,
|
||||
public context: any,
|
||||
) {
|
||||
super("StoreQueryError");
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,13 +1,7 @@
|
||||
import {
|
||||
AsyncResult,
|
||||
MaybePromise,
|
||||
PosixDate,
|
||||
VariantFromTag,
|
||||
VariantTag,
|
||||
} from "@fabric/core";
|
||||
import { AsyncResult, MaybePromise, PosixDate } from "@fabric/core";
|
||||
import { StoreQueryError } from "../errors/query-error.js";
|
||||
import { UUID } from "../types/uuid.js";
|
||||
import { Event } from "./event.js";
|
||||
import { Event, EventFromKey } from "./event.js";
|
||||
import { StoredEvent } from "./stored-event.js";
|
||||
|
||||
export interface EventStore<TEvents extends Event> {
|
||||
@ -22,9 +16,9 @@ export interface EventStore<TEvents extends Event> {
|
||||
streamId: UUID,
|
||||
): AsyncResult<StoredEvent<TEvents>[], StoreQueryError>;
|
||||
|
||||
subscribe<TEventKey extends TEvents[VariantTag]>(
|
||||
subscribe<TEventKey extends TEvents["type"]>(
|
||||
events: TEventKey[],
|
||||
subscriber: EventSubscriber<VariantFromTag<TEvents, TEventKey>>,
|
||||
subscriber: EventSubscriber<EventFromKey<TEvents, TEventKey>>,
|
||||
): void;
|
||||
}
|
||||
|
||||
|
||||
@ -1,12 +1,11 @@
|
||||
/* eslint-disable @typescript-eslint/no-explicit-any */
|
||||
import { VariantTag } 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> {
|
||||
readonly [VariantTag]: TTag;
|
||||
readonly type: TTag;
|
||||
readonly id: UUID;
|
||||
readonly streamId: UUID;
|
||||
readonly payload: TPayload;
|
||||
@ -14,5 +13,5 @@ export interface Event<TTag extends string = string, TPayload = any> {
|
||||
|
||||
export type EventFromKey<
|
||||
TEvents extends Event,
|
||||
TKey extends TEvents[VariantTag],
|
||||
> = Extract<TEvents, { [VariantTag]: TKey }>;
|
||||
TKey extends TEvents["type"],
|
||||
> = Extract<TEvents, { type: TKey }>;
|
||||
|
||||
@ -19,7 +19,6 @@ export const DefaultModelFields = {
|
||||
isUnsigned: true,
|
||||
hasArbitraryPrecision: true,
|
||||
}),
|
||||
deletedAt: Field.timestamp({ isOptional: true }),
|
||||
};
|
||||
|
||||
export interface Model<
|
||||
|
||||
@ -1,13 +0,0 @@
|
||||
import { VariantTag } from "@fabric/core";
|
||||
import { Event } from "../events/event.js";
|
||||
import { StoredEvent } from "../events/stored-event.js";
|
||||
import { Model, ModelToType } from "../models/model.js";
|
||||
|
||||
export interface Projection<TModel extends Model, TEvents extends Event> {
|
||||
model: TModel;
|
||||
events: TEvents[VariantTag][];
|
||||
projection: (
|
||||
event: StoredEvent<TEvents>,
|
||||
model?: ModelToType<TModel>,
|
||||
) => ModelToType<TModel>;
|
||||
}
|
||||
@ -26,7 +26,7 @@ describe("Event Store", () => {
|
||||
const newUUID = UUIDGeneratorMock.generate();
|
||||
|
||||
const userCreated: UserCreated = {
|
||||
_tag: "UserCreated",
|
||||
type: "UserCreated",
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
payload: { name: "test" },
|
||||
@ -41,7 +41,7 @@ describe("Event Store", () => {
|
||||
expect(events[0]).toEqual({
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
_tag: "UserCreated",
|
||||
type: "UserCreated",
|
||||
version: BigInt(1),
|
||||
timestamp: expect.any(PosixDate),
|
||||
payload: { name: "test" },
|
||||
@ -52,7 +52,7 @@ describe("Event Store", () => {
|
||||
const newUUID = UUIDGeneratorMock.generate();
|
||||
|
||||
const userCreated: UserCreated = {
|
||||
_tag: "UserCreated",
|
||||
type: "UserCreated",
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
payload: { name: "test" },
|
||||
@ -68,7 +68,7 @@ describe("Event Store", () => {
|
||||
expect(subscriber).toHaveBeenCalledWith({
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
_tag: "UserCreated",
|
||||
type: "UserCreated",
|
||||
version: BigInt(1),
|
||||
timestamp: expect.any(PosixDate),
|
||||
payload: { name: "test" },
|
||||
|
||||
@ -1,10 +1,4 @@
|
||||
import {
|
||||
AsyncResult,
|
||||
MaybePromise,
|
||||
PosixDate,
|
||||
Run,
|
||||
VariantTag,
|
||||
} from "@fabric/core";
|
||||
import { AsyncResult, MaybePromise, PosixDate, Run } from "@fabric/core";
|
||||
import {
|
||||
Event,
|
||||
EventFromKey,
|
||||
@ -25,7 +19,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
private streamVersions = new Map<UUID, bigint>();
|
||||
|
||||
private eventSubscribers = new Map<
|
||||
TEvents[VariantTag],
|
||||
TEvents["type"],
|
||||
EventSubscriber<TEvents>[]
|
||||
>();
|
||||
|
||||
@ -40,7 +34,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
await this.db.run(
|
||||
`CREATE TABLE IF NOT EXISTS events (
|
||||
id TEXT PRIMARY KEY,
|
||||
_tag TEXT NOT NULL,
|
||||
type TEXT NOT NULL,
|
||||
streamId TEXT NOT NULL,
|
||||
version INTEGER NOT NULL,
|
||||
timestamp NUMERIC NOT NULL,
|
||||
@ -49,7 +43,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
)`,
|
||||
);
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) => new StoreQueryError(error.message, { error }),
|
||||
);
|
||||
}
|
||||
|
||||
@ -63,18 +57,18 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
{
|
||||
$id: streamId,
|
||||
},
|
||||
(e) => ({
|
||||
id: e.id,
|
||||
streamId: e.streamId,
|
||||
_tag: e._tag,
|
||||
version: BigInt(e.version),
|
||||
timestamp: new PosixDate(e.timestamp),
|
||||
payload: JSONUtils.parse(e.payload),
|
||||
(event) => ({
|
||||
id: event.id,
|
||||
streamId: event.streamId,
|
||||
type: event.type,
|
||||
version: BigInt(event.version),
|
||||
timestamp: new PosixDate(event.timestamp),
|
||||
payload: JSONUtils.parse(event.payload),
|
||||
}),
|
||||
);
|
||||
return events;
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) => new StoreQueryError(error.message, { error }),
|
||||
);
|
||||
}
|
||||
|
||||
@ -101,7 +95,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
event: StoredEvent<TEvents>,
|
||||
): AsyncResult<void> {
|
||||
return AsyncResult.from(async () => {
|
||||
const subscribers = this.eventSubscribers.get(event[VariantTag]) || [];
|
||||
const subscribers = this.eventSubscribers.get(event.type) || [];
|
||||
await Promise.all(subscribers.map((subscriber) => subscriber(event)));
|
||||
});
|
||||
}
|
||||
@ -120,17 +114,20 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
|
||||
return !lastVersion ? 0n : BigInt(lastVersion);
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) =>
|
||||
new StoreQueryError(`Error getting last version:${error.message}`, {
|
||||
error,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
subscribe<TEventKey extends TEvents[VariantTag]>(
|
||||
eventNames: TEventKey[],
|
||||
subscribe<TEventKey extends TEvents["type"]>(
|
||||
events: TEventKey[],
|
||||
subscriber: (
|
||||
event: StoredEvent<EventFromKey<TEvents, TEventKey>>,
|
||||
) => MaybePromise<void>,
|
||||
): void {
|
||||
eventNames.forEach((event) => {
|
||||
events.forEach((event) => {
|
||||
const subscribers = this.eventSubscribers.get(event) || [];
|
||||
const newSubscribers = [
|
||||
...subscribers,
|
||||
@ -143,7 +140,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
close(): AsyncResult<void, StoreQueryError> {
|
||||
return AsyncResult.tryFrom(
|
||||
() => this.db.close(),
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) => new StoreQueryError(error.message, { error }),
|
||||
);
|
||||
}
|
||||
|
||||
@ -160,12 +157,12 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
timestamp: new PosixDate(),
|
||||
};
|
||||
await this.db.runPrepared(
|
||||
`INSERT INTO events (id, streamId, _tag, version, timestamp, payload)
|
||||
VALUES ($id, $streamId, $_tag, $version, $timestamp, $payload)`,
|
||||
`INSERT INTO events (id, streamId, type, version, timestamp, payload)
|
||||
VALUES ($id, $streamId, $type, $version, $timestamp, $payload)`,
|
||||
{
|
||||
$id: storedEvent.id,
|
||||
$streamId: streamId,
|
||||
$_tag: storedEvent[VariantTag],
|
||||
$type: storedEvent.type,
|
||||
$version: storedEvent.version.toString(),
|
||||
$timestamp: storedEvent.timestamp.timestamp,
|
||||
$payload: JSON.stringify(storedEvent.payload),
|
||||
@ -173,7 +170,7 @@ export class SQLiteEventStore<TEvents extends Event>
|
||||
);
|
||||
return storedEvent;
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) => new StoreQueryError("Error appending event", { error }),
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@ -14,9 +14,6 @@ export function transformRow(model: Collection) {
|
||||
}
|
||||
|
||||
function valueFromSQL(field: FieldDefinition, value: any): any {
|
||||
if (value === null) {
|
||||
return null;
|
||||
}
|
||||
const r = FieldSQLInsertMap[field[VariantTag]];
|
||||
return r(field as any, value);
|
||||
}
|
||||
|
||||
@ -25,9 +25,6 @@ const FieldSQLInsertMap: FieldSQLInsertMap = {
|
||||
};
|
||||
|
||||
export function fieldValueToSQL(field: FieldDefinition, value: any) {
|
||||
if (value === null) {
|
||||
return null;
|
||||
}
|
||||
const r = FieldSQLInsertMap[field[VariantTag]] as any;
|
||||
return r(field as any, value);
|
||||
}
|
||||
|
||||
@ -62,7 +62,11 @@ export class QueryBuilder<T> implements StoreQuery<T> {
|
||||
transformRow(this.schema[this.query.from]),
|
||||
);
|
||||
},
|
||||
(err) => new StoreQueryError(err.message),
|
||||
(err) =>
|
||||
new StoreQueryError(err.message, {
|
||||
err,
|
||||
query: this.query,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
@ -87,7 +91,11 @@ export class QueryBuilder<T> implements StoreQuery<T> {
|
||||
transformRow(this.schema[this.query.from]),
|
||||
);
|
||||
},
|
||||
(err) => new StoreQueryError(err.message),
|
||||
(err) =>
|
||||
new StoreQueryError(err.message, {
|
||||
err,
|
||||
query: this.query,
|
||||
}),
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
import { PosixDate, Run } from "@fabric/core";
|
||||
import { Run } from "@fabric/core";
|
||||
import { defineModel, Field, isLike, UUID } from "@fabric/domain";
|
||||
import { UUIDGeneratorMock } from "@fabric/domain/mocks";
|
||||
import {
|
||||
@ -42,7 +42,6 @@ describe("State Store", () => {
|
||||
name: "test",
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
});
|
||||
@ -56,7 +55,6 @@ describe("State Store", () => {
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
|
||||
@ -68,7 +66,6 @@ describe("State Store", () => {
|
||||
streamId: UUID;
|
||||
streamVersion: bigint;
|
||||
name: string;
|
||||
deletedAt: PosixDate | null;
|
||||
}[]
|
||||
>();
|
||||
|
||||
@ -78,7 +75,6 @@ describe("State Store", () => {
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
name: "test",
|
||||
deletedAt: null,
|
||||
},
|
||||
]);
|
||||
});
|
||||
@ -93,7 +89,6 @@ describe("State Store", () => {
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
() =>
|
||||
store.insertInto("users", {
|
||||
@ -101,7 +96,6 @@ describe("State Store", () => {
|
||||
id: UUIDGeneratorMock.generate(),
|
||||
streamId: UUIDGeneratorMock.generate(),
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
() =>
|
||||
store.insertInto("users", {
|
||||
@ -109,7 +103,6 @@ describe("State Store", () => {
|
||||
id: UUIDGeneratorMock.generate(),
|
||||
streamId: UUIDGeneratorMock.generate(),
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
|
||||
@ -128,7 +121,6 @@ describe("State Store", () => {
|
||||
streamId: UUID;
|
||||
streamVersion: bigint;
|
||||
name: string;
|
||||
deletedAt: PosixDate | null;
|
||||
}[]
|
||||
>();
|
||||
|
||||
@ -138,7 +130,6 @@ describe("State Store", () => {
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
name: "test",
|
||||
deletedAt: null,
|
||||
},
|
||||
]);
|
||||
});
|
||||
@ -152,7 +143,6 @@ describe("State Store", () => {
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
|
||||
@ -171,7 +161,6 @@ describe("State Store", () => {
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
name: "updated",
|
||||
deletedAt: null,
|
||||
});
|
||||
});
|
||||
|
||||
@ -184,7 +173,6 @@ describe("State Store", () => {
|
||||
id: newUUID,
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
|
||||
@ -209,7 +197,6 @@ describe("State Store", () => {
|
||||
name: "test",
|
||||
streamId: ownerUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
|
||||
@ -220,7 +207,6 @@ describe("State Store", () => {
|
||||
owner: ownerUUID,
|
||||
streamId: newUUID,
|
||||
streamVersion: 1n,
|
||||
deletedAt: null,
|
||||
}),
|
||||
);
|
||||
});
|
||||
|
||||
@ -52,7 +52,12 @@ export class SQLiteStateStore<TModel extends Model>
|
||||
recordToSQLParams(model, record),
|
||||
);
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) =>
|
||||
new StoreQueryError(error.message, {
|
||||
error,
|
||||
collectionName: model.name,
|
||||
record,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
@ -82,7 +87,12 @@ export class SQLiteStateStore<TModel extends Model>
|
||||
params,
|
||||
);
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) =>
|
||||
new StoreQueryError(error.message, {
|
||||
error,
|
||||
collectionName: model.name,
|
||||
record,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
@ -99,7 +109,12 @@ export class SQLiteStateStore<TModel extends Model>
|
||||
{ $id: id },
|
||||
);
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) =>
|
||||
new StoreQueryError(error.message, {
|
||||
error,
|
||||
collectionName: model.name,
|
||||
id,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
@ -115,7 +130,11 @@ export class SQLiteStateStore<TModel extends Model>
|
||||
}
|
||||
});
|
||||
},
|
||||
(error) => new StoreQueryError(error.message),
|
||||
(error) =>
|
||||
new StoreQueryError(error.message, {
|
||||
error,
|
||||
schema: this.schema,
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user