Implemented failover in querypairs script

gsscoder · gsscoder · commit 7b69459bceac · 2022-07-25T10:36:54.000+02:00
diff --git a/.env.example b/.env.example
@@ -1,3 +1,3 @@
-PROVIDER_URL_MUMBAI="your_mumbai_provider_url"
+PROVIDER_URL_POLYGON="your_provider_url"
 ACCOUNT_KEY="your_account_key"
-UV2QUERY_ADDRESS_MUMBAI="query_contract_address"
+UV2QUERY_ADDRESS_POLYGON="query_contract_address"
diff --git a/README.md b/README.md
@@ -9,28 +9,29 @@ Choose a consistent network name across the two configuration files.
 ### .env
 
 ```text
-PROVIDER_URL_MUMBAI="https://polygon-mumbai.g.alchemy.com/v2/..."
+PROVIDER_URL_POLYGON="https://polygon-mainnet.g.alchemy.com/v2/..."
 ACCOUNT_KEY="5fa...9f39"
-UV2QUERY_ADDRESS_MUMBAI="0x460...7e67"
+UV2QUERY_ADDRESS_POLYGON="0x460...7e67"
 ```
 
 ### appconfigs.json
 
 ```json
 {
-  "network": "mumbai",
+  "network": "polygon",
   "dex": "quickswap",
-  "pairsChunkSize": 1000,
-  "cooldownMs": 1000,
+  "pairsChunkSize": 500,
+  "cooldownMs": 2000,
+  "cooldownAfterFailSec": 3,
   "tokensChunkSize": 10,
-  "quickswapFactoryMumbai": "0x5757371414417b8C6CAad45bAeF941aBc7d3Ab32",
+  "quickswapFactoryPolygon": "0x5757371414417b8C6CAad45bAeF941aBc7d3Ab32",
   "outputPath": "./output"
 }
 ```
 
 ## Usage
 
-- Deploy the contract: `npx hardhat run .\scripts\deploy.js --network mumbai`.
+- Deploy the contract: `npx hardhat run .\scripts\deploy.js --network polygon`.
 
 - Set all needed configuration values.
 
diff --git a/appconfigs.json b/appconfigs.json
@@ -1,9 +1,11 @@
 {
-  "network": "mumbai",
+  "network": "polygon",
   "dex": "quickswap",
-  "pairsChunkSize": 1000,
-  "cooldownMs": 1000,
+  "pairsChunkSize": 500,
+  "cooldownMs": 2000,
+  "cooldownAfterFailSec": 3,
   "tokensChunkSize": 10,
   "quickswapFactoryMumbai": "0x5757371414417b8C6CAad45bAeF941aBc7d3Ab32",
+  "quickswapFactoryPolygon": "0x5757371414417b8C6CAad45bAeF941aBc7d3Ab32",
   "outputPath": "./output"
 }
diff --git a/scripts/querypairs.js b/scripts/querypairs.js
@@ -10,7 +10,6 @@ const dex = configs.dex;
 const dexDescr = `${dex} (${network})`;
 const uv2queryAddress = process.env[`UV2QUERY_ADDRESS_${network.toUpperCase()}`];
 const factoryAddress = configs[`${dex}Factory${utils.toTitleCase(network)}`]
-const cooldownMs = configs.cooldownMs;
 
 async function main() {
   const account = utils.connectAccount(network, process.env.ACCOUNT_KEY);
@@ -23,9 +22,22 @@ async function main() {
   for (let r = 0; r < ranges.length; r++) {
     const from = ranges[r][0];
     const to = ranges[r][1];
-    console.log(`Getting pairs from ${from} to ${to}`);
-    const pairsChunk = await uv2query.getPairsByRange(factoryAddress, from, to);
-    await utils.sleep(cooldownMs);
+    console.log(`[${[r]}] Getting pairs from ${from} to ${to}`);
+    let succeeded = false;
+    let pairsChunk;
+    try {
+      pairsChunk = await uv2query.getPairsByRange(factoryAddress, from, to);
+      succeeded = true;
+    } catch {
+      console.log(`ERROR: failed to get pairs for range ${[r]}`);
+      console.log(`Cooling down for ${configs.cooldownAfterFailSec} sec`);
+      await utils.sleep(configs.cooldownAfterFailSec * 1000);
+      r--;
+      continue;
+    }
+    if (succeeded) {
+      await utils.sleep(configs.cooldownMs);
+    }
     for (let c = 0; c < pairsChunk.length; c++) {
       pairs.push({
         address: pairsChunk[c][0],
