@navadt/common/dist/mongoConnector.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const dotenv_1 = require("dotenv");
const mongoose = require("mongoose");
const loggerFactory_1 = require("./logger/loggerFactory");
class MongoConnector {
    constructor(envfile) {
        /**
         * Load environment variables from .env file, where API keys and passwords are configured.
         */
        const envFile = envfile || process.env.ENVFILE || ".env";
        dotenv_1.config({ path: envFile });
        mongoose.Promise = global.Promise;
    }
    /**
     * Initiate connection to MongoDB
     * @returns {Promise<void>}
     */
    connect(mongoUri) {
        mongoUri = mongoUri || process.env.MONGODB_URI;
        return new Promise((resolve, reject) => {
            const options = {
                keepAlive: true,
                useNewUrlParser: true
            };
            this.mongoConnection = mongoose.connection;
            mongoose.connect(mongoUri, options).then(() => {
                const indexOfA = mongoUri.indexOf("@");
                const db = indexOfA !== -1 ?
                    mongoUri.substring(0, 10) + "!_:_!" + mongoUri.substring(indexOfA) : mongoUri;
                loggerFactory_1.default.info("MongoDB connected [%s]", db);
                resolve();
            }).catch(reject);
        });
    }
    /**
     * Disconnects from MongoDB
     * @returns {Promise<void>}
     */
    disconnect() {
        return this.mongoConnection.close();
    }
}
exports.MongoConnector = MongoConnector;
//# sourceMappingURL=mongoConnector.js.map