import {createLogger} from "@gongt/ts-stl-library/debug/create-logger";
import {LOG_LEVEL} from "@gongt/ts-stl-library/debug/levels";

const sd = require('systemd-daemon');

const debug = createLogger(LOG_LEVEL.INFO, 'daemon-notify');
const error = createLogger(LOG_LEVEL.ERROR, 'daemon-notify');

export function NotifyInitStatus(str: string) {
	sd.notify('STATUS=' + str);
}

let statusIsComplete = false;
let statusIsFailed = false;

export function NotifyInitCompleteEvent() {
	if (statusIsFailed) {
		error('call notify complete after init failed');
		InitFailQuit();
	}
	if (statusIsComplete) {
		error('call notify complete multiple times');
	}
	statusIsComplete = true;
	try {
		console.log('NOTIFY_SOCKET=%s', process.env.NOTIFY_SOCKET);
		console.log('WATCHDOG_USEC=%s', process.env.WATCHDOG_USEC);
		console.log('WATCHDOG_PID=%s', process.env.WATCHDOG_PID);
		sd.watchdog.start();
		sd.notify('READY=1');
		sd.notify('MAINPID=' + process.pid);
		debug('>>>\x1B[38;5;10mnotify success\x1B[0m<<<');
	} catch (e) {
		error(e.stack);
		InitFailQuit();
	}
}

export function NotifyInitErrorEvent() {
	if (statusIsFailed) {
		error('call notify fail multiple times');
	}
	if (statusIsComplete) {
		InitFailQuit();
	}
	statusIsFailed = true;
	error('>>>\x1B[38;5;9mnotify fail\x1B[0m<<<');
}

export function InitFailQuit(e?: any) {
	error('InitFailQuit(%s);', e? e : 'void');
	if (e && e.stack) {
		debug('\r\x1B[2m%s\x1B[0m', e.stack);
	}
	process.exit(101);
}

process.on('uncaughtException', InitFailQuit);