@castore/core
Advanced tools
Comparing version 0.7.3 to 1.0.0
@@ -23,3 +23,3 @@ /// <reference types="jest" /> | ||
}; | ||
export declare const requiredEventStores: [import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
export declare const requiredEventStores: [import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -69,3 +69,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -114,3 +114,3 @@ version: number; | ||
export declare const onEventAlreadyExistsMock: jest.Mock<any, any>; | ||
export declare const incrementCounter: JSONSchemaCommand<[import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
export declare const incrementCounter: JSONSchemaCommand<[import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -160,3 +160,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -203,3 +203,3 @@ version: number; | ||
timestamp: string; | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -249,3 +249,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -315,3 +315,3 @@ version: number; | ||
}>; | ||
export declare const incrementCounterNoOutput: JSONSchemaCommand<[import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
export declare const incrementCounterNoOutput: JSONSchemaCommand<[import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -361,3 +361,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -404,3 +404,3 @@ version: number; | ||
timestamp: string; | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -450,3 +450,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -505,3 +505,3 @@ version: number; | ||
}, import("json-schema-to-ts").JSONSchema7 | undefined, void>; | ||
export declare const incrementCounterA: JSONSchemaCommand<[import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
export declare const incrementCounterA: JSONSchemaCommand<[import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -551,3 +551,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -594,3 +594,3 @@ version: number; | ||
timestamp: string; | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -640,3 +640,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -695,3 +695,3 @@ version: number; | ||
}>; | ||
export declare const incrementCounterANoOutput: JSONSchemaCommand<[import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
export declare const incrementCounterANoOutput: JSONSchemaCommand<[import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -741,3 +741,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -784,3 +784,3 @@ version: number; | ||
timestamp: string; | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<(import("../..").EventType<"COUNTER_CREATED", { | ||
}, (userAggregate: import("../../eventStore.util.test").UserAggregate, event: import("../../eventStore.util.test").UserEventsDetails) => import("../../eventStore.util.test").UserAggregate, import("../../eventStore.util.test").UserAggregate>], [import("../..").EventStore<"Counters", (import("../..").EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -830,3 +830,3 @@ version: number; | ||
timestamp: string; | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<(import("../..").EventType<"USER_CREATED", { | ||
}, (counterAggregate: import("../../eventStore.util.test").CounterAggregate, event: import("../../eventStore.util.test").CounterEventsDetails) => import("../../eventStore.util.test").CounterAggregate, import("../../eventStore.util.test").CounterAggregate>, import("../..").EventStore<"Users", (import("../..").EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -833,0 +833,0 @@ version: number; |
@@ -8,3 +8,3 @@ import { Aggregate } from './aggregate'; | ||
}; | ||
export declare class EventStore<E extends EventType[] = EventType[], $D extends EventDetail = EventTypesDetails<E>, D extends EventDetail = EventDetail extends $D ? any : $D, R extends (aggregate: any, event: D) => Aggregate = (aggregate: any, event: D) => Aggregate, A extends Aggregate = ReturnType<R>> { | ||
export declare class EventStore<I extends string = string, E extends EventType[] = EventType[], $D extends EventDetail = EventTypesDetails<E>, D extends EventDetail = EventDetail extends $D ? any : $D, R extends (aggregate: any, event: D) => Aggregate = (aggregate: any, event: D) => Aggregate, A extends Aggregate = ReturnType<R>> { | ||
_types: { | ||
@@ -14,3 +14,3 @@ details: $D; | ||
}; | ||
eventStoreId: string; | ||
eventStoreId: I; | ||
eventStoreEvents: E; | ||
@@ -36,3 +36,3 @@ reduce: R; | ||
constructor({ eventStoreId, eventStoreEvents, reduce, simulateSideEffect, storageAdapter, }: { | ||
eventStoreId: string; | ||
eventStoreId: I; | ||
eventStoreEvents: E; | ||
@@ -39,0 +39,0 @@ reduce: R; |
@@ -38,3 +38,3 @@ /// <reference types="jest" /> | ||
export declare const countersReducer: (counterAggregate: CounterAggregate, event: CounterEventsDetails) => CounterAggregate; | ||
export declare const counterEventStore: EventStore<(EventType<"COUNTER_CREATED", { | ||
export declare const counterEventStore: EventStore<"Counters", (EventType<"COUNTER_CREATED", { | ||
aggregateId: string; | ||
@@ -112,3 +112,3 @@ version: number; | ||
export declare const usersReducer: (userAggregate: UserAggregate, event: UserEventsDetails) => UserAggregate; | ||
export declare const userEventStore: EventStore<(EventType<"USER_CREATED", { | ||
export declare const userEventStore: EventStore<"Users", (EventType<"USER_CREATED", { | ||
aggregateId: string; | ||
@@ -115,0 +115,0 @@ version: number; |
{ | ||
"name": "@castore/core", | ||
"version": "0.7.3", | ||
"version": "1.0.0", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/theodo/castore#readme", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
211256
0
0