Class EventBusFactory<TAdapters>

The EventBusFactory class is immutable.

IMPORT_PATH: "@daiso-tech/core/event-bus"

Type Parameters

  • TAdapters extends string = string

Implements

Constructors

constructor

Methods

setKeyPrefixer setLazyPromiseFactory use

Constructors

constructor

  • new EventBusFactory<TAdapters extends string = string>(
        settings: EventBusFactorySettings<TAdapters>,
    ): EventBusFactory<TAdapters>

  • Type Parameters

    • TAdapters extends string = string

    Parameters

    Returns EventBusFactory<TAdapters>

    Example

    import { type IEventBusAdapter, BaseEvent } from "@daiso-tech/core/event-bus/contracts";
    import { EventBusFactory } from "@daiso-tech/core/event-bus";
    import { MemoryEventBusAdapter, RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/adapters";
    import { KeyPrefixer, type FactoryFn } from "@daiso-tech/core/utilities";
    import { Serde } from "@daiso-tech/core/serde";
    import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/adapters"
    import Redis from "ioredis";

    type Store = Partial<Record<string, IEventBusAdapter>>;

    function cahceAdapterFactory(store: Store): FactoryFn<string, IEventBusAdapter> {
      return (prefix) => {
        let adapter = store[prefix];
        if (adapter === undefined) {
          adapter = new MemoryEventBusAdapter();
          store[prefix] = adapter;
        }
        return adapter;
      }
    }

    const serde = new Serde(new SuperJsonSerdeAdapter());
    const store: Store = {};
    const eventBusFactory = new EventBusFactory({
      keyPrefixer: new KeyPrefixer("event-bus"),
      adapters: {
        memory: new MemoryEventBusAdapter(),
        memoryFactory: cahceAdapterFactory(store),
        redis: new RedisPubSubEventBusAdapter({
          serde,
          dispatcherClient: new Redis("YOUR_REDIS_CONNECTION_STRING"),
          listenerClient: new Redis("YOUR_REDIS_CONNECTION_STRING"),
        }),
      },
      defaultAdapter: "memory"
    });

Methods

setKeyPrefixer

setLazyPromiseFactory

use

  • use<
        TEvents extends
            BaseEvent<Record<string, unknown>> = BaseEvent<Record<string, unknown>>,
    >(
        adapterName?: undefined | TAdapters,
    ): IEventBus<TEvents>

  • Type Parameters

    Parameters

    Returns IEventBus<TEvents>

    Example

    import { type IEventBusAdapter, BaseEvent } from "@daiso-tech/core/event-bus/contracts";
    import { EventBusFactory } from "@daiso-tech/core/event-bus";
    import { MemoryEventBusAdapter, RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/adapters";
    import { KeyPrefixer, type FactoryFn } from "@daiso-tech/core/utilities";
    import { Serde } from "@daiso-tech/core/serde";
    import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/adapters"
    import Redis from "ioredis";

    type Store = Partial<Record<string, IEventBusAdapter>>;

    function cahceAdapterFactory(store: Store): FactoryFn<string, IEventBusAdapter> {
      return (prefix) => {
        let adapter = store[prefix];
        if (adapter === undefined) {
          adapter = new MemoryEventBusAdapter();
          store[prefix] = adapter;
        }
        return adapter;
      }
    }

    const dispatcherClient = new Redis("YOUR_REDIS_CONNECTION_STRING");
    const listenerClient = new Redis("YOUR_REDIS_CONNECTION_STRING");
    const serde = new Serde(new SuperJsonSerdeAdapter());
    const store: Store = {};
    const eventBusFactory = new EventBusFactory({
      keyPrefixer: new KeyPrefixer("event-bus"),
      adapters: {
        memory: new MemoryEventBusAdapter(),
        memoryFactory: cahceAdapterFactory(store),
        redis: new RedisPubSubEventBusAdapter({
          serde,
          dispatcherClient: new Redis("YOUR_REDIS_CONNECTION_STRING"),
          listenerClient: new Redis("YOUR_REDIS_CONNECTION_STRING"),
        }),
      },
      defaultAdapter: "memory"
    });

    class AddEvent extends BaseEvent<{ a: number, b: number }> {}

    // Will dispatch AddEvent using the default adapter which is MemoryEventBusAdapter
    await eventBusFactory
      .use()
      .dispatch(new AddEvent({ a: 1, b: 2 }));

    // Will dispatch AddEvent using the redis adapter which is RedisPubSubEventBusAdapter
    await eventBusFactory
      .use("redis")
      .dispatch(new AddEvent({ a: 1, b: 2 }));

Settings

Member Visibility

On This Page

Constructors
Methods