X-Git-Url: https://git.kengrimes.com/?p=henge%2Fkiak.git;a=blobdiff_plain;f=main.js;h=c7d5bd757e0b0cc35745a843b97ba53148fffd31;hp=b24e9f39f6c16c208bd17d6d21f32ae44c27f82c;hb=8a4003e360fdd0f28553d8140a5ba567891a25f5;hpb=37b12d7d745749e7fb0091afb6c4f9747e1bb51b diff --git a/main.js b/main.js index b24e9f3..c7d5bd7 100644 --- a/main.js +++ b/main.js @@ -1,81 +1,93 @@ +/** + * @file Node entry and main driver + * @author Jordan Lavatai, Ken Grimes + * @version 0.0.1 + * @license AGPL-3.0 + * @copyright jk software 2017 + * @summary HTTP(S) Router that uses the first directory in the requested URL + * as the route name + */ const fs = require('fs') const ws = require('ws') +const http = require('http') const https = require('https') const getport = require('get-port') const mime = require('mime') +const opts = require('./opts.js') -const argv = require('minimist')(process.argv.slice(2), { - string: [ 'ca-cert', 'ca-key', 'config', 'client-js', 'host-js', 'electron', 'port' ], - boolean: [ 'remote-host' ], - alias: { c: 'config', - j: 'client-js', - J: 'host-js', - C: 'ca-cert', - K: 'ca-key', - e: 'electron', - r: 'remote-host', - p: 'port' - }, - default: { config: undefined, - 'client-js': 'client.js', - 'host-js': 'host.js', - 'ca-cert': 'stunnel.cert', - 'ca-key': 'stunnel.key', - 'remote-host': true, - 'port': 2443 - }, - stopEarly: true, - unknown: (opt) => { - console.log(process.argv.join(" ") + '\nUnknown operator: ' + opt + ` -Usage: strapp [OPTION]... -Route https connections from a hardware port to a remote host, and initiate -peer-to-peer connection with clients. - -CONFIG - -c, --config=path Configuration file to use (/etc/strapp.conf) - - overridden by command line opts - -j, --client-js=path Path to the client Strapp code (./strapp-client.js) - -J, --host-js=path Path to the host Strapp code (./strapp-host.js) - -C, --ca-cert=path Accessible location of the CA Cert (./stunnel.cert) - -K, --ca-key=path Accessible location of the CA Key (./stunnel.key) - -p, --port=number The local port to bind HTTPS listener to (2443) - -ROUTING - -e, --electron=route Route to the local electron user (nil) - - enables optional electron dependency - -d, --dedicated=route Route all incoming connections to this route (nil) - - used in conjunction with '-e=my_route' - -(c)2017 jk software -`) - process.exit() +/* const routeConnection = (request,response) => { + const htArgv = request.url.slice(1).split("?") + let routeName = /[^\/]*/.match(htArgv[0])[0] + if (routeName === '') + routeName = opts['index'] + if (routeName.indexOf('.') != -1) { + if (routeName in fileBuf) { + response.writeHead(200, { 'Content-Type': fileBuf[routeName].mime }) + response.write(fileBuf[routeName].data) + } + else { + if ('404.html' in fileBuf) { + response.writeHead(404, fileBuf['404.html'].mime) + response.write(fileBuf['404.html'].data) + } + else + response.writeHead(404) + } + response.end() } -}) - -//TODO: if (argv['config'] !== undefined), read and apply to argv without overwrite -if (argv['www-path'] == undefined) - argv['www-path'] = 'www' -else if (String(argv['www-path']).endsWith('/')) - argv['www-path'] = argv['www-path'].slice(0,-1) + else if (routeName in routes) { + const route = routes[routeName] + response.writeHead(200, { 'Content-Type': 'text/html' }) + response.write(skelPage[0] + clientJS + skelPage[1]) + response.end() + route.socket.send(request.headers['x-forwarded-for'] || request.connection.remoteAddress) + } + else { + routes[htArgv[0]] = true + const newRoute = {} + newRoute.host = request.headers['x-forwarded-for'] || request.connection.remoteAddress + getport().then( (port) => { + newRoute.port = port + newRoute.httpd = https.createServer(routerOpts, (request, response) => { + }).listen(newRoute.port) + + newRoute.ws = new ws.Server( { server: newRoute.httpd } ) + newRoute.ws.on('connection', (ws) => { console.log("socket connected"); newRoute.socket = ws; ws.send("CONNECTED") } ) + newRoute.ws.on('message', (msg) => { console.log("Received message" + msg) }) + console.log("Listening for websocket " + newRoute.host + " on port " + newRoute.port) + routes[htArgv[0]] = newRoute + }).then(() => { + response.writeHead(200, { 'Content-Type': 'text/html' }) + response.write(skelPage[0] + 'const _strapp_port = \'' + newRoute.port + '\'\n' + hostJS + skelPage[1]) + response.end() + }) + } +} -const routerOpts = { - key: fs.readFileSync(argv['ca-key']), - cert: fs.readFileSync(argv['ca-cert']) +if (!opts['no-tls']) { + router.httpd = http.createServer(router.listener) } -const skelPage = String(fs.readFileSync('skel.html')).split("") -const clientJS = fs.readFileSync(argv['client-js']) -const hostJS = fs.readFileSync(argv['host-js']) -const routes = {} -const fileBuf = {} -let fbSize = 0 -fs.readdirSync(argv['www-path']).forEach((file) => { - if (fbSize++ < 50) { - fileBuf[file] = { mime: mime.lookup(argv['www-path'] + '/' + file), - data: fs.readFileSync(argv['www-path'] + '/' + file) - } +else { + /* Setup TLS */ + if (!fs.existsSync(opts['ca-key'])) { + console.log(`ERR: Key ${opts['ca-key']} inaccessible (required for tls)`) + process.exit() + } + if (!fs.existsSync(opts['ca-cert'])) { + console.log(`ERR: Cert ${opts['ca-cert']} inaccessible (required for tls)`) + process.exit() + } + router.opts = { + key: fs.readFileSync(opts['ca-key']), + cert: fs.readFileSync(opts['ca-cert']) } -}) +} +const skelPage = String(fs.readFileSync('skel.html')).split("") +const clientJS = fs.readFileSync(opts['client-js']) +const hostJS = fs.readFileSync(opts['host-js']) +const routes = {} +/* const router = https.createServer(routerOpts, (request, response) => { const htArgv = request.url.slice(1).split("?") let routeName = htArgv[0].split('/')[0] @@ -119,11 +131,11 @@ const router = https.createServer(routerOpts, (request, response) => { routes[htArgv[0]] = newRoute }).then(() => { response.writeHead(200, { 'Content-Type': 'text/html' }) - response.write(skelPage[0] + 'const _strapp_host = \'www.strapp.io\'\n\tconst _strapp_port = \'' + newRoute.port + '\'\n' + hostJS + skelPage[1]) + response.write(skelPage[0] + 'const _strapp_port = \'' + newRoute.port + '\'\n' + hostJS + skelPage[1]) response.end() }) } }).listen(argv['port']) - +*/ //TODO: if ("electron" in process.versions) open a local renderwindow, and route to it