Make updates to allow passing Ids with aggregate create commands

index.js

@@ -4,6 +4,7 @@ exports.Event = require('./lib/event');
 exports.Identity = require('./lib/identity');
 exports.BasicHandler = require('./lib/basicCommandHandler');
 exports.CommandHandler = require('./lib/commandHandler');
+exports.CreateAggregateCommandHandler = require('./lib/createAggregateCommandHandler');
 exports.AggregateCommandHandler = require('./lib/aggregateCommandHandler');
 exports.Repository = require('./lib/repository');
 exports.ValidationError = require('./lib/validationError');

src/createAggregateCommandHandler.js

@@ -0,0 +1,5 @@
+import AggregateCommandHandler from './aggregateCommandHandler';
+
+export default class CreateAggregateCommandHandler extends AggregateCommandHandler {
+  isCreateHandler = true;
+}

src/repository.js

@@ -11,13 +11,12 @@ export default class Repository {
   get = async(aggregateId) => {
     let events = await (await this.getStore()).getEvents(aggregateId);
     if (!events.length) {
-      console.log(`Aggregate ${aggregateId} not found`);
       return null;
     }
     return new this.Ctor(aggregateId, events);
   }
 
-  create = () => new this.Ctor(uuidV4());
+  create = id => new this.Ctor(id || uuidV4());
 
   record = async events => {
     let store = await this.getStore();