fix server-side subscribe/unsubscribe, prepare 2.8.3

CHANGELOG.md

@@ -1,3 +1,8 @@
+2.8.3
+=====
+
+* Fix regression of 2.8.0: handle server-side subscribe and unsubscribe pushes.
+
 2.8.2
 =====
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "centrifuge",
-  "version": "2.8.2",
+  "version": "2.8.3",
   "description": "Centrifuge and Centrifugo client for NodeJS and browser",
   "main": "dist/centrifuge.js",
   "types": "dist/centrifuge.d.ts",

src/centrifuge.js

@@ -1599,11 +1599,11 @@ export class Centrifuge extends EventEmitter {
     } else if (type === this._pushType.LEAVE) {
       const leave = this._decoder.decodePushData(this._pushType.LEAVE, push.data);
       this._handleLeave(channel, leave);
-    } else if (type === this._pushType.UNSUB) {
-      const unsub = this._decoder.decodePushData(this._pushType.UNSUB, push.data);
+    } else if (type === this._pushType.UNSUBSCRIBE) {
+      const unsub = this._decoder.decodePushData(this._pushType.UNSUBSCRIBE, push.data);
       this._handleUnsub(channel, unsub);
-    } else if (type === this._pushType.SUB) {
-      const sub = this._decoder.decodePushData(this._pushType.SUB, push.data);
+    } else if (type === this._pushType.SUBSCRIBE) {
+      const sub = this._decoder.decodePushData(this._pushType.UNSUBSCRIBE, push.data);
       this._handleSub(channel, sub);
     }
     next();

src/protobuf.js

@@ -1,4 +1,4 @@
-import {Centrifuge} from './centrifuge.js';
+import { Centrifuge } from './centrifuge.js';
 
 const protobuf = require('protobufjs/light');
 const proto = protobuf.Root.fromJSON(require('./client.proto.json'));