cleaned up the mess ... :)

app/Game/Core/NotificationCenter.js

@@ -11,7 +11,7 @@ function () {
     NotificationCenter.prototype.trigger = function (topic /*, arguments*/) {
 
         if (!this.topics[topic]) {
-            throw "No such topic " + topic + ". Could not trigger.";
+            throw "No such topic " + topic + ". Could not trigger. arguments: " + arguments.join;
         }
 
         var args = Array.prototype.slice.call(arguments, 1);

app/Game/Server/Channel.js

@@ -5,11 +5,16 @@
 
     function (GameController, NotificationCenter) {
 
-        function Channel (coordinatorLink) {
+        function Channel (pipeToLobby) {
+
             var self = this;
 
-            this.coordinatorLink = coordinatorLink;
+            this.pipeToLobby = pipeToLobby;
-            this.coordinatorLink.receive = function (message) { self.onMessage(message) };
+
+            
+            //this.pipeToLobby.receive = function (message) { self.onMessage(message) };
+            // !!! This should be done differently - use NotificationCenter.on('channel/dungeon/message') instead
+
             
             this.users = {};
 

app/Game/Server/PipeToLobby.js

@@ -1,30 +1,33 @@
 define([
-    "Game/Core/NotficationCenter"
+    "Game/Core/NotificationCenter",
+    "Game/Server/Channel"
 ],
 
-function (NotficationCenter) {
+function (NotificationCenter, Channel) {
 
     function PipeToLobby (process) {
 
+        var self = this;
+
         this.channel = null;
         this.process = process;
 
-        NotficationCenter.on('net/send', this.send, this);
+        NotificationCenter.on('net/send', this.send, this);
 
         process.on('message', function (message, handle) {
 
-            switch(message) {
+            switch(message.data) {
                 case 'CREATE':
-                    this.channel = new Channel(this);
+                    self.channel = new Channel(self);
                     break;
 
                 case 'KILL':
-                    this.channel.destroy();
+                    self.channel.destroy();
                     process.exit(0);
                     break;
 
                 default:
-                    this.onMessage(message);
+                    self.onMessage(message);
                     break;
             }
         });    
@@ -40,7 +43,7 @@ function (NotficationCenter) {
     };
 
     PipeToLobby.prototype.onMessage = function (message) {
-        NotficationCenter.trigger(message.recipient + '/message', message.data);
+        NotificationCenter.trigger(message.recipient + '/message', message.data);
     }
 
     return PipeToLobby;

app/Lobby/Coordinator.js

@@ -1,13 +1,11 @@
 define([
     "Lobby/User", 
     "Game/Server/Channel",
-    "Lobby/PipeToChannel"
+    "Lobby/PipeToChannel",
-    "child_process"
+    "Game/Core/NotificationCenter"
 ], 
 
-function (User, Channel, PipeToChannel, childProcess) {
+function (User, Channel, PipeToChannel, NotificationCenter) {
-
-    var fork = childProcess.fork;
 
     function Coordinator () {
         this.channels = {};

app/Lobby/PipeToChannel.js

@@ -1,8 +1,11 @@
 define([
-	"Game/Core/NotificationCenter"
+	//"Game/Core/NotificationCenter",
+	"child_process"
 ],
 
-function (NotificationCenter) {
+function (childProcess) {
+
+	var fork = childProcess.fork;
 
 	function PipeToChannel (channelName) {
 

channel.js

@@ -1,17 +1,19 @@
 var requirejs = require('requirejs');
 
 requirejs.config({
+    nodeRequire: require,
     baseUrl: 'app'
 });
 
 var inspector = {};
 
 requirejs([
-    "Game/Server/LobbyPipe"
+    "Game/Server/PipeToLobby",
+    "Game/Core/NotificationCenter"
 ], 
 
-function (LobbyPipe) {
+function (PipeToLobby, nc) {
-	var lobbyPipe = new LobbyPipe(process);
+	var PipeToLobby = new PipeToLobby(process);
     
-    inspector.lobbyPipe = lobbyPipe;
+    inspector.PipeToLobby = PipeToLobby;
 });