147 lines
3.4 KiB
JavaScript
147 lines
3.4 KiB
JavaScript
'use strict';
|
|
|
|
var cluster = require('cluster');
|
|
var PromiseA = require('bluebird');
|
|
var memstore;
|
|
var sqlstore;
|
|
// TODO
|
|
// var rootMasterKey;
|
|
|
|
function init(conf/*, state*/) {
|
|
if (!conf.ipcKey) {
|
|
conf.ipcKey = require('crypto').randomBytes(16).toString('base64');
|
|
}
|
|
if (!conf.sqlite3Sock) {
|
|
conf.sqlite3Sock = '/tmp/sqlite3.' + require('crypto').randomBytes(4).toString('hex') + '.sock';
|
|
}
|
|
if (!conf.memstoreSock) {
|
|
conf.memstoreSock = '/tmp/memstore.' + require('crypto').randomBytes(4).toString('hex') + '.sock';
|
|
}
|
|
|
|
try {
|
|
require('fs').unlinkSync(conf.memstoreSock);
|
|
} catch(e) {
|
|
if ('ENOENT' !== e.code) {
|
|
console.error(e.stack);
|
|
console.error(JSON.stringify(e));
|
|
}
|
|
// ignore
|
|
}
|
|
try {
|
|
require('fs').unlinkSync(conf.sqlite3Sock);
|
|
} catch(e) {
|
|
if ('ENOENT' !== e.code) {
|
|
console.error(e.stack);
|
|
console.error(JSON.stringify(e));
|
|
}
|
|
// ignore
|
|
}
|
|
|
|
var cstore = require('cluster-store');
|
|
var sqlite3 = require('sqlite3-cluster/server');
|
|
var promise = PromiseA.all([
|
|
cstore.create({
|
|
sock: conf.memstoreSock
|
|
, serve: cluster.isMaster && conf.memstoreSock
|
|
, store: cluster.isMaster && null //new require('express-session/session/memory')()
|
|
// TODO implement
|
|
, key: conf.ipcKey
|
|
}).then(function (_memstore) {
|
|
memstore = _memstore;
|
|
return memstore;
|
|
})
|
|
, sqlite3.createServer({
|
|
verbose: null
|
|
, sock: conf.sqlite3Sock
|
|
, ipcKey: conf.ipcKey
|
|
}).then(function (_sqlstore) {
|
|
sqlstore = _sqlstore;
|
|
return sqlstore;
|
|
})
|
|
]).then(function (/*args*/) {
|
|
return conf;
|
|
/*
|
|
{
|
|
conf: conf
|
|
, memstore: memstore // args[0]
|
|
, sqlstore: sqlstore // args[1]
|
|
};
|
|
*/
|
|
});
|
|
|
|
return promise;
|
|
}
|
|
|
|
function touch(conf, state) {
|
|
if (!state.initialize) {
|
|
state.initialize = init(conf, state);
|
|
}
|
|
|
|
// TODO if no xyz worker, start on xyz worker (unlock, for example)
|
|
return state.initialize.then(function () {
|
|
// TODO conf.locked = true|false;
|
|
conf.initialized = true;
|
|
return conf;
|
|
});
|
|
|
|
/*
|
|
setInterval(function () {
|
|
console.log('SIGUSR1 to caddy');
|
|
return caddy.update(caddyConf);
|
|
}, 10 * 60 * 1000);
|
|
*/
|
|
}
|
|
|
|
//var config = require('./device.json');
|
|
|
|
// require('ssl-root-cas').inject();
|
|
// TODO try SNI loopback.example.com as result of api.ipify.com with loopback token
|
|
|
|
/*
|
|
function phoneHome() {
|
|
var holepunch = require('./holepunch/beacon');
|
|
var ports;
|
|
|
|
ports = [
|
|
{ private: 65022
|
|
, public: 65022
|
|
, protocol: 'tcp'
|
|
, ttl: 0
|
|
, test: { service: 'ssh' }
|
|
, testable: false
|
|
}
|
|
, { private: 650443
|
|
, public: 650443
|
|
, protocol: 'tcp'
|
|
, ttl: 0
|
|
, test: { service: 'https' }
|
|
}
|
|
, { private: 65080
|
|
, public: 65080
|
|
, protocol: 'tcp'
|
|
, ttl: 0
|
|
, test: { service: 'http' }
|
|
}
|
|
];
|
|
|
|
// TODO return a middleware
|
|
holepunch.run(require('./redirects.json').reduce(function (all, redirect) {
|
|
if (!all[redirect.from.hostname]) {
|
|
all[redirect.from.hostname] = true;
|
|
all.push(redirect.from.hostname);
|
|
}
|
|
if (!all[redirect.to.hostname]) {
|
|
all[redirect.to.hostname] = true;
|
|
all.push(redirect.to.hostname);
|
|
}
|
|
|
|
return all;
|
|
}, []), ports).catch(function () {
|
|
console.error("Couldn't phone home. Oh well");
|
|
});
|
|
}
|
|
*/
|
|
|
|
module.exports.init = init;
|
|
module.exports.touch = touch;
|