mirror of
https://github.com/exane/not-gwent-online
synced 2024-10-31 10:36:53 +00:00
remove store + worker
This commit is contained in:
parent
a6dbba198f
commit
d96562855d
@ -1,4 +0,0 @@
|
|||||||
|
|
||||||
module.exports.run = function (store) {
|
|
||||||
console.log(' >> Store PID:', process.pid);
|
|
||||||
};
|
|
@ -1,96 +0,0 @@
|
|||||||
var fs = require('fs');
|
|
||||||
var express = require('express');
|
|
||||||
var serveStatic = require('serve-static');
|
|
||||||
var path = require('path');
|
|
||||||
|
|
||||||
var User = require("./User");
|
|
||||||
var Connections = require("./Connections");
|
|
||||||
var Battle = require("./Battle");
|
|
||||||
var Room = require("./Room");
|
|
||||||
|
|
||||||
module.exports.run = function(worker){
|
|
||||||
console.log(' >> Worker PID:', process.pid);
|
|
||||||
|
|
||||||
var app = require('express')();
|
|
||||||
|
|
||||||
var httpServer = worker.httpServer;
|
|
||||||
var scServer = worker.scServer;
|
|
||||||
|
|
||||||
app.use(serveStatic(path.resolve(__dirname, 'public')));
|
|
||||||
|
|
||||||
httpServer.on('request', app);
|
|
||||||
|
|
||||||
//var roomCollection = {};
|
|
||||||
global.connections = Connections(/*roomCollection*/);
|
|
||||||
|
|
||||||
scServer.on('connection', function(socket){
|
|
||||||
var user = User(socket);
|
|
||||||
connections.add(user);
|
|
||||||
console.log("new user ", user.getName());
|
|
||||||
|
|
||||||
socket.on("request:name", function(data){
|
|
||||||
if(data && data.name){
|
|
||||||
user.setName(data.name);
|
|
||||||
}
|
|
||||||
socket.emit("response:name", {name: user.getName()});
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on("set:deck", function(data) {
|
|
||||||
console.log(data);
|
|
||||||
if(data && data.deck){
|
|
||||||
user.setDeck(data.deck);
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on("request:gameLoaded", function(data){
|
|
||||||
console.log(data);
|
|
||||||
connections.roomCollection[data._roomID].setReady(user);
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on("request:createRoom", function(){
|
|
||||||
if(user.getRoom()) return;
|
|
||||||
if(user._searching) return;
|
|
||||||
var room = Room(worker.getSCServer());
|
|
||||||
connections.roomCollection[room.getID()] = room;
|
|
||||||
room.join(user);
|
|
||||||
user._searching = true;
|
|
||||||
console.log("room %s created by %s", room.getID(), user.getName());
|
|
||||||
user.send("response:createRoom", room.getID());
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on("request:joinRoom", function(){
|
|
||||||
if(user._searching) return;
|
|
||||||
user._searching = true;
|
|
||||||
console.log("joinroom");
|
|
||||||
var interval = setInterval(function(){
|
|
||||||
if(!user || user.disconnected) {
|
|
||||||
clearInterval(interval);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
for(var key in connections.roomCollection) {
|
|
||||||
var room = connections.roomCollection[key];
|
|
||||||
if(!room) continue;
|
|
||||||
if(!room.isOpen()) continue;
|
|
||||||
room.join(user);
|
|
||||||
clearInterval(interval);
|
|
||||||
user._searching = false;
|
|
||||||
console.log("user %s joined room %s", user.getName(), room.getID());
|
|
||||||
user.send("response:joinRoom", room.getID());
|
|
||||||
}
|
|
||||||
}, 500);
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on("request:roomData", function(){
|
|
||||||
var room = user.getRoom();
|
|
||||||
var players = room.getPlayers();
|
|
||||||
user.send("response:roomData", {players: players});
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on('disconnect', function(){
|
|
||||||
connections.remove(user);
|
|
||||||
user.disconnect();
|
|
||||||
console.log("user ", user.getName(), " disconnected");
|
|
||||||
user = null;
|
|
||||||
});
|
|
||||||
});
|
|
||||||
};
|
|
Loading…
Reference in New Issue
Block a user