server.js

var express = require('express');
var app = express();
var server = require('http').Server(app);
var bodyParser = require('body-parser');

app.use(bodyParser.json());

app.get('/', function(req, res) {
    res.sendfile(__dirname + '/index.html');
});

app.post('/requestSent', function(req, res) {
    var userId = req.param('userId');
    var requestId = req.param('requestId');
    var data = req.body;

    console.log("Request Sent API");
    console.log("Body: %j", data);
    console.log("User ID:" + userId);
    console.log("Request ID:" + requestId);
    console.log("Count Users: %j", service.users.length);

    var user = service.findUserWithShop(userId);
    if (user != null) {
        console.log("Found User: " + user.userId);

        user.sendRequestSentNotification(requestId, data);
    }

    res.json(data);
});

app.post('/cancel', function(req, res) {
    var userId = req.param('userId');
    var requestId = req.param('requestId');

    console.log("Cancel Sent API");
    console.log("User ID:" + userId);
    console.log("Request ID:" + requestId);
    console.log("Count Users: %j", service.users.length);

    var user = service.findUserWithShop(userId);
    if (user != null) {
        console.log("Found User: " + user.userId);

        user.sendCancelNotification(requestId);
    }

    res.json({requestId: requestId, userId: userId});
});

function User(socket, userId) {
    var self = this
    this.socket = socket
    this.userId = userId
    this.addHandlers();
}
User.prototype.addHandlers = function() {
    var self = this;
    this.socket.emit("hello", {
            message: "Hello world!"
        })
        // game.addPlayer(new Player(socket))
        // 
    this.socket.on("requestSent", function(data) {
        console.log(data)
    })

    this.socket.on("hello", function(data) {
        console.log(data)
    })
}

User.prototype.sendCancelNotification = function(requestId) {
    var self = this;
    this.socket.emit('cancel', requestId);
    console.log("sent cancel event");
}

User.prototype.sendRequestSentNotification = function(requestId, request) {
    var self = this;
    this.socket.emit('requestSent2', request);
    console.log("sent requestSend2");
}

function XeemService() {
    this.io = require('socket.io')(server);
    this.started = false
    this.users = []
    this.addHandlers()
}

XeemService.prototype.addUser = function(newUser){
  console.log("adding new user");
  console.log(this.users.length);
  for(var i = 0; i < this.users.length; i++){
    console.log(this.users[i].userId);
    if(this.users[i].userId == newUser.userId) {
      this.users[i] = newUser;
      return;
    }
  }

  this.users.push(newUser); 
}
XeemService.prototype.addHandlers = function() {
    var service = this
    console.log("adding handlers")
    this.io.on("connection", function(socket) {
        
        console.log("user connected")
        socket.on('sendUserId', function(data) {
            console.log("send user id event");
            console.log(data);
            
            var newUser = new User(socket, data);
            service.addUser(newUser);
        });
        console.log("Users: %j", service.users.length);
    })
}
XeemService.prototype.findUserWithShop = function(userId) {
        var service = this;
        for (var i = 0; i < this.users.length; i++) {
            console.log("user #" + i + "'s id: " + this.users[i].userId)
            if (this.users[i].userId == userId) return this.users[i];
        }
        return null;
    }
    // // Start the game server
var service = new XeemService()
server.listen(process.env.PORT || 3000)
console.log("server is listening on port 3000")