var connect = require("connect");
var io = require("socket.io");
var sws = require("../sws.js")();

var server = connect.createServer(

  connect.cookieDecoder(),
  connect.session(),

  sws.http,

  connect.staticProvider(__dirname+"/static")
);

server.listen(8000);

var socket = io.listen(server);

socket.on('connection', sws.ws(function(client) {

  client.on("secure", function() {
    console.log("SECURE");
    console.log(client.session.req.sessionID);
  });

  client.on("insecure", function() {
    console.log("INSECURE ACCESS");
  });

  client.on("message", function(msg) {
    client.send(msg);
    console.log("MSG:"+msg);
  });
}));

var util = require('util');

module.exports = function verifier(options)
{

  var defaults = {
    ttl: 30*1000 // 30 秒
  };

  for (var k in options) {
    defaults[k] = options[k];
  }

  var session_jar = {};

  return {

    http:function give_token(req, res, next) {

      if (req.headers["x-access-request-token"]) {
        if (req.headers["x-access-request-token"].toLowerCase()==="simple") {
          var token = Math.random();

          while (session_jar[token]) {
            token = Math.random();
          }

          var tmp = Date.now();
          session_jar[token] = {
            session: req.session,
            date: tmp,
            id: req.sessionID
          };

          res.writeHead(200);
          res.end('{"x-access-token": "'+token+';'+tmp+'"}');
          return;
        }
      }

      if (next) {
        next();
      }
    }

    , ws: function attach_client(cb) {

      return function route_client(client) {

        function verify(token) {
          var tmp = session_jar[token];

          if (tmp && tmp.date > Date.now() - defaults.ttl) {
            var session = tmp;
            delete session_jar[token];
            return session;
          }
          return false;
        }

        client.once('message', function first_verify(msg) {

          var session = verify(msg) || false;
          if (session) {
            client._session = session;
            client.session = session.session;
            client.emit("secure");

            client.on = oldon;
            for (var i = 0, l = onmsgs.length; i < l; i++) {
              client.on('message', onmsgs[i]);
            }
          }

          else {
            client.emit("insecure");
          }
        });

        var onmsgs = [];
        var oldon = client.on;
        client.on = function(name, fn) {
          if (name === "message") onmsgs[onmsgs.length] = fn;
          else oldon.apply(this, arguments);
        };
        

        cb(client);
      };
    }
  };
};

SessionWebSocket(function(socket){
 socket.on('message',function(msg){
  console.log("SWS:",msg);
  });

  setInterval(function() {
    socket.send('Succeed!');
  }, 1000);
});

var socket = new io.Socket()
socket.connect();
socket.send("OH NOES");

function SessionWebSocket(cb) {
  var xhr = new XMLHttpRequest()
  xhr.open("GET","/?no-cache="+(new Date()+0));

  xhr.setRequestHeader("x-access-request-token","simple");

  xhr.onreadystatechange = function xhrverify() {

    if (xhr.readyState === 4) {
      var tmp;
      try {

        if (tmp = JSON.parse(xhr.responseText)["x-access-token"]) {
          var socket = new io.Socket();
          cb(socket);
          socket.connect();

          socket.send(tmp.split(";")[0]);
        }
      }
      catch(e) {
        throw new Error("XMLHttpResponse had non-json response, possible cache issue?")
      }
    }
  };

  xhr.send();
}