import { Container } from "inversify";
import eventDispatching, { TYPES } from "event-dispatching";
import "es6-shim"; // -- Not required --

// create container from inversify module
const container = new Container();

// Import and bootstrap the "event-dispatching" module bootstraper
eventDispatching({ container });

// Call the event dispatcher service
const eventDispatcher = container.get<EventDispatcher>(TYPES.EventDispatcher);

import { injectable, inject } from "inversify";
import { EventSubscriber, On } from "event-dispatching";
import { AWESOME_TYPES as TYPES } from "my-awesome-module";

@EventSubscriber()
@injectable()
export class UserEventSubscriber {
  private _myAwesomeStatusProvider: AwesomeStatusProvider;

  constructor(
    @inject(TYPES.AwesomeStatusProvider)
    _awesomeStatusProvider: AwesomeStatusProvider
  ) {
    this._myAwesomeStatusProvider = _awesomeStatusProvider;
  }

  @On("onUserCreate")
  onUserCreate(user: User) {
    console.log("User " + user.name + " created!");
  }

  @On("onStatusUpdate")
  updateUserStatus(status: string) {
    console.log("New status: " + status);
  }

  @On("onAsyncStatusUpdate")
  async onAsyncStatusUpdate(): Promise<{ status: any }> {
    const status: any = await this._myAwesomeStatusProvider.loadMyAwesomeStatus();

    return {
      status,
    };
  }
}

import { EventDispatcher, TYPES } from "event-dispatching";
import { UserEventSubscriber } from "./subscriber/UserEventSubscriber";

// note that all your subscribers must be imported somewhere in the app, so they are getting registered
// on node you can also require the whole directory using [require all](https://www.npmjs.com/package/require-all) package

container
  .bind<UserEventSubscriber>(Symbole.for("UserEventSubscriber"))
  .to(UserEventSubscriber);

// Call the event dispatcher service
const eventDispatcher: EventDispatcher = container.get<EventDispatcher>(
  TYPES.EventDispatcher
);

// Dispatch with Object
eventDispatcher.dispatch("onUserCreate", new User("Johny"));

// Dispatch with simple string
eventDispatcher.dispatch("onStatusUpdate", "hello world");

// Dispatch asynchronously
eventDispatcher
  .asyncDispatch("onAsyncStatusUpdate")
  .then((result: any[]) => {
    for (const key in result) {
      const data = result[key];

      if (data.status) {
        console.log("The actual loaded status is: " + data.status);
      }
    }
  })
  .catch((error) => {
    console.log("Something went wrong while loading the status");
  });