Event Emitter added

jolira · Aug 12, 2011 · cb6ed2a · cb6ed2a
1 parent 8b9ba02
commit cb6ed2a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 15 deletions.
diff --git a/examples/echo.js b/examples/echo.js
@@ -43,5 +43,6 @@ xmpp.connect({
     jid         : argv[2],
     password    : argv[3],
     host        : 'talk.google.com',
+    host        : 'talk.google.com',
     port        : 5222
 });
diff --git a/lib/simple-xmpp.js b/lib/simple-xmpp.js
@@ -25,27 +25,26 @@
  */
 
 var xmpp = require('node-xmpp');
+var EventEmitter = require('events').EventEmitter;
 
 module.exports = new SimpleXMPP();
 
 function SimpleXMPP() {
 
     var conn;
 
-    var chatCallback;
-    var errorCallback;
-    var onlineCallback;
+    var events = new EventEmitter();
 
     this.onChat = function(callback) {
-        chatCallback = callback;
+        events.on('chat', callback);
     };
 
     this.onError = function(callback) {
-        errorCallback = callback;
+        events.on('error', callback);
     };
 
     this.onOnline = function(callback) {
-        onlineCallback = callback;
+        events.on('online', callback);
     };
 
     this.send = function(to, message) {
@@ -68,9 +67,7 @@ function SimpleXMPP() {
 
         conn.on('online', function(){
             conn.send(new xmpp.Element('presence'));
-            if(onlineCallback) {
-                onlineCallback();
-            }
+            events.emit('online');
         });
 
         conn.on('stanza', function(stanza) {
@@ -80,17 +77,13 @@ function SimpleXMPP() {
                 if(chat.name == 'body') {
                     var message = stanza.children[0].children[0];
                     var from = stanza.attrs.from;
-                    if(chatCallback) {
-                        chatCallback(from, message);
-                    }   
+                    events.emit('chat', from, message);  
                 }
             }
         });
 
         conn.on('error', function(err) {
-            if(errorCallback) {
-                errorCallback(err);
-            }
+            events.emit('error', err);
         });
 
     };