✨ add mongodb connection

Author: dre1597

.env.example

@@ -4,3 +4,9 @@ DB_USER=user
 DB_PASSWORD=password
 DB_DATABASE=subway
 DB_DATABASE_TEST=subway_test
+MONGO_URL=mongodb://localhost:27017/subway
+MONGO_URL_TEST=mongodb://localhost:27017/subway_test
+
+# InMemory | MYSQL | MONGO
+
+REPOSITORY_VENDOR=MYSQL

package.json

@@ -42,6 +42,7 @@
   "dependencies": {
     "dotenv": "^16.0.3",
     "fastify": "^4.17.0",
+    "mongodb": "^5.5.0",
     "mysql2": "^3.3.0",
     "yup": "^1.1.1"
   }

pnpm-lock.yaml

@@ -0,0 +1,47 @@
+import { Collection } from 'mongodb';
+
+import { MongoHelper } from './mongo-helper';
+
+describe('MongoHelper', () => {
+  afterAll(async () => {
+    await MongoHelper.disconnect();
+  });
+
+  it('should be able to create a connection', async () => {
+    await MongoHelper.connect();
+
+    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+    // @ts-ignore private property
+    expect(MongoHelper._client).toBeTruthy();
+  });
+
+  it('should be able to disconnect from the database', async () => {
+    await MongoHelper.disconnect();
+
+    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+    // @ts-ignore private property
+    expect(MongoHelper._client).toBeNull();
+  });
+
+  it('should be able to get a collection', async () => {
+    const collection = await MongoHelper.getCollection('subway_test');
+
+    expect(collection).toBeInstanceOf(Collection);
+
+    const result = await collection.find({}).toArray();
+
+    expect(result).toEqual([]);
+  });
+
+  it('should be able to reconnect to get a collection if there is not connection', async () => {
+    await MongoHelper.disconnect();
+
+    const collection = await MongoHelper.getCollection('subway_test');
+
+    expect(collection).toBeInstanceOf(Collection);
+
+    const result = await collection.find({}).toArray();
+
+    expect(result).toEqual([]);
+  });
+});

src/@core/@shared/infra/db/mongo/mongo-helper.spec.ts

@@ -0,0 +1,30 @@
+import { Collection, MongoClient } from 'mongodb';
+import { config } from 'dotenv';
+
+config();
+
+const connectionURI =
+  process.env.NODE_ENV === 'test'
+    ? process.env.MONGO_URI_TEST
+    : process.env.MONGO_URI;
+
+export class MongoHelper {
+  private static _client: MongoClient | null;
+
+  public static async connect(): Promise<void> {
+    this._client = await MongoClient.connect(connectionURI);
+  }
+
+  public static async getCollection(name: string): Promise<Collection> {
+    if (!this._client) {
+      await this.connect();
+    }
+
+    return this._client.db().collection(name);
+  }
+
+  public static async disconnect(): Promise<void> {
+    await this._client.close();
+    this._client = null;
+  }
+}