npm prettier

0xProject · Oct 4, 2024 · 8e2c4b3 · 8e2c4b3
1 parent 2230e55
commit 8e2c4b3
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 15 deletions.
diff --git a/src/config.ts b/src/config.ts
@@ -142,10 +142,10 @@ export const SCRAPER_MODE: ScraperMode =
     process.env.SCRAPER_MODE === undefined
         ? DEFAULT_SCRAPER_MODE
         : process.env.SCRAPER_MODE === 'BLOCKS'
-            ? 'BLOCKS'
-            : process.env.SCRAPER_MODE === 'EVENTS'
-                ? 'EVENTS'
-                : throwError('Wrong SCRAPER_MODE');
+        ? 'BLOCKS'
+        : process.env.SCRAPER_MODE === 'EVENTS'
+        ? 'EVENTS'
+        : throwError('Wrong SCRAPER_MODE');
 export const METRICS_PATH = process.env.METRICS_PATH || DEFAULT_METRICS_PATH;
 
 export const PROMETHEUS_PORT = getIntConfig('PROMETHEUS_PORT', DEFAULT_PROMETHEUS_PORT);
@@ -386,13 +386,13 @@ export const FEAT_UNISWAP_V2_PAIR_CREATED_EVENT = getBoolConfig(
 export const UNISWAP_V2_PAIR_CREATED_PROTOCOL_CONTRACT_ADDRESSES_AND_START_BLOCKS = process.env
     .UNISWAP_V2_PAIR_CREATED_PROTOCOL_CONTRACT_ADDRESSES_AND_START_BLOCKS
     ? process.env.UNISWAP_V2_PAIR_CREATED_PROTOCOL_CONTRACT_ADDRESSES_AND_START_BLOCKS.split(',').map((contract) => {
-        const [name, factoryAddress, startBlock] = contract.split(':');
-        return {
-            name,
-            factoryAddress,
-            startBlock: parseInt(startBlock),
-        };
-    })
+          const [name, factoryAddress, startBlock] = contract.split(':');
+          return {
+              name,
+              factoryAddress,
+              startBlock: parseInt(startBlock),
+          };
+      })
     : [];
 
 if (

diff --git a/src/data_sources/events/web3.ts b/src/data_sources/events/web3.ts
@@ -259,20 +259,34 @@ export class Web3Source {
             try {
                 logger.debug(`Fetching block ${blockNumber}`);
 
-                const block = (await this._web3Wrapper.getBlockIfExistsAsync(blockNumber)) as BlockWithoutTransactionData;
+                const block = (await this._web3Wrapper.getBlockIfExistsAsync(
+                    blockNumber,
+                )) as BlockWithoutTransactionData;
 
                 if (block == null) {
-                    logger.warn(`Block ${blockNumber} returned null, likely because the RPC node is not fully synced. Retrying... (${retryCount + 1}/${MAX_RPC_RETRY_CALLS})`);
+                    logger.warn(
+                        `Block ${blockNumber} returned null, likely because the RPC node is not fully synced. Retrying... (${
+                            retryCount + 1
+                        }/${MAX_RPC_RETRY_CALLS})`,
+                    );
                     retryCount++;
                     await new Promise((resolve) => setTimeout(resolve, 1000));
                     continue;
                 }
                 return block;
             } catch (err) {
                 if (err instanceof Error) {
-                    logger.error(`Error while fetching block ${blockNumber}: ${err.message}. Retrying... (${retryCount + 1}/${MAX_RPC_RETRY_CALLS})`);
+                    logger.error(
+                        `Error while fetching block ${blockNumber}: ${err.message}. Retrying... (${
+                            retryCount + 1
+                        }/${MAX_RPC_RETRY_CALLS})`,
+                    );
                 } else {
-                    logger.error(`Unknown error while fetching block ${blockNumber}. Retrying... (${retryCount + 1}/${MAX_RPC_RETRY_CALLS})`);
+                    logger.error(
+                        `Unknown error while fetching block ${blockNumber}. Retrying... (${
+                            retryCount + 1
+                        }/${MAX_RPC_RETRY_CALLS})`,
+                    );
                 }
                 retryCount++;
                 await new Promise((resolve) => setTimeout(resolve, 1000));