Implemented and connected MongoDB repository

Author: oskardudycz

samples/unwrapping_onion/src/core/repositories/index.ts

@@ -0,0 +1,36 @@
+import { Collection, Document, Filter, MongoClient, ObjectId } from 'mongodb';
+
+export interface Repository<T> {
+  add(entity: T): Promise<void>;
+  update(entity: T): Promise<void>;
+  find(id: string): Promise<T | null>;
+}
+
+export class MongoDbRepository<T extends Document & { _id: ObjectId }>
+  implements Repository<T>
+{
+  private collection: Collection<T>;
+
+  constructor(
+    mongo: MongoClient,
+    collectionName: string,
+    databaseName?: string | undefined
+  ) {
+    const db = mongo.db(databaseName);
+    this.collection = db.collection<T>(collectionName);
+  }
+  async add(entity: T): Promise<void> {
+    await this.collection.updateOne(entity, {}, { upsert: true });
+  }
+  async update(entity: T): Promise<void> {
+    await this.collection.updateOne(entity, {}, { upsert: false });
+  }
+
+  async find(id: string): Promise<T | null> {
+    const result = await this.collection.findOne(new ObjectId(id) as Filter<T>);
+
+    if (result === null) return null;
+
+    return result as T;
+  }
+}

samples/unwrapping_onion/src/ecommerce/app.ts

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

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

@@ -2,11 +2,12 @@ import { RegisterCommandHandler } from '#core/commands';
 import ShoppingCartRepository from '../../infrastructure/shoppingCarts/shoppingCartRepository';
 import OpenShoppingCart from '../../domain/commands/shoppingCarts/openShoppingCart';
 import OpenShoppingCartHandler from './openShoppingCartHandler';
+import { MongoClient } from 'mongodb';
 
-const registerHandlers = () => {
+const registerHandlers = (mongo: MongoClient) => {
   RegisterCommandHandler(
     OpenShoppingCart,
-    new OpenShoppingCartHandler(new ShoppingCartRepository())
+    new OpenShoppingCartHandler(new ShoppingCartRepository(mongo))
   );
 };
 

samples/unwrapping_onion/src/ecommerce/index.ts

@@ -1,10 +1,15 @@
 import { startAPI } from '#core/api';
-import { disconnectFromMongoDB } from '#core/mongodb';
-import app from './app';
+import { disconnectFromMongoDB, getMongoDB } from '#core/mongodb';
+import initApp from './app';
 
 //////////////////////////////////////////////////////////
 /// API
 //////////////////////////////////////////////////////////
 
 process.once('SIGTERM', disconnectFromMongoDB);
-startAPI(app, 5000);
+
+(async () => {
+  const mongo = await getMongoDB();
+  const app = initApp(mongo);
+  startAPI(app);
+})().catch(console.error);

samples/unwrapping_onion/src/ecommerce/infrastructure/shoppingCarts/shoppingCartRepository.ts

@@ -1 +1,9 @@
-export default class ShoppingCartRepository {}
+import { MongoDbRepository } from '#core/repositories';
+import { MongoClient } from 'mongodb';
+import { ShoppingCartModel } from '../../models/shoppingCart';
+
+export default class ShoppingCartRepository extends MongoDbRepository<ShoppingCartModel> {
+  constructor(mongo: MongoClient) {
+    super(mongo, 'shoppingCarts');
+  }
+}

samples/unwrapping_onion/src/ecommerce/models/shoppingCart.ts

@@ -0,0 +1,5 @@
+import { ObjectId } from 'mongodb';
+
+export class ShoppingCartModel {
+  constructor(public _id: ObjectId) {}
+}

samples/unwrapping_onion/src/tests/e2e/fullFlow.e2e.test.ts

@@ -3,20 +3,23 @@ import { v4 as uuid } from 'uuid';
 import { config } from '#config';
 // import { greaterOrEqual } from '#core/validation';
 import { TestResponse } from '#testing/api/testResponse';
-import app from '../../ecommerce/app';
+import initApp from '../../ecommerce/app';
 import {
   MongoDBContainer,
   StartedMongoDBContainer,
 } from '#testing/api/mongoDB/mongoDBContainer';
 import { disconnectFromMongoDB } from '#core/mongodb';
+import { Application } from 'express';
 
 describe('Full flow', () => {
+  let app: Application;
   let mongodbContainer: StartedMongoDBContainer;
 
   beforeAll(async () => {
     mongodbContainer = await new MongoDBContainer().start();
     config.mongoDB.connectionString = mongodbContainer.getConnectionString();
     console.log(config.mongoDB.connectionString);
+    app = initApp(mongodbContainer.getClient());
   });
 
   afterAll(async () => {