update

packages/cts-api/dist/cjs/WebSocketClient.js

                                             }
                                             catch (err) {
                                                 console.error(err);
+                                                reject(err);
                                             }
                                             return [4, this.connect()];
                                         case 1:
         return __awaiter(this, void 0, void 0, function () {
             var tk, data;
             return __generator(this, function (_a) {
-                tk = this.token;
-                data = this.request('/v1/session/bind/uid/by/token', { token: tk });
-                return [2, data || true];
+                switch (_a.label) {
+                    case 0:
+                        tk = this.token;
+                        return [4, this.request('/v1/session/bind/uid/by/token', { token: tk })];
+                    case 1:
+                        data = _a.sent();
+                        return [2, data || true];
+                }
             });
         });
     };
     WebSocketClient.prototype.onMessage = function (callback) {
-        this.on('/v1/message/listener', callback);
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                this.on('/v1/message/listener', callback);
+                return [2];
+            });
+        });
     };
     WebSocketClient.prototype.sendMessage = function (data) {
-        return this.request('/v1/send/message', data);
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                return [2, this.request('/v1/send/message', data)];
+            });
+        });
     };
     WebSocketClient.prototype.markServiced = function (data) {
-        return this.request('/v1/mark/message/serviced', data);
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                return [2, this.request('/v1/mark/message/serviced', data)];
+            });
+        });
     };
     WebSocketClient.prototype.getHistoryMessage = function (data) {
-        return this.request('/v1/history/message', data);
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                return [2, this.request('/v1/history/message', data)];
+            });
+        });
     };
     return WebSocketClient;
 }());

packages/cts-api/dist/types/WebSocketClient.d.ts

     connect(): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;
     ping(): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;
     authentication(): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;
-    onMessage(callback: ListenerCallback): void;
+    onMessage(callback: ListenerCallback): Promise<void>;
     sendMessage(data: object): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;
     markServiced(data: object): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;
     getHistoryMessage(data: object): Promise<import("ts-linker-sdk/dist/types/types").WebSocketResp>;

packages/cts-api/src/WebSocketClient.ts

             }, PING_INTERVAL) as any;
           } catch (err) {
             console.error(err);
+            reject(err);
           }
 
           const data = await this.connect();
 
   async authentication() {
     const tk = this.token;
-    const data = this.request('/v1/session/bind/uid/by/token', { token: tk });
+    const data = await this.request('/v1/session/bind/uid/by/token', { token: tk });
     return data || true;
   }
 
-  onMessage(callback: ListenerCallback) {
+  async onMessage(callback: ListenerCallback) {
     this.on('/v1/message/listener', callback);
   }
 
-  sendMessage(data: object) {
+  async sendMessage(data: object) {
     return this.request('/v1/send/message', data);
   }
 
-  markServiced(data: object) {
+  async markServiced(data: object) {
     return this.request('/v1/mark/message/serviced', data);
   }
 
    *
    * @param {*} data contact_id chat_type start_time limit
    */
-  getHistoryMessage(data: object) {
+  async getHistoryMessage(data: object) {
     return this.request('/v1/history/message', data);
   }
 }