From 205380dc853ea8e0dc9643f159354c8e15c44fe0 Mon Sep 17 00:00:00 2001
From: Zog
Date: Thu, 29 Mar 2018 11:03:40 +0200
Subject: Prevent multiple concurent queries for routes costs

---
 app/javascript/journey_patterns/actions/index.js | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

(limited to 'app/javascript/journey_patterns')

diff --git a/app/javascript/journey_patterns/actions/index.js b/app/javascript/journey_patterns/actions/index.js
index b90908264..666157ea4 100644
--- a/app/javascript/journey_patterns/actions/index.js
+++ b/app/javascript/journey_patterns/actions/index.js
@@ -220,7 +220,16 @@ const actions = {
       })
   },
   fetchRouteCosts: (dispatch, key, index) => {
-    if (actions.routeCostsCache) {
+    if(actions.fetchingRouteCosts){
+        // A request is already sent, wait for it
+        if(!actions.waitingForRouteCosts){
+          actions.waitingForRouteCosts = []
+        }
+        actions.waitingForRouteCosts.push([key, index])
+        return
+    }
+
+    if(actions.routeCostsCache) {
       // Dispatch asynchronously to prevent warning when
       // this executes during `render()`
       requestAnimationFrame(() => {
@@ -231,6 +240,7 @@ const actions = {
         ))
       })
     } else {
+      actions.fetchingRouteCosts = true
       fetch(window.routeCostsUrl, {
         credentials: 'same-origin',
       }).then(response => {
@@ -240,6 +250,12 @@ const actions = {
         actions.routeCostsCache = costs
 
         dispatch(actions.receiveRouteCosts(costs, key, index))
+        if(actions.waitingForRouteCosts){
+          actions.waitingForRouteCosts.map(function(item, i) {
+            dispatch(actions.receiveRouteCosts(costs, item[0], item[1]))
+          })
+        }
+        actions.fetchingRouteCosts = false
       })
     }
   },
-- 
cgit v1.2.3