From b7bc1cfe776aa07a0cfd94fd68f0b6a15a0299ce Mon Sep 17 00:00:00 2001
From: Christopher Jeffrey <chjjeffrey@gmail.com>
Date: Fri, 27 May 2016 01:05:44 -0700
Subject: [PATCH] more socket.io things.

---
 lib/bcoin/http/client.js |  4 ++--
 lib/bcoin/http/server.js | 10 +++++++++-
 2 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/lib/bcoin/http/client.js b/lib/bcoin/http/client.js
index e974becf..3a47d1cb 100644
--- a/lib/bcoin/http/client.js
+++ b/lib/bcoin/http/client.js
@@ -140,7 +140,7 @@ HTTPClient.prototype.listenWallet = function listenWallet(id) {
   if (!this.socket)
     return;
 
-  this.socket.join(id);
+  this.socket.emit('join', id);
 };
 
 /**
@@ -152,7 +152,7 @@ HTTPClient.prototype.unlistenWallet = function unlistenWallet(id) {
   if (!this.socket)
     return;
 
-  this.socket.leave(id);
+  this.socket.emit('leave', id);
 };
 
 /**
diff --git a/lib/bcoin/http/server.js b/lib/bcoin/http/server.js
index c43f8d08..355990fd 100644
--- a/lib/bcoin/http/server.js
+++ b/lib/bcoin/http/server.js
@@ -663,6 +663,14 @@ HTTPServer.prototype._initIO = function _initIO() {
       self.emit('error', err);
     });
 
+    socket.on('join', function(id) {
+      socket.join(id);
+    });
+
+    socket.on('leave', function(id) {
+      socket.leave(id);
+    });
+
     self.emit('websocket', socket);
 
     socket.emit('version', {
@@ -771,7 +779,7 @@ HTTPServer.prototype.listen = function listen(port, host, callback) {
       return self.emit('error', err);
     }
 
-    bcoin.debug('Listening - host=%s port=%d',
+    bcoin.debug('HTTP server listening on %s (port=%d).',
       address.address, address.port);
 
     self.loaded = true;