Rename directFlag variable

0xProject · Jun 28, 2023 · 587b296 · 587b296
1 parent df8995f
commit 587b296
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/src/events.ts b/src/events.ts
@@ -188,7 +188,7 @@ export const eventScrperProps: EventScraperProps[] = [
         contractAddress: 'nofilter',
         startBlock: UNISWAP_V3_VIP_SWAP_START_BLOCK,
         parser: parseUniswapV3VIPSwapEvent,
-        deleteOptions: { isDirectTrade: true, directProtocol: ['UniswapV3'] },
+        deleteOptions: { directFlag: true, directProtocol: ['UniswapV3'] },
         tokenMetadataMap: { tokenA: 'fromToken', tokenB: 'toToken' },
         callback: null,
     },
@@ -201,7 +201,7 @@ export const eventScrperProps: EventScraperProps[] = [
         contractAddress: FLASHWALLET_ADDRESS,
         startBlock: FLASHWALLET_DEPLOYMENT_BLOCK,
         parser: parseBridgeFill,
-        deleteOptions: { isDirectTrade: false },
+        deleteOptions: { directFlag: false },
         tokenMetadataMap: { tokenA: 'fromToken', tokenB: 'toToken' },
         callback: null,
     },
@@ -214,7 +214,7 @@ export const eventScrperProps: EventScraperProps[] = [
         contractAddress: 'nofilter',
         startBlock: UNISWAP_V2_VIP_SWAP_START_BLOCK,
         parser: parseUniswapV2SwapEvent,
-        deleteOptions: { isDirectTrade: true, directProtocol: UNISWAP_V2_VIP_SWAP_SOURCES },
+        deleteOptions: { directFlag: true, directProtocol: UNISWAP_V2_VIP_SWAP_SOURCES },
         tokenMetadataMap: { tokenA: 'fromToken', tokenB: 'toToken' },
         callback: null,
     },
@@ -227,7 +227,7 @@ export const eventScrperProps: EventScraperProps[] = [
         contractAddress: 'nofilter',
         startBlock: UNISWAP_V3_VIP_SWAP_START_BLOCK,
         parser: parseUniswapV3SwapEvent,
-        deleteOptions: { isDirectTrade: true, directProtocol: ['UniswapV3'] },
+        deleteOptions: { directFlag: true, directProtocol: ['UniswapV3'] },
         tokenMetadataMap: { tokenA: 'fromToken', tokenB: 'toToken' },
         callback: null,
     },

diff --git a/src/scripts/utils/event_abi_utils.ts b/src/scripts/utils/event_abi_utils.ts
@@ -292,11 +292,11 @@ export class PullAndSaveEventsByTopic {
 
         let deleteQuery = '';
         if (tableName === 'erc20_bridge_transfer_events') {
-            if (deleteOptions.isDirectTrade && deleteOptions.directProtocol != undefined) {
+            if (deleteOptions.directFlag && deleteOptions.directProtocol != undefined) {
                 deleteQuery = `DELETE FROM ${SCHEMA}.${tableName} WHERE block_number >= ${startBlock} AND block_number <= ${endBlock} AND direct_protocol IN ('${deleteOptions.directProtocol.join(
                     "','",
                 )}')`;
-            } else if (deleteOptions.isDirectTrade === false) {
+            } else if (deleteOptions.directFlag === false) {
                 deleteQuery = `DELETE FROM ${SCHEMA}.${tableName} WHERE block_number >= ${startBlock} AND block_number <= ${endBlock} AND direct_flag = FALSE`;
             }
         } else if (tableName === 'native_fills' && deleteOptions.protocolVersion != undefined) {

diff --git a/src/utils/kafka_send.ts b/src/utils/kafka_send.ts
@@ -8,7 +8,7 @@ export interface SchemaOptions {
 }
 
 export interface DeleteOptions {
-    isDirectTrade?: boolean;
+    directFlag?: boolean;
     directProtocol?: string[];
     protocolVersion?: string;
     nativeOrderType?: string;