Added initial state of the unpeeled onion as the preparation for slimming it down.

Author: oskardudycz

samples/unwrapping_onion/src/unpeeled/ecommerce/app.ts

@@ -0,0 +1,11 @@
+import { getApplication } from '#core/api';
+import { MongoClient } from 'mongodb';
+import registerHandlers from './application/shoppingCarts';
+import controllers from './controllers';
+
+const initApp = (mongo: MongoClient) => {
+  registerHandlers(mongo);
+  return getApplication(...controllers);
+};
+
+export default initApp;

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commandHandlers/addProductToShoppingCartHandler.ts

@@ -0,0 +1,32 @@
+import { CommandHandler } from '#core/commands';
+import { EventBus } from '#core/events';
+import { ShoppingCartRepository } from 'src/unpeeled/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository';
+import { AddProductItemToShoppingCart } from '../commands/shoppingCarts/addProductItemToShoppingCart';
+import { ShoppingCartMapper } from '../mappers/shoppingCartMapper';
+
+export class AddProductItemToShoppingCartHandler
+  implements CommandHandler<AddProductItemToShoppingCart>
+{
+  constructor(
+    private repository: ShoppingCartRepository,
+    private mapper: ShoppingCartMapper,
+    private eventBus: EventBus
+  ) {}
+
+  async handle(command: AddProductItemToShoppingCart): Promise<void> {
+    const model = await this.repository.find(command.shoppingCartId);
+
+    if (model === null) {
+      throw Error(`Shopping cart with id ${command.shoppingCartId} not found!`);
+    }
+
+    const aggregate = this.mapper.toAggregate(model);
+    aggregate.addProductItem(command.productItem);
+
+    await this.repository.add(this.mapper.toModel(aggregate));
+
+    for (const event of aggregate.dequeueUncomittedEvents()) {
+      await this.eventBus.publish(event);
+    }
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commandHandlers/confirmShoppingCart.ts

@@ -0,0 +1,32 @@
+import { CommandHandler } from '#core/commands';
+import { EventBus } from '#core/events';
+import { ShoppingCartRepository } from 'src/unpeeled/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository';
+import { ConfirmShoppingCart } from '../commands/shoppingCarts/confirmShoppingCart';
+import { ShoppingCartMapper } from '../mappers/shoppingCartMapper';
+
+export class ConfirmShoppingCartHandler
+  implements CommandHandler<ConfirmShoppingCart>
+{
+  constructor(
+    private repository: ShoppingCartRepository,
+    private mapper: ShoppingCartMapper,
+    private eventBus: EventBus
+  ) {}
+
+  async handle(command: ConfirmShoppingCart): Promise<void> {
+    const model = await this.repository.find(command.shoppingCartId);
+
+    if (model === null) {
+      throw Error(`Shopping cart with id ${command.shoppingCartId} not found!`);
+    }
+
+    const aggregate = this.mapper.toAggregate(model);
+    aggregate.confirm();
+
+    await this.repository.add(this.mapper.toModel(aggregate));
+
+    for (const event of aggregate.dequeueUncomittedEvents()) {
+      await this.eventBus.publish(event);
+    }
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commandHandlers/openShoppingCartHandler.ts

@@ -0,0 +1,29 @@
+import { CommandHandler } from '#core/commands';
+import { OpenShoppingCart } from '../commands/shoppingCarts/openShoppingCart';
+import { ShoppingCart } from 'src/unpeeled/ecommerce/domain/shoppingCarts';
+import { ShoppingCartRepository } from 'src/unpeeled/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository';
+import { ShoppingCartMapper } from '../mappers/shoppingCartMapper';
+import { EventBus } from '#core/events';
+
+export class OpenShoppingCartHandler
+  implements CommandHandler<OpenShoppingCart>
+{
+  constructor(
+    private repository: ShoppingCartRepository,
+    private mapper: ShoppingCartMapper,
+    private eventBus: EventBus
+  ) {}
+
+  async handle(command: OpenShoppingCart): Promise<void> {
+    const aggregate = ShoppingCart.open(
+      command.shoppingCartId,
+      command.customerId
+    );
+
+    await this.repository.add(this.mapper.toModel(aggregate));
+
+    for (const event of aggregate.dequeueUncomittedEvents()) {
+      await this.eventBus.publish(event);
+    }
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commandHandlers/removeProductFromShoppingCartHandler.ts

@@ -0,0 +1,32 @@
+import { CommandHandler } from '#core/commands';
+import { EventBus } from '#core/events';
+import { ShoppingCartRepository } from 'src/unpeeled/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository';
+import { RemoveProductItemFromShoppingCart } from '../commands/shoppingCarts/removeProductItemFromShoppingCart';
+import { ShoppingCartMapper } from '../mappers/shoppingCartMapper';
+
+export class RemoveProductItemFromShoppingCartHandler
+  implements CommandHandler<RemoveProductItemFromShoppingCart>
+{
+  constructor(
+    private repository: ShoppingCartRepository,
+    private mapper: ShoppingCartMapper,
+    private eventBus: EventBus
+  ) {}
+
+  async handle(command: RemoveProductItemFromShoppingCart): Promise<void> {
+    const model = await this.repository.find(command.shoppingCartId);
+
+    if (model === null) {
+      throw Error(`Shopping cart with id ${command.shoppingCartId} not found!`);
+    }
+
+    const aggregate = this.mapper.toAggregate(model);
+    aggregate.removeProductItem(command.productItem);
+
+    await this.repository.add(this.mapper.toModel(aggregate));
+
+    for (const event of aggregate.dequeueUncomittedEvents()) {
+      await this.eventBus.publish(event);
+    }
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/addProductItemToShoppingCart.ts

@@ -0,0 +1,11 @@
+import { Command } from '#core/commands';
+import { ProductItem } from 'src/unpeeled/ecommerce/common/shoppingCarts/productItem';
+
+export class AddProductItemToShoppingCart extends Command {
+  constructor(
+    public readonly shoppingCartId: string,
+    public readonly productItem: ProductItem
+  ) {
+    super();
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/confirmShoppingCart.ts

@@ -0,0 +1,7 @@
+import { Command } from '#core/commands';
+
+export class ConfirmShoppingCart extends Command {
+  constructor(public readonly shoppingCartId: string) {
+    super();
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/openShoppingCart.ts

@@ -0,0 +1,10 @@
+import { Command } from '#core/commands';
+
+export class OpenShoppingCart extends Command {
+  constructor(
+    public readonly shoppingCartId: string,
+    public readonly customerId: string
+  ) {
+    super();
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/removeProductItemFromShoppingCart.ts

@@ -0,0 +1,11 @@
+import { Command } from '#core/commands';
+import { ProductItem } from 'src/unpeeled/ecommerce/common/shoppingCarts/productItem';
+
+export class RemoveProductItemFromShoppingCart extends Command {
+  constructor(
+    public readonly shoppingCartId: string,
+    public readonly productItem: ProductItem
+  ) {
+    super();
+  }
+}

samples/unwrapping_onion/src/unpeeled/ecommerce/application/shoppingCarts/index.ts

@@ -0,0 +1,62 @@
+import { MongoClient } from 'mongodb';
+import { registerCommandHandler } from '#core/commands';
+import { registerQueryHandler } from '#core/queries';
+import { OpenShoppingCart } from 'src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/openShoppingCart';
+import { GetShoppingCartById } from 'src/unpeeled/ecommerce/application/shoppingCarts/queries/getShoppingCartById';
+import { AddProductItemToShoppingCart } from 'src/unpeeled/ecommerce/application/shoppingCarts/commands/shoppingCarts/addProductItemToShoppingCart';
+import { RemoveProductItemFromShoppingCart } from './commands/shoppingCarts/removeProductItemFromShoppingCart';
+import { ShoppingCartMapper } from './mappers/shoppingCartMapper';
+import { OpenShoppingCartHandler } from './commandHandlers/openShoppingCartHandler';
+import { AddProductItemToShoppingCartHandler } from './commandHandlers/addProductToShoppingCartHandler';
+import { RemoveProductItemFromShoppingCartHandler } from './commandHandlers/removeProductFromShoppingCartHandler';
+import { GetShoppingCartByIdHandler } from './queryHandlers/getShoppingCartByIdQueryHandler';
+import { MongoDBShoppingCartRepository } from 'src/unpeeled/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository';
+import { ConfirmShoppingCart } from './commands/shoppingCarts/confirmShoppingCart';
+import { ConfirmShoppingCartHandler } from './commandHandlers/confirmShoppingCart';
+import { GetCustomerShoppingHistory } from './queries/getCustomerShoppingHistory';
+import { GetCustomerShoppingHistoryHandler } from './queryHandlers/getCustomerShoppingHistoryHandler';
+import { CustomerShoppingHistoryMapper } from './mappers/customerShoppingHistoryMapper';
+import { EventBusFactory } from '#core/events';
+
+const registerHandlers = (mongo: MongoClient) => {
+  const repository = new MongoDBShoppingCartRepository(mongo);
+  const eventBus = EventBusFactory();
+
+  const shoppingCartMapper = new ShoppingCartMapper();
+  const shoppingHistoryMapper = new CustomerShoppingHistoryMapper();
+
+  registerCommandHandler(
+    OpenShoppingCart,
+    new OpenShoppingCartHandler(repository, shoppingCartMapper, eventBus)
+  );
+  registerCommandHandler(
+    AddProductItemToShoppingCart,
+    new AddProductItemToShoppingCartHandler(
+      repository,
+      shoppingCartMapper,
+      eventBus
+    )
+  );
+  registerCommandHandler(
+    RemoveProductItemFromShoppingCart,
+    new RemoveProductItemFromShoppingCartHandler(
+      repository,
+      shoppingCartMapper,
+      eventBus
+    )
+  );
+  registerCommandHandler(
+    ConfirmShoppingCart,
+    new ConfirmShoppingCartHandler(repository, shoppingCartMapper, eventBus)
+  );
+  registerQueryHandler(
+    GetShoppingCartById,
+    new GetShoppingCartByIdHandler(repository)
+  );
+  registerQueryHandler(
+    GetCustomerShoppingHistory,
+    new GetCustomerShoppingHistoryHandler(repository, shoppingHistoryMapper)
+  );
+};
+
+export default registerHandlers;