diff --git a/services/notifications/app/js/mongodb.js b/services/notifications/app/js/mongodb.js index ba88a9df34..db45bbf7f3 100644 --- a/services/notifications/app/js/mongodb.js +++ b/services/notifications/app/js/mongodb.js @@ -3,16 +3,20 @@ const { MongoClient, ObjectId } = require('mongodb') const clientPromise = MongoClient.connect(Settings.mongo.url) +let setupDbPromise async function waitForDb() { - await clientPromise + if (!setupDbPromise) { + setupDbPromise = setupDb() + } + await setupDbPromise } const db = {} -waitForDb().then(async function () { +async function setupDb() { const internalDb = (await clientPromise).db() db.notifications = internalDb.collection('notifications') -}) +} module.exports = { db,