/** * @module EventBus */ import { type IEventBus, type IEventBusResolver, type BaseEventMap, type IEventBusAdapter } from "../../../../event-bus/contracts/_module.js"; import { type EventBusSettingsBase } from "../../../../event-bus/implementations/derivables/event-bus/_module.js"; import { type IReadableContext } from "../../../../execution-context/contracts/_module.js"; /** * IMPORT_PATH: `"@daiso-tech/core/event-bus"` * @group Derivables */ export type EventBusAdapters = Partial>; /** * Configuration for `EventBusResolver`. * Registers named event-bus adapters and optionally designates a default. * * IMPORT_PATH: `"@daiso-tech/core/event-bus"` * @group Derivables */ export type EventBusResolverSettings = EventBusSettingsBase & { /** * Named registry of event-bus adapters. Each key is an adapter alias and the corresponding value is the adapter instance. */ adapters: EventBusAdapters; /** * The alias of the adapter to use when none is explicitly specified. Must be a key in the `adapters` map. */ defaultAdapter?: NoInfer; }; /** * The `EventBusResolver` class is immutable. * * IMPORT_PATH: `"@daiso-tech/core/event-bus"` * @group Derivables */ export declare class EventBusResolver implements IEventBusResolver { private readonly settings; /** * @example * ```ts * import { type IEventBusAdapter, BaseEvent } from "@daiso-tech/core/event-bus/contracts"; * import { EventBusResolver } from "@daiso-tech/core/event-bus"; * import { MemoryEventBusAdapter } from "@daiso-tech/core/event-bus/memory-event-bus-adapter"; * import { RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/redis-pub-sub-event-bus-adapter"; * import { Serde } from "@daiso-tech/core/serde"; * import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/super-json-serde-adapter" * import Redis from "ioredis"; * * type Store = Partial>; * * const serde = new Serde(new SuperJsonSerdeAdapter()); * const store: Store = {}; * const eventBusResolver = new EventBusResolver({ * adapters: { * memory: new MemoryEventBusAdapter(), * redis: new RedisPubSubEventBusAdapter({ * serde, * dispatcherClient: new Redis("YOUR_REDIS_CONNECTION_STRING"), * listenerClient: new Redis("YOUR_REDIS_CONNECTION_STRING"), * }), * }, * defaultAdapter: "memory" * }); * ``` */ constructor(settings: EventBusResolverSettings); setEventMapType(): EventBusResolver; setExecutionContext(context: IReadableContext): EventBusResolver; /** * @example * ```ts * import { type IEventBusAdapter, BaseEvent } from "@daiso-tech/core/event-bus/contracts"; * import { EventBusResolver } from "@daiso-tech/core/event-bus"; * import { MemoryEventBusAdapter } from "@daiso-tech/core/event-bus/memory-event-bus-adapter"; * import { RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/redis-pub-sub-event-bus-adapter"; * import { Serde } from "@daiso-tech/core/serde"; * import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/super-json-serde-adapter" * import Redis from "ioredis"; * * const serde = new Serde(new SuperJsonSerdeAdapter()); * const eventBusResolver = new EventBusResolver({ * adapters: { * memory: new MemoryEventBusAdapter(), * redis: new RedisPubSubEventBusAdapter({ * serde, * dispatcherClient: new Redis("YOUR_REDIS_CONNECTION_STRING"), * listenerClient: new Redis("YOUR_REDIS_CONNECTION_STRING"), * }), * }, * defaultAdapter: "memory" * }); * * type AddEvent = { * a: number; * b: number; * }; * type EventMap = { * add: AddEvent; * }; * * // Will dispatch AddEvent using the default adapter which is MemoryEventBusAdapter * await eventBusResolver * .setEventMapType() * .use() * .dispatch("add", { a: 1, b: 2 }); * * // Will dispatch AddEvent using the redis adapter * await eventBusResolver * .setEventMapType() * .use("redis") * .dispatch("add", { a: 1, b: 2 }); * ``` */ use(adapterName?: TAdapters | undefined): IEventBus; }