Headers emulation

src/centrifuge.ts

@@ -28,6 +28,7 @@ import {
 import EventEmitter from 'events';
 
 const defaults: Options = {
+  headers: {},
   token: '',
   getToken: null,
   data: null,
@@ -250,6 +251,11 @@ export class Centrifuge extends (EventEmitter as new () => TypedEventEmitter<Cli
     this._token = token;
   }
 
+  /** setHeaders allows setting connection emulated headers. */
+  setHeaders(headers: {[key: string]: string}) {
+    this._config.headers = headers;
+  }
+
   /** send asynchronous data to a server (without any response from a server 
    * expected, see rpc method if you need response). */
   send(data: any): Promise<void> {
@@ -1045,6 +1051,9 @@ export class Centrifuge extends (EventEmitter as new () => TypedEventEmitter<Cli
     if (this._config.version) {
       req.version = this._config.version;
     }
+    if (Object.keys(this._config.headers).length > 0) {
+      req.headers = this._config.headers;
+    }
 
     const subs = {};
     let hasSubs = false;

src/client.proto.json

@@ -273,6 +273,10 @@
                     "time": {
                       "type": "int64",
                       "id": 9
+                    },
+                    "channel": {
+                      "type": "string",
+                      "id": 10
                     }
                   },
                   "reserved": [
@@ -465,6 +469,11 @@
                     "version": {
                       "type": "string",
                       "id": 5
+                    },
+                    "headers": {
+                      "keyType": "string",
+                      "type": "string",
+                      "id": 6
                     }
                   }
                 },

src/types.ts

@@ -91,6 +91,11 @@ export interface TransportEndpoint {
 
 /** Options for Centrifuge client. */
 export interface Options {
+  // provide header emulation, these headers are sent with first protocol message
+  // the backend can process those in a customized manner. In case of Centrifugo
+  // these headers are then used like real HTTP headers sent from the client.
+  // Requires Centrifugo v6.
+  headers: {[key: string]: string};
   /** allows enabling debug mode */
   debug: boolean;
   /** allows setting initial connection token (JWT) */