1
0
mirror of https://github.com/exane/not-gwent-online synced 2025-09-19 06:39:10 +00:00

more lobby stuff

This commit is contained in:
exane
2015-07-01 19:51:09 +02:00
parent cdbb5443af
commit 05af359b85
6 changed files with 27 additions and 101 deletions

View File

@@ -19,13 +19,16 @@ var Connections = (function(){
r._connections = null;
r.roomCollection = null;
r._length = 0;
r.add = function(user) {
this._connections[user.getID()] = user;
this._length++;
}
r.remove = function(user) {
delete this._connections[user.getID()];
this._length--;
}
r.get = function() {
@@ -36,6 +39,10 @@ var Connections = (function(){
return !!this._connections[user.getID()];
}
r.length = function() {
return this._length;
}
return Connections;
})();

View File

@@ -1,91 +0,0 @@
/*var app = require('http').createServer();
global.io = require("socket.io")(app);*/
/*var User = require("./User");
var Connections = require("./Connections");
var Room = require("./Room");*/
var Socket = (function(){
var Socket = function(){
if(!(this instanceof Socket)){
return (new Socket());
}
/**
* constructor here
*/
this.connections = Connections();
this.roomCollection = {};
app.listen(this.port);
this.io = io;
this._events();
};
var r = Socket.prototype;
/**
* methods && properties here
* r.property = null;
* r.getProperty = function() {...}
*/
r.io = null;
r.port = 16918;
r.connections = null;
r.roomCollection = null;
/*
r.matchmaker = null;
*/
r._events = function(){
var self = this;
this.io.on("connection", function(socket){
var user = User(socket);
self.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("request:createRoom", function(){
var room = Room();
self.roomCollection[room.getID()] = room;
room.join(user);
console.log("room %s created by %s", room.getID(), user.getName());
user.send("response:createRoom", room.getID());
})
socket.on("request:joinRoom", function(){
console.log("joinroom");
var interval = setInterval(function(){
for(var key in self.roomCollection) {
var room = self.roomCollection[key];
if(!room.isOpen()) continue;
room.join(user);
clearInterval(interval);
console.log("user %s joined room %s", user.getName(), room.getID());
user.send("response:joinRoom", room.getID());
}
}, 1000);
})
socket.on("request:roomData", function(){
var room = user.getRoom();
var players = room.getPlayers();
user.send("response:roomData", {players: players});
})
socket.on("disconnect", function(){
self.connections.remove(user);
user.disconnect();
})
socket.on("request:gameLoaded", function(data){
self.roomCollection[data._roomID].setReady(user);
})
});
}
return Socket;
})();
module.exports = Socket;

View File

@@ -64,7 +64,7 @@ var User = (function(){
}
r.setDeck = function(deck) {
console.log("set deck: ", deck);
//console.log("set deck: ", deck);
this._deck = deck;
}
@@ -96,7 +96,7 @@ var User = (function(){
this._rooms.forEach(function(room) {
room.leave(self);
if(!room.hasUser()) {
console.log("Remove room: ", room.getID());
//console.log("Remove room: ", room.getID());
room = null;
}
})
@@ -121,12 +121,12 @@ var User = (function(){
});
socket.on("request:gameLoaded", function(data){
console.log(data);
//console.log(data);
connections.roomCollection[data._roomID].setReady(self);
})
socket.on("set:deck", function(data) {
console.log(data);
//console.log(data);
if(data && data.deck){
self.setDeck(data.deck);
}

View File

@@ -39,6 +39,9 @@ io.on("connection", function(socket) { //global connection
user.disconnect();
console.log("user ", user.getName(), " disconnected");
user = null;
//io.emit("update:playerOnline", connections.length());
})
io.emit("update:playerOnline", connections.length());
})