fix: update etherscan/polygonscan plugin

src/apis/api.ts

@@ -1,14 +1,15 @@
 import fetch from 'node-fetch';
 import Cache from '../common/cache';
 import { Coin } from '../plugins/common/plugin';
+import { sleep } from '../common/utils';
 
 export type Price = {
   price: number;
   coin: Coin;
 };
 
 export default class Api {
-  public async getJson(url: string) {
+  public async getJson(url: string): Promise<any | null> {
     const cachedText = Cache.get(url);
     if (cachedText) {
       return JSON.parse(cachedText);
@@ -19,6 +20,14 @@ export default class Api {
       Cache.write(url, text);
       return JSON.parse(text);
     }
+    if (response.status === 429) {
+      console.log(
+        `Hit rate limit (${response.status}), trying again in 6 seconds...`,
+        url
+      );
+      await sleep(6000);
+      return this.getJson(url);
+    }
     return null;
   }
 }

src/common/utils.ts

@@ -35,3 +35,5 @@ export const mergeDeep = (target: any, ...sources: any[]): any => {
 
   return mergeDeep(target, ...sources);
 };
+
+export const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));

src/plugins/etherscan.ts

@@ -7,10 +7,11 @@ export default class Etherscan extends Plugin {
 
   // "Txhash","UnixTimestamp","DateTime","From","To","Value","ContractAddress","TokenName","TokenSymbol"
   // "Txhash","UnixTimestamp","DateTime","From","To","TokenValue","USDValueDayOfTx","ContractAddress","TokenName","TokenSymbol"
+  // "Txhash","Blockno","UnixTimestamp","DateTime","From","To","TokenValue","USDValueDayOfTx","ContractAddress","TokenName","TokenSymbol"
   async convertRow(line: string[]): Promise<string[] | null> {
-    const csvToken = line[9] || line[8];
-    const csvTimestamp = line[1];
-    const csvAmount = line[5];
+    const csvToken = line[10] || line[9] || line[8];
+    const csvTimestamp = line[2];
+    const csvAmount = line[6];
     if (!csvToken || !csvTimestamp) {
       console.warn(
         `Token (${csvToken}) or timestamp (${csvTimestamp}) not found!)`