backend/src/services/dbAccess.services.js

const log      = require('../utils/log.utils');          // Log Helper

const dbUser = process.env.OWL_DB_USER || "owl"
const dbPass = process.env.OWL_DB_PASS || "twittwoo"
const dbName = process.env.OWL_DB_NAME || "owlboard"
const dbPort = process.env.OWL_DB_PORT || 27017
const dbHost = process.env.OWL_DB_HOST || "localhost"
const uri = `mongodb://${dbUser}:${dbPass}@${dbHost}:${dbPort}`;

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

const client = new MongoClient(uri);
const db = client.db(dbName);

async function query(collection, query){
    await client.connect();
    log.out(`dbAccess.query: Connecting to collection: '${collection}'`)
    var qcoll = db.collection(collection);
    var qcursor = qcoll.find(query)
    qcursor.project({_id: 0})
    log.out(`dbAccess.query: Running Query: ${JSON.stringify(query)}`)
    increment(collection)
    return (await qcursor.toArray());
}

async function increment(target) {
    log.out(`dbAccess.increment: Incrementing counter for: ${target}`)
    await client.connect();
    let col = db.collection("meta");
    let update = {}
    update[target] = 1
    col.updateOne({target: "counters"}, {$inc:update})
    return;
}

module.exports = {
    query,
    increment
}