122 lines
2.6 KiB
JavaScript
122 lines
2.6 KiB
JavaScript
(() => {
|
|
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('checkout', execSync(`git checkout --force --theirs ${branch}`));
|
|
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.service);
|
|
|
|
|
|
|
|
|
|
|
|
})(); |