fix: add debouncer

avantgardefinance · Feb 27, 2024 · 32a32db · 32a32db
1 parent 17a0eef
commit 32a32db
Showing 1 changed file with 30 additions and 27 deletions.
diff --git a/balancer-js/src/modules/data/token-prices/coingecko.ts b/balancer-js/src/modules/data/token-prices/coingecko.ts
@@ -13,6 +13,10 @@ function splitIntoChunks<TItem>(items: TItem[]): TItem[][] {
   return chunks;
 }
 
+function wait(ms: number) {
+  return new Promise((resolve) => setTimeout(resolve, ms));
+}
+
 /**
  * Simple coingecko price source implementation. Configurable by network and token addresses.
  */
@@ -42,36 +46,35 @@ export class CoingeckoPriceRepository implements Findable<Price> {
 
     const chunks = splitIntoChunks(addresses);
 
-    const response = await Promise.all(
-      chunks.map((chunk) =>
-        axios
-          .get<TokenPrices>(this.url(chunk), { signal })
-          .then(({ data }) => {
-            return data;
-          })
-          .catch((error) => {
-            const message = ['Error fetching token prices from coingecko'];
-            if (error.isAxiosError) {
-              if (error.response?.status) {
-                message.push(`with status ${error.response.status}`);
-              }
-            } else {
-              message.push(error);
+    let result: TokenPrices = {};
+
+    for (let i = 0; i < chunks.length; i++) {
+      const chunk = chunks[i];
+      const repsonse = await axios
+        .get<TokenPrices>(this.url(chunk), { signal })
+        .then(({ data }) => {
+          return data;
+        })
+        .catch((error) => {
+          const message = ['Error fetching token prices from coingecko'];
+          if (error.isAxiosError) {
+            if (error.response?.status) {
+              message.push(`with status ${error.response.status}`);
             }
-            return Promise.reject(message.join(' '));
-          })
-          .finally(() => {
-            console.timeEnd(
-              `fetching coingecko for ${addresses.length} tokens`
-            );
-          })
-      )
-    );
+          } else {
+            message.push(error);
+          }
+          return Promise.reject(message.join(' '));
+        })
+        .finally(() => {
+          console.timeEnd(`fetching coingecko for ${addresses.length} tokens`);
+        });
 
-    let result: TokenPrices = {};
+      result = { ...result, ...repsonse };
 
-    for (const chunk of response) {
-      result = { ...result, ...chunk };
+      if (i < chunks.length - 1) {
+        await wait(200);
+      }
     }
 
     return result;