@castore/core
Advanced tools
Comparing version 1.20.1 to 1.20.2
@@ -6,3 +6,3 @@ import { NotificationMessageQueue, StateCarryingMessageBus } from "../messaging"; | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -19,3 +19,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -39,3 +39,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -51,3 +51,3 @@ } | { | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -64,3 +64,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -84,3 +84,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -95,3 +95,3 @@ } | { | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -108,3 +108,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -128,3 +128,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -140,3 +140,3 @@ } | { | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -153,3 +153,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -173,3 +173,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -185,3 +185,3 @@ } | { | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -198,3 +198,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -218,3 +218,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -229,3 +229,3 @@ } | { | ||
level: number; | ||
}, never> | import("..").EventType<"POKEMON_CATCHED", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("..").EventType<"POKEMON_CAUGHT", never, never> | import("..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -242,3 +242,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -262,3 +262,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -265,0 +265,0 @@ } | { |
@@ -17,5 +17,5 @@ import { EventType, EventTypeDetail } from "../event/eventType"; | ||
}, never>; | ||
export declare const pokemonCatchedEvent: EventType<"POKEMON_CATCHED", never, never>; | ||
export declare const pokemonCaughtEvent: EventType<"POKEMON_CAUGHT", never, never>; | ||
export declare const pokemonLeveledUpEvent: EventType<"POKEMON_LEVELED_UP", never, never>; | ||
export declare type PokemonEventDetails = EventTypeDetail<typeof pokemonAppearedEvent> | EventTypeDetail<typeof pokemonCatchedEvent> | EventTypeDetail<typeof pokemonLeveledUpEvent>; | ||
export declare type PokemonEventDetails = EventTypeDetail<typeof pokemonAppearedEvent> | EventTypeDetail<typeof pokemonCaughtEvent> | EventTypeDetail<typeof pokemonLeveledUpEvent>; | ||
export declare type PokemonAggregate = { | ||
@@ -26,7 +26,7 @@ aggregateId: string; | ||
level: number; | ||
status: 'wild' | 'catched'; | ||
status: 'wild' | 'caught'; | ||
}; | ||
export declare const pikachuId = "pikachuId"; | ||
export declare const pikachuAppearedEvent: PokemonEventDetails; | ||
export declare const pikachuCatchedEvent: PokemonEventDetails; | ||
export declare const pikachuCaughtEvent: PokemonEventDetails; | ||
export declare const pikachuLeveledUpEvent: PokemonEventDetails; | ||
@@ -45,3 +45,3 @@ export declare const pikachuEventsMocks: ({ | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -58,3 +58,3 @@ } | { | ||
level: number; | ||
}, never> | EventType<"POKEMON_CATCHED", never, never> | EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | EventType<"POKEMON_CAUGHT", never, never> | EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -71,3 +71,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -91,3 +91,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -94,0 +94,0 @@ } | { |
@@ -5,3 +5,3 @@ import { NotificationMessageQueue } from './notificationMessageQueue'; | ||
level: number; | ||
}, never> | import("../..").EventType<"POKEMON_CATCHED", never, never> | import("../..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("../..").EventType<"POKEMON_CAUGHT", never, never> | import("../..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -18,3 +18,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -38,3 +38,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -41,0 +41,0 @@ } | { |
@@ -5,3 +5,3 @@ import { StateCarryingMessageQueue } from './stateCarryingMessageQueue'; | ||
level: number; | ||
}, never> | import("../..").EventType<"POKEMON_CATCHED", never, never> | import("../..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
}, never> | import("../..").EventType<"POKEMON_CAUGHT", never, never> | import("../..").EventType<"POKEMON_LEVELED_UP", never, never>)[], { | ||
aggregateId: string; | ||
@@ -18,3 +18,3 @@ version: number; | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -38,3 +38,3 @@ } | { | ||
version: number; | ||
type: "POKEMON_CATCHED"; | ||
type: "POKEMON_CAUGHT"; | ||
timestamp: string; | ||
@@ -41,0 +41,0 @@ } | { |
@@ -77,3 +77,3 @@ { | ||
}, | ||
"version": "1.20.1" | ||
"version": "1.20.2" | ||
} |
@@ -231,3 +231,3 @@ <p align="center"> | ||
> // 👇 Equivalent to: | ||
> type PokemonCatchedEventTypeDetail = { | ||
> type PokemonCaughtEventTypeDetail = { | ||
> aggregateId: string; | ||
@@ -248,6 +248,6 @@ > version: number; | ||
> type PokemonEventTypeDetails = EventTypesDetails< | ||
> [typeof pokemonAppearedEventType, typeof pokemonCatchedEventType] | ||
> [typeof pokemonAppearedEventType, typeof pokemonCaughtEventType] | ||
> >; | ||
> // => EventTypeDetail<typeof pokemonAppearedEventType> | ||
> // | EventTypeDetail<typeof pokemonCatchedEventType> | ||
> // | EventTypeDetail<typeof pokemonCaughtEventType> | ||
> ``` | ||
@@ -274,3 +274,3 @@ > | ||
level: number; | ||
status: 'wild' | 'catched'; | ||
status: 'wild' | 'caught'; | ||
} | ||
@@ -284,3 +284,3 @@ | ||
level: number; | ||
status: 'wild' | 'catched'; | ||
status: 'wild' | 'caught'; | ||
} | ||
@@ -317,4 +317,4 @@ ``` | ||
} | ||
case 'POKEMON_CATCHED': | ||
return { ...pokemonAggregate, version, status: 'catched' }; | ||
case 'POKEMON_CAUGHT': | ||
return { ...pokemonAggregate, version, status: 'caught' }; | ||
case 'POKEMON_LEVELED_UP': | ||
@@ -357,3 +357,3 @@ return { | ||
pokemonAppearedEventType, | ||
pokemonCatchedEventType, | ||
pokemonCaughtEventType, | ||
pokemonLeveledUpEventType, | ||
@@ -396,3 +396,3 @@ ... | ||
> const pokemonsEventStoreEvents = pokemonsEventStore.eventStoreEvents; | ||
> // => [pokemonAppearedEventType, pokemonCatchedEventType...] | ||
> // => [pokemonAppearedEventType, pokemonCaughtEventType...] | ||
> ``` | ||
@@ -607,3 +607,3 @@ > | ||
> type PokemonEventTypes = EventStoreEventsTypes<typeof pokemonsEventStore>; | ||
> // => [typeof pokemonAppearedEventType, typeof pokemonCatchedEventType...] | ||
> // => [typeof pokemonAppearedEventType, typeof pokemonCaughtEventType...] | ||
> ``` | ||
@@ -618,3 +618,3 @@ > | ||
> // => EventTypeDetail<typeof pokemonAppearedEventType> | ||
> // | EventTypeDetail<typeof pokemonCatchedEventType> | ||
> // | EventTypeDetail<typeof pokemonCaughtEventType> | ||
> // | ... | ||
@@ -704,3 +704,3 @@ > ``` | ||
version: 1, | ||
type: 'POKEMON_CATCHED', | ||
type: 'POKEMON_CAUGHT', | ||
payload: { name, level }, | ||
@@ -794,3 +794,3 @@ }); | ||
Some commands can have an effect on several event stores, or on several aggregates of the same event store. For instance, the `CATCH_POKEMON` command could write both a `CATCHED_BY_TRAINER` event on a pokemon aggregate (changing its `status` to `'catched'`) and a `POKEMON_CATCHED` event on a trainer aggregate (appending the `pokemonId` to its `pokedex`). | ||
Some commands can have an effect on several event stores, or on several aggregates of the same event store. For instance, the `CATCH_POKEMON` command could write both a `CAUGHT_BY_TRAINER` event on a pokemon aggregate (changing its `status` to `'caught'`) and a `POKEMON_CAUGHT` event on a trainer aggregate (appending the `pokemonId` to its `pokedex`). | ||
@@ -809,3 +809,3 @@  | ||
aggregateId: 'pikachu1', | ||
type: 'CATCHED_BY_TRAINER', | ||
type: 'CAUGHT_BY_TRAINER', | ||
payload: { trainerId: 'ashKetchum' }, | ||
@@ -816,3 +816,3 @@ ... | ||
aggregateId: 'ashKetchum', | ||
type: 'POKEMON_CATCHED', | ||
type: 'POKEMON_CAUGHT', | ||
payload: { pokemonId: 'pikachu1' }, | ||
@@ -1200,3 +1200,3 @@ ... | ||
Compared to data streams, connected event stores have the advantage of simplicity, performances and costs. However, they **strongly decouple your storage and messaging solutions**: Make sure to anticipate any issue that might arise (consistency, non-catched errors etc.). | ||
Compared to data streams, connected event stores have the advantage of simplicity, performances and costs. However, they **strongly decouple your storage and messaging solutions**: Make sure to anticipate any issue that might arise (consistency, non-caught errors etc.). | ||
@@ -1203,0 +1203,0 @@ > <details> |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
544541