Migrate to TypeScript

.github/workflows/audit.yml

@@ -0,0 +1,17 @@
+name: Audit
+
+on: ["push", "pull_request"]
+
+jobs:
+  audit:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [20.x]
+    steps:
+    - uses: actions/checkout@v3
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v3
+      with:
+        node-version: ${{ matrix.node-version }}
+    - run: npm audit --parseable --production --audit-level=moderate

.github/workflows/coveralls.yml

@@ -0,0 +1,22 @@
+name: Coveralls
+
+on: ["push", "pull_request"]
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [20.x]
+    steps:
+    - uses: actions/checkout@v3
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v3
+      with:
+        node-version: ${{ matrix.node-version }}
+    - run: npm ci --no-optional
+      env:
+        CI: true
+    - run: npm run test:coverage
+    - name: Coveralls
+      uses: coverallsapp/github-action@v2

.github/workflows/tests.yml

@@ -0,0 +1,21 @@
+name: Tests
+
+on: ["push", "pull_request"]
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [18.x, 20.x, 22.x]
+    steps:
+    - uses: actions/checkout@v3
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v3
+      with:
+        node-version: ${{ matrix.node-version }}
+    - run: npm ci --no-optional
+      env:
+        CI: true
+    - run: npm run test
+    - run: npm run test:integration

.gitignore

@@ -9,6 +9,8 @@ app/tests/coverage/
 .bower-*/
 coverage/
 .nyc_output/
+dist/
+*.tgz
 
 # IDE's
 # =====

.npmignore

@@ -9,5 +9,8 @@ tests/
 .eslintrc.json
 .eslintignore
 .gitignore
-.travis.yml
 book.json
+tsconfig.json
+jsconfig.json
+jest.config.ts
+*.tgz

README.md

@@ -2,7 +2,8 @@ node-cqrs
 =========
 
 [![NPM Version](https://img.shields.io/npm/v/node-cqrs.svg)](https://www.npmjs.com/package/node-cqrs)
-[![Build Status](https://secure.travis-ci.org/snatalenko/node-cqrs.svg?branch=master)](http://travis-ci.org/snatalenko/node-cqrs)
+[![Audit Status](https://github.com/snatalenko/node-cqrs/actions/workflows/audit.yml/badge.svg)](https://github.com/snatalenko/node-cqrs/actions/workflows/audit.yml)
+[![Tests Status](https://github.com/snatalenko/node-cqrs/actions/workflows/tests.yml/badge.svg)](https://github.com/snatalenko/node-cqrs/actions/workflows/tests.yml)
 [![Coverage Status](https://coveralls.io/repos/github/snatalenko/node-cqrs/badge.svg?branch=master)](https://coveralls.io/github/snatalenko/node-cqrs?branch=master)
 [![NPM Downloads](https://img.shields.io/npm/dm/node-cqrs.svg)](https://www.npmjs.com/package/node-cqrs)
 

examples/user-domain-tests/index.js → examples/user-domain-tests/index.test.js

@@ -1,14 +1,18 @@
 'use strict';
 
 const { expect } = require('chai');
-const { createContainer, createBaseInstances } = require('../../examples/user-domain');
+const { createContainer, createBaseInstances } = require('../user-domain');
+const { nextCycle } = require('../../src/infrastructure/utils');
 
 describe('user-domain example', () => {
 
 	const testEventFlow = async container => {
 
 		const { commandBus, eventStore } = container;
 
+		// HACK: let projection restoring to start before emitting new events
+		await nextCycle();
+
 		// we send a command to an aggregate that does not exist yet (userAggregateId = undefined),
 		// a new instance will be created automatically
 		let userAggregateId;
@@ -51,7 +55,10 @@ describe('user-domain example', () => {
 
 		const { commandBus, eventStore, users } = container;
 
-		commandBus.send('createUser', undefined, {
+		// HACK: let projection restoring to start before emitting new events
+		await nextCycle();
+
+		await commandBus.send('createUser', undefined, {
 			payload: {
 				username: 'sherlock',
 				password: 'test'

examples/user-domain/UserAggregate.js

@@ -1,7 +1,7 @@
 // @ts-check
 'use strict';
 
-const { AbstractAggregate } = require('../../src'); // node-cqrs
+const { AbstractAggregate } = require('../..'); // node-cqrs
 
 const crypto = require('crypto');
 
@@ -68,12 +68,10 @@ class UserAggregate extends AbstractAggregate {
 	}
 
 	/**
-	 * Aggregate state
-	 *
-	 * @readonly
+	 * Creates an instance of UserAggregate
 	 */
-	get state() {
-		return this._state || (this._state = new UserAggregateState());
+	constructor({ id, events }) {
+		super({ id, events, state: new UserAggregateState() });
 	}
 
 	/**

examples/user-domain/UsersProjection.js

@@ -1,7 +1,7 @@
 // @ts-check
 'use strict';
 
-const { AbstractProjection } = require('../../src'); // node-cqrs
+const { AbstractProjection } = require('../..'); // node-cqrs
 
 /**
  * Users projection listens to events and updates associated view (read model)
@@ -29,7 +29,7 @@ class UsersProjection extends AbstractProjection {
 	 * userCreated event handler
 	 *
 	 * @param {object} event
-	 * @param {Identifier} event.aggregateId
+	 * @param {import('../../src').Identifier} event.aggregateId
 	 * @param {object} event.payload
 	 * @param {string} event.payload.username
 	 * @param {string} event.payload.passwordHash

examples/user-domain/index.js

@@ -5,8 +5,9 @@ const {
 	InMemoryEventStorage,
 	CommandBus,
 	EventStore,
-	AggregateCommandHandler
-} = require('../../src'); // node-cqrs
+	AggregateCommandHandler,
+	InMemoryMessageBus
+} = require('../..'); // node-cqrs
 const UserAggregate = require('./UserAggregate');
 const UsersProjection = require('./UsersProjection');
 
@@ -32,9 +33,10 @@ exports.createContainer = () => {
  */
 exports.createBaseInstances = () => {
 	// create infrastructure services
+	const messageBus = new InMemoryMessageBus();
 	const storage = new InMemoryEventStorage();
-	const eventStore = new EventStore({ storage });
-	const commandBus = new CommandBus();
+	const eventStore = new EventStore({ storage, messageBus });
+	const commandBus = new CommandBus({ messageBus });
 
 	/** @type {IAggregateConstructor} */
 	const aggregateType = UserAggregate;