'use strict';

const { MongoClient, ObjectId, Int32 } = require('mongodb')
	, { migrateVersion } = require(__dirname+'/../package.json')
	, configs = require(__dirname+'/../configs/main.js');

module.exports = {

	connect: async () => {
		if (module.exports.client) {
			throw new Error('Mongo already connected');
		}
		module.exports.client = await MongoClient.connect(configs.dbURL, {
			useNewUrlParser: true,
			useUnifiedTopology: true
		});
	},

	checkVersion: async() => {
		const currentVersion = await module.exports.client
			.db('jschan')
			.collection('version')
			.findOne({ '_id': 'version' })
			.then(res => res.version);
		if (currentVersion < migrateVersion) {
			console.error('Your migration version is out-of-date. Run `gulp migrate` to update.');
			process.exit(1);
		}
	},

	ObjectId,

	NumberInt: Int32,

}