Add parameter to specify clientMsgId generation in order to support c…

…Tweb-12413 (#30)

* Add parameter to specify clientMsgId generation in order to support cTweb-12413

* Update version

lib/connect.d.ts

@@ -7,6 +7,7 @@ export interface IConnectionParams {
     adapter: IConnectionAdapter;
     instanceId: string;
     payloadTypesNotAwaitingResponse?: number[];
+    generateClientMsgId?(): string;
 }
 export interface ISendCommand {
     message: IMessage;
@@ -26,6 +27,7 @@ export declare class Connect {
     private guaranteedCommandsToBeSent;
     private pushEvents;
     private payloadTypesNotAwaitingResponse;
+    private readonly generateClientMsgId;
     constructor(params: IConnectionParams);
     private subscribeToAdapter();
     private onOpen();
@@ -39,6 +41,5 @@ export declare class Connect {
     sendCommand(command: ISendCommand): ISubscribableCommand;
     private getSubscribableForList(cachedCommand, listUsed);
     private getEmptySubscribable();
-    private generateClientMsgId();
     setPushEventHandler(callback: (data: IMessage) => void): void;
 }

lib/connect.js

@@ -12,6 +12,7 @@ var Connect = (function () {
         this.instanceId = params.instanceId || 'connect';
         this.adapter = params.adapter;
         this.payloadTypesNotAwaitingResponse = params.payloadTypesNotAwaitingResponse || [];
+        this.generateClientMsgId = params.generateClientMsgId || hat;
         this.subscribeToAdapter();
     }
     Connect.prototype.subscribeToAdapter = function () {
@@ -140,9 +141,6 @@ var Connect = (function () {
             }
         };
     };
-    Connect.prototype.generateClientMsgId = function () {
-        return hat();
-    };
     Connect.prototype.setPushEventHandler = function (callback) {
         this.pushEvents.subscribe(callback);
     };

package.json

@@ -1,6 +1,6 @@
 {
   "name": "connect-ts-api",
-  "version": "4.6.1",
+  "version": "4.6.2",
   "main": "lib/connect.js",
   "typings": "lib/connect",
   "scripts": {
@@ -49,4 +49,4 @@
     "tslint": "3.15.1",
     "typescript": "2.3.0"
   }
-}
+}

src/connect.ts

@@ -11,6 +11,7 @@ export interface IConnectionParams {
     adapter: IConnectionAdapter;
     instanceId: string;
     payloadTypesNotAwaitingResponse?: number[];
+    generateClientMsgId?(): string;
 }
 
 export interface ISendCommand {
@@ -39,11 +40,13 @@ export class Connect {
     private guaranteedCommandsToBeSent: CacheCommand[] = [];
     private pushEvents = new ReplaySubject<IMessage>(1);
     private payloadTypesNotAwaitingResponse: number[];
+    private readonly generateClientMsgId: () => string;
 
     constructor(params: IConnectionParams) {
         this.instanceId = params.instanceId || 'connect';
         this.adapter = params.adapter;
         this.payloadTypesNotAwaitingResponse = params.payloadTypesNotAwaitingResponse || [];
+        this.generateClientMsgId = params.generateClientMsgId || hat;
         this.subscribeToAdapter();
     }
 
@@ -178,10 +181,6 @@ export class Connect {
         }
     }
 
-    private generateClientMsgId(): string {
-        return hat();
-    }
-
     public setPushEventHandler(callback: (data: IMessage) => void): void {
         this.pushEvents.subscribe(callback);
     }