projects / henge / kiak.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
v0.0.1
[henge/kiak.git] / main.js
diff --git a/main.js b/main.js
index 2db2240..c7d5bd7 100644 (file)
--- a/main.js
+++ b/main.js
@@ -1,50 +1,141 @@
+/**
+ * @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 https = require('https')
 const http = require('http')
+const https = require('https')
 const getport = require('get-port')
-const argv = require('minimist')(process.argv.slice(2))
-
-const https_router_opts = {
-  key: fs.readFileSync('stunnel.key'),
-  cert: fs.readFileSync('stunnel.cert')
-}
+const mime = require('mime')
+const opts = require('./opts.js')
 
-let https_routes = {}
-const https_router = https.createServer(https_router_opts, (request, response) => {
-  let ht_argv = request.url.slice(1).split("?")
-  console.log(ht_argv)
-  if (ht_argv[0] in https_routes) {
-    response.writeHead(200, { 'Content-Type': 'text/plain' })
-    response.write('You are a remote client\r\n')
-    let route = https_routes[ht_argv[0]]
-    response.write('You should connect to ' + route.host + "\r\nOn port: " + route.port + "\r\n")
+/* 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()
   }
-  else if (ht_argv[0].indexOf(".") == -1) {
-    https_routes[ht_argv[0]] = 'true'
+  else if (routeName in routes) {
+    const route = routes[routeName]
     response.writeHead(200, { 'Content-Type': 'text/html' })
-    let new_route = {}
-    new_route.host = request.headers['x-forwarded-for'] || request.connection.remoteAddress
+    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) => {
-      new_route.port = port
-      new_route.httpd = https.createServer(https_router_opts, (request, response) => {
-      }).listen(port)
-      new_route.ws = new ws.Server( { server: new_route.httpd } )
-      new_route.ws.on('connection', (ws) => { console.log("socket connected"); ws.send("CONNECTED") } )
-      new_route.ws.on('message', (msg) => { console.log("Received message" + msg) })
-      console.log("Listening for websocket socket " + new_route.port + " on " + new_route.host)
-      console.log(new_route)
-      https_routes[ht_argv[0]] = new_route
+      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(() => {
-      let str = String(fs.readFileSync('remote-server.html'))
-      response.write(str.replace("$HOST","www.strapp.io").replace("$PORT",new_route.port))
+      response.writeHead(200, { 'Content-Type': 'text/html' })
+      response.write(skelPage[0] + 'const _strapp_port = \'' + newRoute.port + '\'\n' + hostJS + skelPage[1])
       response.end()
     })
   }
-}).listen(2443)
-
+}
 
+if (!opts['no-tls']) {
+  router.httpd = http.createServer(router.listener)
+}
+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'])
+  }
+}
 
-if ("electron" in process.versions);
+const skelPage = String(fs.readFileSync('skel.html')).split("<!--STRAPP_SRC-->")
+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]
+  if (routeName === '')
+    routeName = 'index.html'
+  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()
+  }
+  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()
+    })
+  }
+}).listen(argv['port'])
+*/
+//TODO: if ("electron" in process.versions) open a local renderwindow, and route to it
 
kiak isn't a kernel, it's a json-based filesystem that runs in browser memory and provides filesystem abstractions for general i/o, webrtc, webcrypto and webgl. it also provides a node.js server bridge over a websocket, providing restricted server-side filesystem access. the node.js server acts as a router, using URLs to route messages to the bridged 'remote admin', who then may receive HTTP and TCP connections in the browser. any application written for the kiak browser environment may also run on the node.js server. developed for the HENGE engine, but also an independent project providing a multi-user application framework (e.g. for multiplayer web games, screen sharing, or pair programming). the web-client is also a kiak routing server, so it can act as a host for its own clients, who may recursively act as servers for their own clients over WebRTC, and so on.