new approach

rollup.config.mjs

@@ -40,17 +40,14 @@ export default [
     plugins: [
       json(),
       typescript(),
+      resolve({
+        preferBuiltins: false
+      }),
       commonjs(),
       del({
         targets: [
-          'build/cjs/*',
-          'build/esm/*',
-          '!build/cjs/protobuf.js',
-          '!build/cjs/protobuf.js.map',
-          '!build/cjs/protobuf.d.ts',
-          '!build/esm/protobuf.js',
-          '!build/esm/protobuf.js.map',
-          '!build/esm/protobuf.d.ts',
+          'build/cjs/index.d.ts',
+          'build/esm/index.d.ts',
         ],
         hook: 'writeBundle',
         runOnce: true,

src/browser.protobuf.ts

@@ -6,12 +6,8 @@ import { Centrifuge } from './centrifuge';
 import { ProtobufCodec } from './protobuf';
 
 export default class CentrifugeProtobuf extends Centrifuge {
-    protected _formatOverride(format: 'json' | 'protobuf') {
-        if (format === 'protobuf') {
-            this._codec = new ProtobufCodec();
-            return true;
-        }
-        return false;
+    protected _formatOverride() {
+        this._codec = new ProtobufCodec();
     }
 }
 

src/centrifuge.ts

@@ -28,7 +28,6 @@ import {
 import EventEmitter from 'events';
 
 const defaults: Options = {
-  codec: new JsonCodec(),
   token: '',
   getToken: null,
   data: null,
@@ -417,15 +416,8 @@ export class Centrifuge extends (EventEmitter as new () => TypedEventEmitter<Cli
   }
 
   /** @internal */
-  private _setFormat(format: 'json' | 'protobuf') {
-    if (this._formatOverride(format)) {
-      return;
-    }
-  }
-
-  /** @internal */
-  protected _formatOverride(_format: 'json' | 'protobuf') {
-    return false;
+  protected _formatOverride() {
+    return;
   }
 
   private _configure() {
@@ -445,8 +437,8 @@ export class Centrifuge extends (EventEmitter as new () => TypedEventEmitter<Cli
       this._data = this._config.data;
     }
 
-    this._codec = this._config.codec;
-    this._setFormat(this._codec.name());
+    this._codec = new JsonCodec();
+    this._formatOverride();
 
     if (this._config.debug === true ||
       (typeof localStorage !== 'undefined' && localStorage.getItem('centrifuge.debug'))) {

src/protobuf.ts

@@ -1,8 +1,10 @@
-// import * as protobuf from 'protobufjs/light'
-// import * as protoJSON from './client.proto.json';
-// const proto = protobuf.Root.fromJSON(protoJSON);
-const protobuf = require('protobufjs/light');
-const proto = protobuf.Root.fromJSON(require('./client.proto.json'));
+import { Centrifuge, UnauthorizedError } from './centrifuge';
+import { Subscription } from './subscription';
+export * from "./types";
+
+import * as protobuf from 'protobufjs/light'
+import * as protoJSON from './client.proto.json';
+const proto = protobuf.Root.fromJSON(protoJSON);
 
 const Command = proto.lookupType('protocol.Command');
 const Reply = proto.lookupType('protocol.Reply');
@@ -54,3 +56,15 @@ export class ProtobufCodec {
     };
   }
 }
+
+class CentrifugeProtobuf extends Centrifuge {
+  protected _formatOverride() {
+    this._codec = new ProtobufCodec();
+  }
+}
+
+export {
+  CentrifugeProtobuf as Centrifuge,
+  UnauthorizedError,
+  Subscription
+}

src/types.ts

@@ -80,9 +80,6 @@ export interface TransportEndpoint {
 
 /** Options for Centrifuge client. */
 export interface Options {
-  /** select codec to use. Default is JSON. To use Protobuf protocol you need to use 
-   * ProtobufCodec. */
-  codec: any;
   /** allows enabling debug mode */
   debug: boolean;
   /** allows setting initial connection token (JWT) */