mongodb

index.js

var MongoClient = require('mongodb').MongoClient;

function dbConnect(callback) {	
	MongoClient.connect(dbUrl, function(err, db) {
		if (err) return console.log(err);
		callback(db);
	});
}

function updateSubscriptions() {	
	dbConnect(function(db) {
	  var docs = db.collection('accounts').find( {} );
	  docs.forEach(updateUserSubscription, function() {db.close()});
	});
}

function cleanAccountsCollection() {
	dbConnect(function(db) {
		db.collection('accounts').remove({}, function(err) {
			if (err) console.log(err);
			db.close();
		});
	});
}