Screeps Websocket POC

var http = require('http');
var sockjs = require('sockjs-client');
var request = require('request');
var pg = require('pg');
var sock = new sockjs('https://screeps.com/socket');
var user_id = "56b20f601436e6ad4fcc0e68";
var user_name =
var password =

var conString = "postgres://postgres:xxxxx@localhost/screeps";
var client = new pg.Client(conString);
client.connect(function(err) {
    if(err) {
        return console.error('could not connect to postgres', err);
    }
});
function sleep(time, callback) {
    var stop = new Date().getTime();
    while(new Date().getTime() < stop + time) {
        ;
    }
    callback();
}
sock.onopen = function() {
    console.log('open');
    var x;
    request.post({url:"https://screeps.com/api/auth/signin", json:true, body: {email: user_name, password:password }}, function(err,httpResponse,body){
      sock.send('auth '+body.token);
    });
};
sock.onmessage = function(e) {
    console.log(e.data);
    if (e.data.substring(0,7) === "auth ok") {

      sock.send("subscribe user:"+user_id+"/memory/stats");
    }
    try {
        var v = JSON.parse(e.data);
        client.query({
            name:'insert-tick',
            text:'insert into cpu (tick,cpu) values($1,$2)',
            values: v[1].split(",")
        });
    } catch (e){}
};
sock.onclose = function() {
    console.log('close');
};

var server = http.createServer();
server.listen(9999, '127.0.0.1');