MongoConnection.js

MongoConnection.js

const {
    MongoClient
} = require("mongodb");

const uri =
    `mongodb://${encodeURIComponent(process.env.MONGO_USER)}:${encodeURIComponent(process.env.MONGO_PASSWORD)}@${process.env.MONGO_HOST}?retryWrites=true&writeConcern=majority`;

const client = new MongoClient(uri, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
    monitorCommands: true
});

function getMongoConnection(dbName, collectionName) {
    return client.db(dbName).collection(collectionName)
}

function killAllConnections() {
    client.close();
}

module.exports = {
    getMongoConnection,
    killAllConnections
};