import { EntityEvent } from "ddd-es-node";

export class OrderCancelledEvent extends EntityEvent {
}

import { Entity } from "ddd-es-node";
import { OrderCancelledEvent } from "./events";

export class Order extends Entity {
  private cancelled : boolean;
  constructor(id) {
    super(id, (self, event) => {
      if(event instanceof OrderCancelledEvent) {
        this.cancelled = true;
      }
    });
  }
  public cancel() {
    if(this.cancelled) {
      throw new Error('Order already cancelled');
    } else {
      this.dispatch(new OrderCancelledEvent());
    }
  }
}

import { entityRepository } from "ddd-es-node";
import { Order } from "./orders";

export const cancelOrder = (id) : void => {
  return entityRepository
      .load(Order, id)
      .then((order : Order) => order.cancel());
};

import { eventBus, EntityEvent } from "ddd-es-node";
import { OrderCancelledEvent } from "./events";

eventBus.subscribe((event : EntityEvent) => {
  if (event instanceof OrderCancelledEvent) {
    // do something
  }
}, { replay: true });