Remove eventStorageWrite from default container as it's implementation-specific

Author: snatalenko

examples/user-domain/index.js

@@ -9,6 +9,7 @@ const {
 	InMemoryMessageBus,
 	EventDispatcher
 } = require('../..'); // node-cqrs
+const { InMemorySnapshotStorage } = require('../../dist/in-memory/InMemorySnapshotStorage');
 const UserAggregate = require('./UserAggregate');
 const UsersProjection = require('./UsersProjection');
 
@@ -20,6 +21,7 @@ exports.createContainer = () => {
 
 	// register infrastructure services
 	builder.register(InMemoryEventStorage).as('eventStorageReader').as('eventStorageWriter');
+	builder.register(InMemorySnapshotStorage).as('snapshotStorage');
 	builder.register(InMemoryMessageBus).as('eventBus');
 
 	// register domain entities

src/CqrsContainerBuilder.ts

@@ -4,7 +4,7 @@ import { CommandBus } from './CommandBus';
 import { EventStore } from './EventStore';
 import { SagaEventHandler } from './SagaEventHandler';
 import { EventDispatcher } from './EventDispatcher';
-import { InMemoryEventStorage, InMemoryMessageBus, InMemorySnapshotStorage } from './in-memory';
+import { InMemoryMessageBus } from './in-memory';
 import { EventValidationProcessor } from './EventValidationProcessor';
 import { isClass } from './utils';
 import {
@@ -29,16 +29,10 @@ export class CqrsContainerBuilder extends ContainerBuilder {
 		super.register(CommandBus).as('commandBus');
 		super.register(EventDispatcher).as('eventDispatcher');
 
-		super.register(InMemoryEventStorage).as('eventStorageWriter');
-		super.register(InMemorySnapshotStorage).as('snapshotStorage');
-
-		// Register default event dispatch pipeline:
-		// validate events, write to event storage, write to snapshot storage.
-		// If any of the processors is not defined, it will be skipped.
-		super.register((container: IContainer) => [
-			new EventValidationProcessor(),
-			container.eventStorageWriter,
-			container.snapshotStorage
+		// Register default event dispatch pipeline with event validation only;
+		// No storage processors added by default
+		super.register(() => [
+			new EventValidationProcessor()
 		]).as('eventDispatchPipeline');
 	}
 

src/interfaces/IContainer.ts

@@ -4,7 +4,7 @@ import { IEventDispatcher } from './IEventDispatcher';
 import { IEventStore } from './IEventStore';
 import { IEventBus } from './IEventBus';
 import { IDispatchPipelineProcessor } from './IDispatchPipelineProcessor';
-import { IEventStorageReader, IEventStorageWriter } from './IEventStorage';
+import { IEventStorageReader } from './IEventStorage';
 import { IAggregateSnapshotStorage } from './IAggregateSnapshotStorage';
 import { IIdentifierProvider } from './IIdentifierProvider';
 import { IExtendableLogger, ILogger } from './ILogger';
@@ -13,7 +13,6 @@ export interface IContainer extends Container {
 	eventBus: IEventBus;
 	eventStore: IEventStore
 	eventStorageReader: IEventStorageReader;
-	eventStorageWriter?: IEventStorageWriter;
 	identifierProvider?: IIdentifierProvider;
 	snapshotStorage?: IAggregateSnapshotStorage;
 

tests/unit/dispatch-pipeline.test.ts

@@ -1,3 +1,4 @@
+import { InMemorySnapshotStorage } from '../../dist/in-memory/InMemorySnapshotStorage';
 import {
 	ContainerBuilder,
 	EventValidationProcessor,
@@ -22,6 +23,7 @@ describe('eventDispatchPipeline', () => {
 
 		builder.register(InMemoryMessageBus).as('externalEventBus');
 		builder.register(InMemoryEventStorage).as('eventStorageWriter');
+		builder.register(InMemorySnapshotStorage).as('snapshotStorage');
 		builder.register((c: IContainer) => [
 			new EventValidationProcessor(),
 			c.externalEventBus,