jeena/chuck.js
1
0
Fork 0
mirror of https://github.com/logsol/chuck.js.git synced 2026-05-11 18:47:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

added checkpoint output, setting up a channel

Browse source
This commit is contained in:
logsol 2012-08-31 19:23:51 +02:00
parent dd154aa576
commit c2ed00cb9b
10 changed files with 115 additions and 79 deletions
Download patch file Download diff file Expand all files Collapse all files

65
app/Lobby/Coordinator.js
View file

@ -8,25 +8,29 @@ define([
function (User, Channel, PipeToChannel, NotificationCenter) {
function Coordinator () {
this.channels = {};
this.channelPipes = {};
this.lobbyUsers = {};
console.checkpoint('create Coordinator');
}
Coordinator.prototype.createUser = function (socketLink) {
var user = new User(socketLink, this);
console.checkpoint('creating user');
this.assignUserToLobby(user);
}
Coordinator.prototype.assignUserToLobby = function (user) {
if(user.channelProcess) {
if(user.channelPipe) {
//user.channel.releaseUser(user); -> generate message
}
this.lobbyUsers[user.id] = user;
console.checkpoint('assign user to lobby');
}
Coordinator.prototype.assignUserToChannel = function (user, channelName) {
if(user.channelProcess) {
if(user.channelPipe) {
//user.channel.releaseUser(user); -> generate message
}
@ -35,40 +39,55 @@ function (User, Channel, PipeToChannel, NotificationCenter) {
return false;
}
var channel = this.channels[channelName];
if(!channel) {
channel = new PipeToChannel(channelName);
this.channels[channelName] = channel;
NotificationCenter.on('channel/' + channelName + '/message', function (data) {
channel.send('channel', data);
}, this);
NotificationCenter.on('user/joined', function (user) {
NotificationCenter.on('channel/' + channelName + '/user/' + user.id, function (recipient, data) {
channel.send(recipient, data);
}, this);
}, this);
NotificationCenter.on('user/left', function (user) {
}, this);
var channelPipe = this.channelPipes[channelName];
if(!channelPipe) {
this.createPipe(channelName);
}
//channel.addUser(user);
//user.setChannel(channel);
NotificationCenter.trigger('user/joined', user);
delete this.lobbyUsers[user.id];
}
Coordinator.prototype.removeUser = function (user) {
user.channel.send('user/' + user.id + '/left');
NotificationCenter.off('channel/' + user.channel.channelName + '/user/' + user.id);
//user.channel.send('user/' + user.id + '/left');
//NotificationCenter.off('channel/' + user.channel.channelName + '/user/' + user.id);
delete this.lobbyUsers[user.id];
}
Coordinator.prototype.createPipe = function(channelName) {
var channelPipe = new PipeToChannel(channelName);
this.channelPipes[channelName] = channelPipe;
NotificationCenter.on('channel/' + channelName + '/message', function (data) {
channelPipe.send('channel', data);
}, this);
// sending info to user
NotificationCenter.on('user/joined', function (user) {
/*
NotificationCenter.on('channel/' + channelName + '/user/' + user.id, function (recipient, data) {
channelPipe.send(recipient, data);
}, this);
*/
channelPipe.send('channel', { addUser: user.id });
}, this);
NotificationCenter.on('user/left', function (user) {
}, this);
return channelPipe;
};
return Coordinator;
});

17
app/Lobby/PipeToChannel.js
View file

@ -1,24 +1,27 @@
define([
//"Game/Core/NotificationCenter",
"Game/Core/NotificationCenter",
"child_process"
],
function (childProcess) {
function (NotificationCenter, childProcess) {
var fork = childProcess.fork;
function PipeToChannel (channelName) {
this.channelProcess = null;
this.channelPipe = null;
try {
this.channelProcess = fork('channel.js');
this.channelPipe = fork('channel.js');
} catch (err) {
throw 'Failed to fork channel! (' + err + ')';
}
this.send('channel/' + channelName, 'CREATE');
this.channelProcess.on('message', this.onMessage.bind(this));
console.checkpoint('creating channel process for ' + channelName);
this.send('channel/' + channelName, { CREATE: channelName });
this.channelPipe.on('message', this.onMessage.bind(this));
var self = this;
}
@ -29,7 +32,7 @@ function (childProcess) {
data: data
}
this.channelProcess.send(message);
this.channelPipe.send(message);
}
PipeToChannel.prototype.onMessage = function (message) {