Allow empty query for substances
'use strict';

const Promise = require('bluebird');

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

const MONGO_URL = process.env.MONGO_URL;
const MONGO_COLLECTION = process.env.MONGO_COLLECTION;

const mdb_delayed = MongoClient.connect(MONGO_URL);

class Plebiscite {
    constructor({db}) {
        this._db = db;
    }

    * _getCollection() {
        return (yield this._db).collection(MONGO_COLLECTION);
    }

    * find({substance, offset, limit}) {
        const collection = yield* this._getCollection();

        const query = {};

        if (!substance === true) {
            query['substanceInfo.substance'] = substance;
        }

        return yield collection.find(query)
        .sort({'meta.published': -1})
        .skip(offset)
        .limit(limit)
        .toArray();
    }
}

module.exports = new Plebiscite({db: mdb_delayed});

'use strict';

const Promise = require('bluebird');

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

const MONGO_URL = process.env.MONGO_URL;
const MONGO_COLLECTION = process.env.MONGO_COLLECTION;

const mdb_delayed = MongoClient.connect(MONGO_URL);

class Plebiscite {
    constructor({db}) {
        this._db = db;
    }

    * _getCollection() {
        return (yield this._db).collection(MONGO_COLLECTION);
    }

    * find({substance, offset, limit}) {
        const collection = yield* this._getCollection();

        return yield collection.find({
            'substanceInfo.substance': substance
        })
        .sort({'meta.published': -1})
        .skip(offset)
        .limit(limit)
        .toArray();
    }
}

module.exports = new Plebiscite({db: mdb_delayed});
