Merge pull request #1 from binary-hamedanchi/mohammad/duplicate_request

Solve duplicate request

Author: negarn

src/javascript/binary/websocket_pages/mb_trade/mb_symbols.js

@@ -57,7 +57,7 @@ const MBSymbols = (function () {
             } else if (website_status.website_status.clients_country === 'jp' || getLanguage() === 'JA') {
                 req.landing_company = 'japan';
             }
-            BinarySocket.send(req);
+            BinarySocket.send(req, false, 'active_symbols');
             need_page_update = update;
         });
     };

src/javascript/binary/websocket_pages/socket.js

@@ -53,7 +53,9 @@ const BinarySocketClass = function() {
         'get_settings',
         'residence_list',
         'landing_company',
+        'payout_currencies',
     ];
+    let sent_requests = [];
     const waiting_list = {
         items: {},
         add  : (msg_type, promise_obj) => {
@@ -124,17 +126,25 @@ const BinarySocketClass = function() {
         return promise_obj.promise;
     };
 
-    const send = function(data, force_send) {
+    const send = function(data, force_send, msg_type) {
         const promise_obj = new PromiseClass();
 
-        if (!force_send) {
-            const msg_type = no_duplicate_requests.find(c => c in data);
+        msg_type = msg_type || no_duplicate_requests.find(c => c in data);
+        if (!force_send && msg_type) {
             const last_response = State.get(['response', msg_type]);
             if (last_response) {
                 promise_obj.resolve(last_response);
                 return promise_obj.promise;
+            } else if (sent_requests.indexOf(msg_type) >= 0) {
+                return wait(msg_type).then((response) => {
+                    promise_obj.resolve(response);
+                    return promise_obj.promise;
+                });
             }
         }
+        if (msg_type) {
+            sent_requests.push(msg_type);
+        }
 
         if (!data.req_id) {
             data.req_id = ++req_id;
@@ -343,6 +353,7 @@ const BinarySocketClass = function() {
 
         binarySocket.onclose = function () {
             authorized = false;
+            sent_requests = [];
             clearTimeouts();
 
             if (wrongAppId !== getAppId()) {