EventBus | Vendure Docs

.ofType()

import { OnApplicationBootstrap } from '@nestjs/common';import { EventBus, PluginCommonModule, VendurePlugin } from '@vendure/core';import { filter } from 'rxjs/operators';@VendurePlugin({    imports: [PluginCommonModule]})export class MyPlugin implements OnApplicationBootstrap {  constructor(private eventBus: EventBus) {}  async onApplicationBootstrap() {    this.eventBus      .ofType(OrderStateTransitionEvent)      .pipe(        filter(event => event.toState === 'PaymentSettled'),      )      .subscribe((event) => {        // do some action when this event fires      });  }}

Signature

class EventBus implements OnModuleDestroy {    constructor(transactionSubscriber: TransactionSubscriber)    publish(event: T) => Promise<void>;    ofType(type: Type<T>) => Observable<T>;    filter(predicate: (event: VendureEvent) => boolean) => Observable<T>;    registerBlockingEventHandler(handlerOptions: BlockingEventHandlerOptions<T>) => ;}

publish

method(event: T) => Promise<void>

Publish an event which any subscribers can react to.

Example

await eventBus.publish(new SomeEvent());

ofType

method(type: Type<T>) => Observable<T>

Returns an RxJS Observable stream of events of the given type. If the event contains a RequestContext object, the subscriber will only get called after any active database transactions are complete.

This means that the subscriber function can safely access all updated data related to the event.

filter

method(predicate: (event: VendureEvent) => boolean) => Observable<T>

Returns an RxJS Observable stream of events filtered by a custom predicate. If the event contains a RequestContext object, the subscriber will only get called after any active database transactions are complete.

This means that the subscriber function can safely access all updated data related to the event.

registerBlockingEventHandler

method(handlerOptions: BlockingEventHandlerOptions<T>) => v2.2.0

Register an event handler function which will be executed when an event of the given type is published, and will block execution of the code which published the event until the handler has completed.

This is useful when you need assurance that the event handler has successfully completed, and you want the triggering code to fail if the handler fails.

::: warning This API should be used with caution, as errors or performance issues in the handler can cause the associated operation to be slow or fail entirely. For this reason, any handler which takes longer than 100ms to execute will log a warning. Any non-trivial task to be performed in a blocking event handler should be offloaded to a background job using the JobQueueService.

Also, be aware that the handler will be executed in the same database transaction as the code which published the event (as long as you pass the ctx object from the event to any TransactionalConnection calls). :::

Example

eventBus.registerBlockingEventHandler({  event: OrderStateTransitionEvent,  id: 'my-order-state-transition-handler',  handler: async (event) => {    // perform some synchronous task  }});