@eskit/core

Core functionality for definition of aggregate roots & associated functionality

Usage

• Defining an aggregate

import { createAggregateRoot, IAggregateRoot } from '@eskit/core';

interface ICounter {
  value: number;
}

const Counter = createAggregateRoot<ICounter>({
  commands: {
    incrementBy(entity, command) {
      const { by } = command.data;
      entity.publish('incremented', { by });
    }
  },
  initialState: {
    value: 0
  },
  name: 'counter',
  reducer: {
    incremented: (state, event) => ({
      ...state,
      value: state.value + event.data.by
    })
  }
});