sockjs.js

var settings = require('./lib/settings')("settings.json"),
  net = require('net'),
  http = require('http'),
  sockjs = require('sockjs')
let echo = sockjs.createServer();

var server = http.createServer();
echo.installHandlers(server, { prefix: '/sockjs' });
server.listen(settings.socket_io.listen_port, '0.0.0.0');

console.log("sockjs listening on " + settings.socket_io.listen_port)

echo.on('connection', function(client) {
  console.log(client.headers['x-forwarded-for'] + " " + client.id + " connecting to API")
  var apiSocket = net.createConnection(settings.api.listen_port, "localhost")
  var apiBuffer = "";

  apiSocket.on('connect', function() {
    console.log('api connected')
  })

  apiSocket.on('data', function(data) {
    var dstr = data.toString('utf8')
    dstr.split('\n').forEach(function(ds, idx) {
      if (idx == 0) { ds = apiBuffer + ds }
      if (idx == ds.length - 1) {
        apiBuffer = ds
      } else {
        if (ds.length > 0) {
          console.log("-> " + ds)
          client.write(ds)
        }
      }
    })
  })

  apiSocket.on('error', function(err) {
    console.log("apiSocket err: " + err)
  })

  apiSocket.on('close', function() {
    console.log("apiSocket closed")
  })

  client.on('data', function(str) {
    console.log(client.headers['x-forwarded-for'] + " <- " + str)
    var written = apiSocket.write(str + "\n")
    if (!written) {
      console.log('sockjs write error')
    }
  });

  client.on('close', function(client) {
    apiSocket.end()
    console.log('disconnnect!')
  })
});