refactor(ts): change mongo db module to use TS and ESM

Author: jescalada

src/db/mongo/helper.js

@@ -0,0 +1,45 @@
+import { MongoClient, Db, Collection, Filter, Document, FindOptions } from 'mongodb';
+import config from '../../config';
+import MongoDBStore from 'connect-mongo';
+
+const dbConfig = config.getDatabase();
+const connectionString = dbConfig.connectionString;
+const options = dbConfig.options;
+
+let _db: Db | null = null;
+
+export const connect = async (collectionName: string): Promise<Collection> => {
+  if (!_db) {
+    const client = new MongoClient(connectionString, options);
+    await client.connect();
+    _db = client.db();
+  }
+
+  return _db.collection(collectionName);
+};
+
+export const findDocuments = async <T>(
+  collectionName: string,
+  filter: Filter<Document> = {},
+  options: FindOptions<Document> = {}
+): Promise<T[]> => {
+  const collection = await connect(collectionName);
+  return collection.find(filter, options).toArray() as Promise<T[]>;
+};
+
+export const findOneDocument = async <T>(
+  collectionName: string,
+  filter: Filter<Document> = {},
+  options: FindOptions<Document> = {}
+): Promise<T | null> => {
+  const collection = await connect(collectionName);
+  return (await collection.findOne(filter, options)) as T | null;
+};
+
+export const getSessionStore = () => {
+  return new MongoDBStore({
+    mongoUrl: connectionString,
+    collectionName: 'user_session',
+    mongoOptions: options,
+  });
+};

src/db/mongo/helper.ts

@@ -0,0 +1,40 @@
+import * as helper from './helper';
+import * as pushes from './pushes';
+import * as repo  from './repo';
+import * as users from './users';
+
+export const {
+  getSessionStore,
+} = helper;
+
+export const {
+  getPushes,
+  writeAudit,
+  getPush,
+  authorise,
+  cancel,
+  reject,
+  canUserCancelPush,
+  canUserApproveRejectPush,
+} = pushes;
+
+export const {
+  getRepos,
+  getRepo,
+  createRepo,
+  addUserCanPush,
+  addUserCanAuthorise,
+  removeUserCanPush,
+  removeUserCanAuthorise,
+  deleteRepo,
+  isUserPushAllowed,
+  canUserApproveRejectPushRepo,
+} = repo;
+
+export const {
+  findUser,
+  getUsers,
+  createUser,
+  deleteUser,
+  updateUser,
+} = users;