grrrisu/Simulator

"use strict";

const retry = require('retry');
const unix_socket = require('./unix_socket');

const connect_to_unix_socket = function(socket_file, callback, err_callback){
  let operation = retry.operation();
  operation.attempt(function(currentAttempt){
    unix_socket.connect(socket_file, (err, socket) => {
      if(operation.retry(err)){
        err_callback(err);
        return;
      } else {
        callback(socket);
      }
    });

  });
};

exports.connect = function(server, socket_file){

  const io = require('socket.io')(server);

  let player_id = null;

  io.on("connection", function(client){
    console.log("browser connected");
    let serverConnection = null;

    client.connect_to_backend = () => {
      connect_to_unix_socket(socket_file, (socket) => {
        serverConnection = socket;
        serverConnection.browserConnection = client;
        client.emit("net-status", {message: "connected to sim server", key: "server_connected", error: null});
      }, (err) => {
        client.emit("net-status", {message: "sim server is not available", key: "server_away", error: err});
      });
    }

    client.on("join", function(id, token){
      console.log(id + " : " + token + " joined");
      player_id = id;
      client.connect_to_backend();
    });

    client.on("action", function(data){
      console.log("message received ", data);
      if(serverConnection) {
        data.player_id = player_id;
        serverConnection.write(JSON.stringify(data)+"\r\n");
      } else {
        console.log("action dropped as we don't have any server connection");
      }
    });

    client.on("disconnect", function(data){
      console.log("client disconnected");
      if(serverConnection) {
        serverConnection.end();
      }
    });
  });

};