Open a connection to MongoDB

createMongoDbConnection.js

import { MongoClient } from "mongodb";

const openDbConnection = url => {
  const p = new Promise((resolve, reject) => {
    MongoClient.connect(
      url,
      { useUnifiedTopology: true, useNewUrlParser: true },
      async (error, client) => {
        if (error) {
          reject(error);
          return;
        }

        const dbName = process.env.DB_NAME || "test";
        const db = client.db(dbName);

        resolve({ client, db });
      }
    );
  });
  p.catch(err => console.log("ERROR: openDbConnection", err));
  return p;
};

const createDbConnection = async () => {
  const host = process.env.NODE_ENV === "development" ? "localhost" : "mongo";

  const url = `mongodb://${host}:27017`;

  try {
    return await openDbConnection(url);
  } catch (err) {
    throw `ERROR: createDbConnection - ${err}`;
  }
};

export default createDbConnection;