Merge remote-tracking branch 'origin/master' into feat/storage-v2

bin/deepstream.ts

@@ -14,7 +14,7 @@ import { daemon } from './deepstream-daemon'
 const program = new Command('deepstream')
 program
   .usage('[command]')
-  .version(pgk.version)
+  .version(pgk.version.toString())
 
 start(program)
 install(program)

package.json

@@ -56,7 +56,7 @@
     "chai": "^4.1.2",
     "coveralls": "^3.0.0",
     "cucumber": "https://github.com/deepstreamIO/cucumber-js.git",
-    "deepstream.io-client-js": "https://github.com/deepstreamIO/deepstream.io-client-js.git",
+    "deepstream.io-client-js": "https://github.com/deepstreamIO/deepstream.io-client-js.git#v4",
     "istanbul": "^0.4.5",
     "jasmine": "^2.8.0",
     "n0p3": "^1.0.2",

src/cluster/cluster-node.ts

@@ -19,10 +19,10 @@ export default class ClusterNode implements Cluster {
   public isLeader (): boolean { throw new Error('Leader not used in single state') }
 
   public getStateRegistry (stateRegistryTopic: TOPIC) {
-    let stateRegistry = this.stateRegistries.get(name)
+    let stateRegistry = this.stateRegistries.get(stateRegistryTopic)
     if (!stateRegistry) {
-      stateRegistry = new StateRegistry(name, {})
-      this.stateRegistries.set(name, stateRegistry)
+      stateRegistry = new StateRegistry(stateRegistryTopic, {})
+      this.stateRegistries.set(stateRegistryTopic, stateRegistry)
     }
     return stateRegistry
   }

test/test-mocks/message-connector-mock.ts

@@ -44,9 +44,9 @@ export default class MessageConnectorMock extends EventEmitter implements Cluste
 
   }
 
-  public send (topic, message) {
+  public send (stateRegistryTopic, message) {
     this.publishedMessages.push(message)
-    this.lastPublishedTopic = message.topic
+    this.lastPublishedTopic = stateRegistryTopic
     this.lastPublishedMessage = JSON.parse(JSON.stringify(message))
   }