valnet/relay/service.js

(() => {
const log = require('signale').scope('service');
const { execSync, spawn } = require('child_process');
const branch = execSync('git rev-parse --abbrev-ref HEAD').toString().trim();
let proc;
const Datastore = require('nedb');
const logs = new Datastore({
	filename: 'svc.log',
	autoload: true
});
const { config } = require('../package.json');
const express = require('express');
const app = express();

logp('==================================');
logp('Starting Valnet Node as a Service!');
logp('Syncing to branch: ' + branch);
logp('==================================');

setInterval(function update() {
	const remoteHash = execSync('git ls-remote https://github.com/marcus13345/valnet.git').toString()
		.split('\n')
		.filter(test => {
			return test.trim().endsWith(branch);
		})[0]
		.split('\t')[0]
		.trim();
	const localHash = execSync(`git rev-parse ${branch}`).toString().trim();
	if(remoteHash !== localHash) {
		logp(`remote hash: ${remoteHash}`);
		logp(`local hash: ${localHash}`);

		logp('killing relay...');
		try {
			proc.kill();
		} catch (e) {
			logp('failed to kill active relay...', 'error');
			logp(e, 'error');
		}
	}
}, 5000);

(function keepAlive() {
	proc = spawn('node', ['relay'], {
		stdio: 'pipe'
	});

	proc.stdout.on('data', (data) => {
		process.stdout.write(data);
		appendLogs('relay', data.toString(), 'stdout');
	});
	
	proc.stderr.on('data', (data) => {
		process.stderr.write(data);
		appendLogs('relay', data.toString(), 'stderr');
	});

	proc.on('exit', () => {
		logp('relay exitted');
		logp('attempting to fetch new version');

		appendLogs('fetch', execSync(`git fetch`));
		appendLogs('pull', execSync(`git pull`));
		appendLogs('yarn', execSync(`yarn`));

		logp('restarting...')
		setTimeout(() => {
			keepAlive();
		}, 1000);
	})
})();

function logp(message, type = 'info') {
	log[type](message);
	appendLogs('service', message)
}

function appendLogs(source, data, type = 'output') {
	logs.insert({
		message: data.toString(),
		type: type,
		src: source,
		timestamp: new Date().getTime()
	})
}

app.get('/', (req, res) => {
	logs.find({
		timestamp: { $gt: Date.now() - 1000000 }
	}, {}, (err, docs) => {

		if(err) {
			res.end(err.toString());
			return;
		}

		docs.sort(function(a, b) {
			return a.timestamp > b.timestamp;
		});

		res.end(`
			<table style="width: 100%">
			${docs.map(logItem => `
				<tr>
					<td><pre>${logItem.timestamp}</pre></td>
					<td><pre>${logItem.source}</pre></td>
					<td><pre>${logItem.type}</pre></td>
					<td><pre>${logItem.message}</pre></td>
				</tr>
			`).join('')}
			</table>
		`);
	})
});

app.listen(config.ports.http);





})();