From fbd50bad1d9f7a74ae07811c92df182a747f3250 Mon Sep 17 00:00:00 2001
From: Book Pauk <bookpauk@gmail.com>
Date: Wed, 22 Jan 2020 20:02:05 +0700
Subject: [PATCH] =?UTF-8?q?=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=B1=D0=B0=D0=B3=D0=BE=D0=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client/api/WebSocketConnection.js | 30 +++++-------------------------
 1 file changed, 5 insertions(+), 25 deletions(-)

diff --git a/client/api/WebSocketConnection.js b/client/api/WebSocketConnection.js
index e39bd790..69e54561 100644
--- a/client/api/WebSocketConnection.js
+++ b/client/api/WebSocketConnection.js
@@ -98,22 +98,7 @@ class WebSocketConnection {
     }
 
     //timeout в минутах (cleanPeriod)
-    message(timeout = 2) {
-        return new Promise((resolve, reject) => {
-            this.addListener({
-                timeout,
-                onMessage: (mes) => {
-                    resolve(mes);
-                },
-                onError: (e) => {
-                    reject(e);
-                }
-            });
-        });
-    }
-
-    //timeout в минутах (cleanPeriod)
-    messageId(requestId, timeout = 2) {
+    message(requestId, timeout = 2) {
         return new Promise((resolve, reject) => {
             this.addListener({
                 requestId,
@@ -129,17 +114,9 @@ class WebSocketConnection {
     }
 
     send(req) {
-        if (this.ws && this.ws.readyState == WebSocket.OPEN) {
-            this.ws.send(JSON.stringify(req));
-        } else {
-            throw new Error('WebSocket connection is not ready');
-        }
-    }
-
-    sendId(req) {
         if (this.ws && this.ws.readyState == WebSocket.OPEN) {
             const requestId = ++this.requestId;
-            this.ws.send(Object.assign({requestId}, JSON.stringify(req)));
+            this.ws.send(JSON.stringify(Object.assign({requestId}, req)));
             return requestId;
         } else {
             throw new Error('WebSocket connection is not ready');
@@ -162,6 +139,9 @@ class WebSocketConnection {
             for (const listener of this.listeners) {
                 if (now - listener.regTime < listener.timeout*cleanPeriod - 50) {
                     newListeners.push(listener);
+                } else {
+                    if (listener.onError)
+                        listener.onError('Время ожидания ответа истекло');
                 }
             }
             this.listeners = newListeners;