const ntpClient = require('lib/vendor/ntp-client');
const Mutex = require('async-mutex').Mutex;

let nextSyncTime = 0;
let timeOffset = 0;
const fetchingTimeMutex = new Mutex();

const server = {
	domain: 'pool.ntp.org',
	port: 123,
};

async function networkTime():Promise<Date> {
	return new Promise(function(resolve:Function, reject:Function) {
		ntpClient.getNetworkTime(server.domain, server.port, function(error:any, date:Date) {
			if (error) {
				reject(error);
				return;
			}

			resolve(date);
		});
	});
}

function shouldSyncTime() {
	return !nextSyncTime || Date.now() > nextSyncTime;
}

export default async function():Promise<Date> {
	if (shouldSyncTime()) {
		const release = await fetchingTimeMutex.acquire();

		try {
			if (shouldSyncTime()) {
				const date = await networkTime();
				nextSyncTime = Date.now() + 60 * 1000;
				timeOffset = date.getTime() - Date.now();
			}
		} catch (error) {
			// Fallback to application time since
			// most of the time it's actually correct
			nextSyncTime = Date.now() + 20 * 1000;
			timeOffset = 0;
		} finally {
			release();
		}
	}

	return new Date(Date.now() + timeOffset);
}