Run assertion on a mongo collection

mongo_assertion.js

const MongoClient = require("mongodb").MongoClient;
const test = require("tape");

function connect (url) {
	return new Promise((resolve, reject) => {
		MongoClient.connect(url, function (err, db) {
			if (err) {
				reject(err);
			} else {
				resolve(db);
			}
		});
	});
}

function onCollection (url, collectionName, action) {
	connect(url).then(db => {
		const col = db.collection(collectionName);
		const cursor = col.find({});

		cursor.on("data", doc => {
			try {
				action(doc);
			} catch (_) {}
		});

		cursor.on("end", () => {
			db.close();
		});
	});
}

onCollection(SOME_URL, "someCollection", (doc) => {
	runObjectTest(doc);
});

function runObjectTest (obj) {
	test(`${obj.id} - someAttribute should exist`, function (t) {
		t.plan(1);

		t.notEqual(obj.someAttribute, undefined);
	});
}