Merge pull request #35 from pipedrive/fix_channel

Implement multi-channel connectivity

lib/channel.js

@@ -84,6 +84,12 @@ function Channel(apiToken) {
 					});
 				}
 
+				if (data.switch_to_channel && data.switch_to_channel.toString().match(/^\d+$/)) {
+					process.env.PIPEDRIVE_CHANNEL_HOST = 'channel' + data.switch_to_channel + '.pipedrive.com';
+					self.restartClient();
+					return;
+				}
+
 				if (data.rabbitStateChange === 'open') {
 					if (handlers['connect']) {
 						_.each(handlers['connect'], function(handler) {
@@ -96,7 +102,7 @@ function Channel(apiToken) {
 		client.onclose = function (e) {
 			if (!clientClosed) {
 				// not closed by user - we have some connection error.
-				self.restartClient();
+				self.startClient();
 				return;
 			}
 
@@ -111,13 +117,11 @@ function Channel(apiToken) {
 
 	this.restartClient = function() {
 		client.onopen = null;
-		client.onclose = null;
 		client.onmessage = null;
-		client = null;
-
 		clientStarted = false;
+		clientClosed = false;
 
-		setTimeout(self.startClient, (1+Math.random()*4)*1000);
+		client.close();
 	};
 
 	this.on = function(method, handler) {
@@ -145,6 +149,6 @@ function Channel(apiToken) {
 		if (client && client.close) {
 			client.close();
 		}
-	}
+	};
 
 }