workaround for topics issue

Author: iurimatias

js/build/embark.bundle.js

@@ -382,16 +382,13 @@ var EmbarkJS =
 	    throw new Error("missing option: data");
 	  }
 
-	  // do fromAscii to each topics unless it's already a string
 	  if (typeof topics === 'string') {
 	    topics = topics;
 	  } else {
 	    // TODO: better to just send to different channels instead
 	    topics = topics.join(',');
 	  }
 
-	  // TODO: if it's array then join and send ot several
-	  // keep list of channels joined
 	  this.orbit.join(topics);
 
 	  var payload = JSON.stringify(data);
@@ -403,14 +400,14 @@ var EmbarkJS =
 	  var self = this;
 	  var topics = options.topic || options.topics;
 
-	  // do fromAscii to each topics unless it's already a string
 	  if (typeof topics === 'string') {
 	    topics = topics;
 	  } else {
-	    // TODO: better to just send to different channels instead
 	    topics = topics.join(',');
 	  }
 
+	  this.orbit.join(topics);
+
 	  var messageEvents = function() {
 	    this.cb = function() {};
 	  };
@@ -425,10 +422,12 @@ var EmbarkJS =
 
 	  var promise = new messageEvents();
 
-	  this.orbit.events.on('message', (topics, message) => {
+	  this.orbit.events.on('message', (channel, message) => {
+	    // TODO: looks like sometimes it's receving messages from all topics
+	    if (topics !== channel) return;
 	    self.orbit.getPost(message.payload.value, true).then((post) => {
 	      var data = {
-	        topic: topics,
+	        topic: channel,
 	        data: post.content,
 	        from: post.meta.from.name,
 	        time: (new Date(post.meta.ts))

js/embark.js

@@ -335,16 +335,13 @@ EmbarkJS.Messages.Orbit.sendMessage = function(options) {
     throw new Error("missing option: data");
   }
 
-  // do fromAscii to each topics unless it's already a string
   if (typeof topics === 'string') {
     topics = topics;
   } else {
     // TODO: better to just send to different channels instead
     topics = topics.join(',');
   }
 
-  // TODO: if it's array then join and send ot several
-  // keep list of channels joined
   this.orbit.join(topics);
 
   var payload = JSON.stringify(data);
@@ -356,14 +353,14 @@ EmbarkJS.Messages.Orbit.listenTo = function(options) {
   var self = this;
   var topics = options.topic || options.topics;
 
-  // do fromAscii to each topics unless it's already a string
   if (typeof topics === 'string') {
     topics = topics;
   } else {
-    // TODO: better to just send to different channels instead
     topics = topics.join(',');
   }
 
+  this.orbit.join(topics);
+
   var messageEvents = function() {
     this.cb = function() {};
   };
@@ -378,10 +375,12 @@ EmbarkJS.Messages.Orbit.listenTo = function(options) {
 
   var promise = new messageEvents();
 
-  this.orbit.events.on('message', (topics, message) => {
+  this.orbit.events.on('message', (channel, message) => {
+    // TODO: looks like sometimes it's receving messages from all topics
+    if (topics !== channel) return;
     self.orbit.getPost(message.payload.value, true).then((post) => {
       var data = {
-        topic: topics,
+        topic: channel,
         data: post.content,
         from: post.meta.from.name,
         time: (new Date(post.meta.ts))