config.ts

import {
    ScraperMode,
    DEFAULT_RESCRAPE_BLOCKS,
    DEFAULT_SCRAPER_MODE,
    DEFAULT_BASE_GITHUB_LOGO_URL,
    DEFAULT_BLOCKS_REORG_CHECK_INCREMENT,
    DEFAULT_BLOCK_FINALITY_THRESHOLD,
    DEFAULT_ENABLE_PROMETHEUS_METRICS,
    DEFAULT_EP_ADDRESS,
    DEFAULT_FEAT_CANCEL_EVENTS,
    DEFAULT_FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET,
    DEFAULT_FEAT_LIMIT_ORDERS,
    DEFAULT_FEAT_META_TRANSACTION_EXECUTED_EVENT,
    DEFAULT_FEAT_NFT,
    DEFAULT_FEAT_ONCHAIN_GOVERNANCE,
    DEFAULT_FEAT_OTC_ORDERS,
    DEFAULT_FEAT_PLP_SWAP_EVENT,
    DEFAULT_FEAT_POLYGON_RFQM_PAYMENTS,
    DEFAULT_FEAT_RFQ_EVENT,
    DEFAULT_FEAT_SOCKET_BRIDGE_EVENT,
    DEFAULT_FEAT_STAKING,
    DEFAULT_FEAT_TOKENS_FROM_TRANSFERS,
    DEFAULT_FEAT_TRANSFORMED_ERC20_EVENT,
    DEFAULT_FEAT_UNISWAP_V2_PAIR_CREATED_EVENT,
    DEFAULT_FEAT_UNISWAP_V2_SYNC_EVENT,
    DEFAULT_FEAT_UNISWAP_V2_VIP_SWAP_EVENT,
    DEFAULT_FEAT_UNISWAP_V3_POOL_CREATED_EVENT,
    DEFAULT_FEAT_UNISWAP_V3_SWAP_EVENT,
    DEFAULT_FEAT_UNISWAP_V3_VIP_SWAP_EVENT,
    DEFAULT_FEAT_V3_CANCEL_EVENTS,
    DEFAULT_FEAT_V3_FILL_EVENT,
    DEFAULT_FEAT_V3_NATIVE_FILL,
    DEFAULT_FEAT_WRAP_UNWRAP_NATIVE_EVENT,
    DEFAULT_FEAT_WRAP_UNWRAP_NATIVE_TRANSFER_EVENT,
    DEFAULT_LOCAL_POSTGRES_URI,
    DEFAULT_MAX_BLOCKS_REORG,
    DEFAULT_MAX_BLOCKS_TO_PULL,
    DEFAULT_MAX_BLOCKS_TO_SEARCH,
    DEFAULT_MAX_RPC_RETRY_CALLS,
    DEFAULT_MAX_TIME_TO_SEARCH,
    DEFAULT_MAX_TX_TO_PULL,
    DEFAULT_METRICS_PATH,
    DEFAULT_MINUTES_BETWEEN_RUNS,
    DEFAULT_PROMETHEUS_PORT,
    DEFAULT_STAKING_POOLS_JSON_URL,
    DEFAULT_STAKING_POOLS_METADATA_JSON_URL,
    DEFAULT_BLOCK_RECEIPTS_MODE,
    BLOCK_RECEIPTS_MODE_ENDPOINT,
    DEFAULT_FEAT_ERC20_TRANSFER_ALL,
    DEFAULT_FEAT_SETTLER_ERC721_TRANSFER_EVENT,
    DEFAULT_FEAT_SETTLER_RFQ_ORDER_EVENT,
    DEFAULT_FEAT_ZEROEX_EXCHANGE_PROXY,
} from './constants';
import { logger } from './utils';

const throwError = (err: string) => {
    throw new Error(err);
};

interface Map {
    [key: string]: { name: string };
}

const supportedChains: Map = {
    1: { name: 'Ethereum' },
    3: { name: 'Ropsten' },
    10: { name: 'Optimism' },
    56: { name: 'BSC' },
    137: { name: 'Polygon' },
    250: { name: 'Fantom' },
    8453: { name: 'Base' },
    42161: { name: 'Arbitrum' },
    43114: { name: 'Avalanche' },
    42220: { name: 'Celo' },
    59144: { name: 'Linea' },
    81457: { name: 'Blast' },
    534352: { name: 'Scroll' },
    34443: { name: 'Mode' },
    5000: { name: 'Mantle' },
    480: { name: 'Worldchain' },
};

interface BridgeContract {
    contract: string;
    startingBlock: number;
}

const bridgeContracts = [
    { contract: '0x1c29670f7a77f1052d30813a0a4f632c78a02610', startingBlock: 9613431 },
    { contract: '0x991c745401d5b5e469b8c3e2cb02c748f08754f1', startingBlock: 9613441 },
    { contract: '0x6dc7950423ada9f56fb2c93a23edb787f1e29088', startingBlock: 9613455 },
    { contract: '0x36691c4f426eb8f42f150ebde43069a31cb080ad', startingBlock: 9613448 },
    { contract: '0x2818363fb1686c2720b05c4e789165909cd03fc9', startingBlock: 9684028 },
    { contract: '0xc16f74b07e2409e869bae5de01b2265fe32d64e6', startingBlock: 9684280 },
    { contract: '0xd642305ed462cf2ad2a5f0310e30f66bcd1f0f0b', startingBlock: 9684143 },
    { contract: '0x7df9964cad51486eb16e6d3c9341d6eed73de69d', startingBlock: 9684978 },
];

// Parses an environment variable for bridge contracts
// Schema is
// <contractAddress>-<deployedBlockNumber>|<contractAddress>-<deployedBlockNumber>...
function bridgeEnvVarToObject(envVar: string): BridgeContract[] {
    const contracts = envVar.split('|');
    const bridgeContracts = contracts.map((element) => {
        const split = element.split('-');
        return { contract: split[0], startingBlock: Number(split[1]) };
    });
    return bridgeContracts;
}

export const EP_ADDRESS = process.env.EP_ADDRESS ? process.env.EP_ADDRESS : DEFAULT_EP_ADDRESS;

export const EVM_RPC_URL = process.env.EVM_RPC_URL
    ? process.env.EVM_RPC_URL
    : throwError(`Must specify valid EVM_RPC_URL. Got: ${process.env.EVM_RPC_URL}`);

export const FEAT_ZEROEX_EXCHANGE_PROXY = getBoolConfig(
    'FEAT_ZEROEX_EXCHANGE_PROXY',
    DEFAULT_FEAT_ZEROEX_EXCHANGE_PROXY,
);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_ZEROEX_EXCHANGE_PROXY', FEAT_ZEROEX_EXCHANGE_PROXY);

export const EP_DEPLOYMENT_BLOCK = getIntConfig('EP_DEPLOYMENT_BLOCK', -1);
validateStartBlock(
    'EP_DEPLOYMENT_BLOCK',
    EP_DEPLOYMENT_BLOCK,
    'FEAT_ZEROEX_EXCHANGE_PROXY',
    FEAT_ZEROEX_EXCHANGE_PROXY,
);

export const SETTLER_DEPLOYMENT_BLOCK = process.env.SETTLER_DEPLOYMENT_BLOCK
    ? parseInt(process.env.SETTLER_DEPLOYMENT_BLOCK, 10)
    : throwError(`Must specify valid SETTLER_DEPLOYMENT_BLOCK. Got: ${process.env.SETTLER_DEPLOYMENT_BLOCK}`);

export const SCHEMA = process.env.SCHEMA
    ? process.env.SCHEMA
    : throwError(`Must specify valid SCHEMA. Got: ${process.env.SCHEMA}`);

export const POSTGRES_URI = process.env.POSTGRES_URI || DEFAULT_LOCAL_POSTGRES_URI;

export const SHOULD_SYNCHRONIZE = process.env.SHOULD_SYNCHRONIZE === 'true';

export const ENABLE_PROMETHEUS_METRICS = getBoolConfig('ENABLE_PROMETHEUS_METRICS', DEFAULT_ENABLE_PROMETHEUS_METRICS);
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');
export const METRICS_PATH = process.env.METRICS_PATH || DEFAULT_METRICS_PATH;

export const PROMETHEUS_PORT = getIntConfig('PROMETHEUS_PORT', DEFAULT_PROMETHEUS_PORT);

export const MAX_BLOCKS_REORG = getIntConfig('MAX_BLOCKS_REORG', DEFAULT_MAX_BLOCKS_REORG);

export const MAX_BLOCKS_TO_PULL = getIntConfig('MAX_BLOCKS_TO_PULL', DEFAULT_MAX_BLOCKS_TO_PULL);

export const MAX_BLOCKS_TO_SEARCH = getIntConfig('MAX_BLOCKS_TO_SEARCH', DEFAULT_MAX_BLOCKS_TO_SEARCH);

export const MAX_TX_TO_PULL = getIntConfig('MAX_TX_TO_PULL', DEFAULT_MAX_TX_TO_PULL);

export const MAX_RPC_RETRY_CALLS = getIntConfig('MAX_RPC_RETRY_CALLS', DEFAULT_MAX_RPC_RETRY_CALLS);

export const CHAIN_ID = process.env.CHAIN_ID
    ? parseInt(process.env.CHAIN_ID, 10)
    : throwError(`Must specify valid CHAIN_ID. Got: ${process.env.CHAIN_ID}`);
if (!Object.keys(supportedChains).map(Number).includes(CHAIN_ID)) {
    throwError(`Chain ID ${CHAIN_ID} is not supported. Please choose a valid Chain ID: ${supportedChains}`);
}

export const CHAIN_NAME = supportedChains[CHAIN_ID].name;
export const CHAIN_NAME_LOWER = supportedChains[CHAIN_ID].name.toLowerCase();

export const BLOCK_FINALITY_THRESHOLD = getIntConfig('BLOCK_FINALITY_THRESHOLD', DEFAULT_BLOCK_FINALITY_THRESHOLD);

export let MINUTES_BETWEEN_RUNS = getIntConfig('MINUTES_BETWEEN_RUNS', DEFAULT_MINUTES_BETWEEN_RUNS);
export const SECONDS_BETWEEN_RUNS = getIntConfig('SECONDS_BETWEEN_RUNS', 60);
if (SECONDS_BETWEEN_RUNS !== 60) {
    if (Object.prototype.hasOwnProperty.call(process.env, 'MINUTES_BETWEEN_RUNS')) {
        throwError(`MINUTES_BETWEEN_RUNS and SECONDS_BETWEEN_RUNS are mutually exclusive, use only one`);
    } else {
        MINUTES_BETWEEN_RUNS = 1;
    }
}

export const STAKING_POOLS_JSON_URL = process.env.STAKING_POOLS_JSON_URL || DEFAULT_STAKING_POOLS_JSON_URL;

export const STAKING_POOLS_METADATA_JSON_URL =
    process.env.STAKING_POOLS_METADATA_JSON_URL || DEFAULT_STAKING_POOLS_METADATA_JSON_URL;

export const BASE_GITHUB_LOGO_URL = process.env.BASE_GITHUB_LOGO_URL || DEFAULT_BASE_GITHUB_LOGO_URL;

export const BRIDGE_CONTRACTS = process.env.BRIDGE_CONTRACTS
    ? bridgeEnvVarToObject(String(process.env.BRIDGE_CONTRACTS))
    : bridgeContracts;

export const MAX_TIME_TO_SEARCH = getIntConfig('MAX_TIME_TO_SEARCH', DEFAULT_MAX_TIME_TO_SEARCH);

export const FEAT_CANCEL_EVENTS = getBoolConfig('FEAT_CANCEL_EVENTS', DEFAULT_FEAT_CANCEL_EVENTS);

export const FEAT_STAKING = getBoolConfig('FEAT_STAKING', DEFAULT_FEAT_STAKING);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_STAKING', FEAT_STAKING);
export const STAKING_DEPLOYMENT_BLOCK = getIntConfig('STAKING_DEPLOYMENT_BLOCK', -1);
validateStartBlock('STAKING_DEPLOYMENT_BLOCK', STAKING_DEPLOYMENT_BLOCK, 'FEAT_STAKING', FEAT_STAKING);

/*
 * Staking is paused for now, and this scraper only scans a specific tx, so it it requires manually changing STAKING_PROXY_DEPLOYMENT_TRANSACTION when there is a new deployment
 *
export const STAKING_PROXY_DEPLOYMENT_TRANSACTION = process.env.STAKING_PROXY_DEPLOYMENT_TRANSACTION
    ? process.env.STAKING_PROXY_DEPLOYMENT_TRANSACTION
    : null;
if (STAKING_PROXY_DEPLOYMENT_TRANSACTION === null && FEAT_STAKING) {
    throwError(
        `The Staking scraper is enabled, but no STAKING_PROXY_DEPLOYMENT_TRANSACTION was provided. Please include STAKING_PROXY_DEPLOYMENT_TRANSACTION or disable the feature`,
    );
}
*/

export const FIRST_SEARCH_BLOCK = Math.min(
    SETTLER_DEPLOYMENT_BLOCK,
    EP_DEPLOYMENT_BLOCK === -1 ? Infinity : EP_DEPLOYMENT_BLOCK,
    STAKING_DEPLOYMENT_BLOCK === -1 ? Infinity : STAKING_DEPLOYMENT_BLOCK,
);

export const FEAT_TRANSFORMED_ERC20_EVENT = getBoolConfig(
    'FEAT_TRANSFORMED_ERC20_EVENT',
    DEFAULT_FEAT_TRANSFORMED_ERC20_EVENT,
);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_TRANSFORMED_ERC20_EVENT', FEAT_TRANSFORMED_ERC20_EVENT);

export const FEAT_UNISWAP_V2_VIP_SWAP_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V2_VIP_SWAP_EVENT',
    DEFAULT_FEAT_UNISWAP_V2_VIP_SWAP_EVENT,
);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_UNISWAP_V2_VIP_SWAP_EVENT', FEAT_UNISWAP_V2_VIP_SWAP_EVENT);

export const UNISWAP_V2_VIP_SWAP_SOURCES = process.env.UNISWAP_V2_VIP_SWAP_SOURCES
    ? process.env.UNISWAP_V2_VIP_SWAP_SOURCES.split(',')
    : undefined;
if (UNISWAP_V2_VIP_SWAP_SOURCES === undefined && FEAT_UNISWAP_V2_VIP_SWAP_EVENT) {
    throwError(
        `The Uniswap VIP Swap Event scraper is enabled, but no UNISWAP_V2_VIP_SWAP_SOURCES was provided. Please include a comma separated list of the enabled VIP sources in this chain or disable the feature`,
    );
}

export const UNISWAP_V2_VIP_SWAP_START_BLOCK = getIntConfig('UNISWAP_V2_VIP_SWAP_START_BLOCK', EP_DEPLOYMENT_BLOCK);

export const FEAT_RFQ_EVENT = getBoolConfig('FEAT_RFQ_EVENT', DEFAULT_FEAT_RFQ_EVENT);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_RFQ_EVENT', FEAT_RFQ_EVENT);

export const FEAT_LIMIT_ORDERS = getBoolConfig('FEAT_LIMIT_ORDERS', DEFAULT_FEAT_LIMIT_ORDERS);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_LIMIT_ORDERS', FEAT_LIMIT_ORDERS);

export const V4_NATIVE_FILL_START_BLOCK = getIntConfig('V4_NATIVE_FILL_START_BLOCK', -1);
validateStartBlock('V4_NATIVE_FILL_START_BLOCK', V4_NATIVE_FILL_START_BLOCK, 'FEAT_RFQ_EVENT', FEAT_RFQ_EVENT);
validateStartBlock('V4_NATIVE_FILL_START_BLOCK', V4_NATIVE_FILL_START_BLOCK, 'FEAT_LIMIT_ORDERS', FEAT_LIMIT_ORDERS);

export const FEAT_PLP_SWAP_EVENT = getBoolConfig('FEAT_PLP_SWAP_EVENT', DEFAULT_FEAT_PLP_SWAP_EVENT);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_PLP_SWAP_EVENT', FEAT_PLP_SWAP_EVENT);

export const PLP_VIP_START_BLOCK = getIntConfig('PLP_VIP_START_BLOCK', -1);
validateStartBlock('PLP_VIP_START_BLOCK', PLP_VIP_START_BLOCK, 'FEAT_PLP_SWAP_EVENT', FEAT_PLP_SWAP_EVENT);

export const FEAT_V3_NATIVE_FILL = getBoolConfig('FEAT_V3_NATIVE_FILL', DEFAULT_FEAT_V3_NATIVE_FILL);

export const FEAT_UNISWAP_V3_VIP_SWAP_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V3_VIP_SWAP_EVENT',
    DEFAULT_FEAT_UNISWAP_V3_VIP_SWAP_EVENT,
);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_UNISWAP_V3_VIP_SWAP_EVENT', FEAT_UNISWAP_V3_VIP_SWAP_EVENT);

export const UNISWAP_V3_VIP_SWAP_START_BLOCK = getIntConfig('UNISWAP_V3_VIP_SWAP_START_BLOCK', -1);
validateStartBlock(
    'UNISWAP_V3_VIP_SWAP_START_BLOCK',
    UNISWAP_V3_VIP_SWAP_START_BLOCK,
    'FEAT_UNISWAP_V3_VIP_SWAP_EVENT',
    FEAT_UNISWAP_V3_VIP_SWAP_EVENT,
);

export const FEAT_UNISWAP_V3_SWAP_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V3_SWAP_EVENT',
    DEFAULT_FEAT_UNISWAP_V3_SWAP_EVENT,
);

export const UNISWAP_V3_SWAP_START_BLOCK = getIntConfig('UNISWAP_V3_VIP_SWAP_START_BLOCK', -1);
validateStartBlock(
    'UNISWAP_V3_SWAP_START_BLOCK',
    UNISWAP_V3_SWAP_START_BLOCK,
    'FEAT_UNISWAP_V3_VIP_SWAP_EVENT',
    FEAT_UNISWAP_V3_VIP_SWAP_EVENT,
);

export const FEAT_UNISWAP_V3_POOL_CREATED_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V3_POOL_CREATED_EVENT',
    DEFAULT_FEAT_UNISWAP_V3_POOL_CREATED_EVENT,
);

export const UNISWAP_V3_POOL_CREATED_START_BLOCK = getIntConfig('UNISWAP_V3_POOL_CREATED_START_BLOCK', -1);
validateStartBlock(
    'UNISWAP_V3_POOL_CREATED_START_BLOCK',
    UNISWAP_V3_POOL_CREATED_START_BLOCK,
    'FEAT_UNISWAP_V3_POOL_CREATED_EVENT',
    FEAT_UNISWAP_V3_POOL_CREATED_EVENT,
);

export const UNISWAP_V3_FACTORY_ADDRESS = process.env.UNISWAP_V3_FACTORY_ADDRESS || '';
validateAddress(
    'UNISWAP_V3_FACTORY_ADDRESS',
    UNISWAP_V3_FACTORY_ADDRESS,
    'UNISWAP_V3_POOL_CREATED_EVENT',
    FEAT_UNISWAP_V3_POOL_CREATED_EVENT,
);

export const FEAT_V3_FILL_EVENT = getBoolConfig('FEAT_V3_FILL_EVENT', DEFAULT_FEAT_V3_FILL_EVENT);
export const FEAT_V3_CANCEL_EVENTS = getBoolConfig('FEAT_V3_CANCEL_EVENTS', DEFAULT_FEAT_V3_CANCEL_EVENTS);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_V3_CANCEL_EVENTS', FEAT_V3_CANCEL_EVENTS);

export const FEAT_OTC_ORDERS = getBoolConfig('FEAT_OTC_ORDERS', DEFAULT_FEAT_OTC_ORDERS);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_OTC_ORDERS', FEAT_OTC_ORDERS);

export const OTC_ORDERS_FEATURE_START_BLOCK = getIntConfig('OTC_ORDERS_FEATURE_START_BLOCK', -1);
validateStartBlock(
    'OTC_ORDERS_FEATURE_START_BLOCK',
    OTC_ORDERS_FEATURE_START_BLOCK,
    'FEAT_OTC_ORDERS',
    FEAT_OTC_ORDERS,
);

export const FEAT_NFT = getBoolConfig('FEAT_NFT', DEFAULT_FEAT_NFT);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_NFT', FEAT_NFT);

export const NFT_FEATURE_START_BLOCK = getIntConfig('NFT_FEATURE_START_BLOCK', -1);
validateStartBlock('NFT_FEATURE_START_BLOCK', NFT_FEATURE_START_BLOCK, 'FEAT_NFT', FEAT_NFT);

export const FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET = getBoolConfig(
    'FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET',
    DEFAULT_FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET,
);
validateAddress(
    'EP_ADDRESS',
    EP_ADDRESS,
    'FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET',
    FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET,
);

export const FLASHWALLET_ADDRESS = process.env.FLASHWALLET_ADDRESS || '';
validateAddress(
    'FLASHWALLET_ADDRESS',
    FLASHWALLET_ADDRESS,
    'FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET',
    FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET,
);

export const FLASHWALLET_DEPLOYMENT_BLOCK = getIntConfig('FLASHWALLET_DEPLOYMENT_BLOCK', -1);
validateStartBlock(
    'FLASHWALLET_DEPLOYMENT_BLOCK',
    FLASHWALLET_DEPLOYMENT_BLOCK,
    'FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET',
    FEAT_ERC20_BRIDGE_TRANSFER_FLASHWALLET,
);

export const FEAT_POLYGON_RFQM_PAYMENTS = getBoolConfig(
    'FEAT_POLYGON_RFQM_PAYMENTS',
    DEFAULT_FEAT_POLYGON_RFQM_PAYMENTS,
);

export const POLYGON_RFQM_PAYMENTS_START_BLOCK = getIntConfig('POLYGON_RFQM_PAYMENTS_START_BLOCK', -1);
validateStartBlock(
    'POLYGON_RFQM_PAYMENTS_START_BLOCK',
    POLYGON_RFQM_PAYMENTS_START_BLOCK,
    'FEAT_POLYGON_RFQM_PAYMENTS',
    FEAT_POLYGON_RFQM_PAYMENTS,
);

export const POLYGON_RFQM_PAYMENTS_ADDRESSES = process.env.POLYGON_RFQM_PAYMENTS_ADDRESSES
    ? process.env.POLYGON_RFQM_PAYMENTS_ADDRESSES.split(',')
    : [];
if (FEAT_POLYGON_RFQM_PAYMENTS && POLYGON_RFQM_PAYMENTS_ADDRESSES.length === 0) {
    throwError(`FEAT_POLYGON_RFQM_PAYMENTS is enabled, but no POLYGON_RFQM_PAYMENTS_ADDRESS was provided`);
}

export const FEAT_UNISWAP_V2_PAIR_CREATED_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V2_PAIR_CREATED_EVENT',
    DEFAULT_FEAT_UNISWAP_V2_PAIR_CREATED_EVENT,
);

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),
          };
      })
    : [];

if (
    FEAT_UNISWAP_V2_PAIR_CREATED_EVENT &&
    UNISWAP_V2_PAIR_CREATED_PROTOCOL_CONTRACT_ADDRESSES_AND_START_BLOCKS.length === 0
) {
    throwError(
        `FEAT_UNISWAP_V2_PAIR_CREATED_EVENT is enabled, but no UNISWAP_V2_PAIR_CREATED_CONTRACT_ADDRESSES_AND_START_BLOCKS was provided`,
    );
}

export const FEAT_UNISWAP_V2_SYNC_EVENT = getBoolConfig(
    'FEAT_UNISWAP_V2_SYNC_EVENT',
    DEFAULT_FEAT_UNISWAP_V2_SYNC_EVENT,
);

export const UNISWAP_V2_SYNC_START_BLOCK = getIntConfig('UNISWAP_V2_SYNC_START_BLOCK', -1);
validateStartBlock(
    'UNISWAP_V2_SYNC_START_BLOCK',
    UNISWAP_V2_SYNC_START_BLOCK,
    'FEAT_UNISWAP_V2_SYNC_EVENT',
    FEAT_UNISWAP_V2_SYNC_EVENT,
);

export const FEAT_TOKENS_FROM_TRANSFERS = getBoolConfig(
    'FEAT_TOKENS_FROM_TRANSFERS',
    DEFAULT_FEAT_TOKENS_FROM_TRANSFERS,
);

export const TOKENS_FROM_TRANSFERS_START_BLOCK = getIntConfig('TOKENS_FROM_TRANSFERS_START_BLOCK', -1);

validateStartBlock(
    'TOKENS_FROM_TRANSFERS_START_BLOCK',
    TOKENS_FROM_TRANSFERS_START_BLOCK,
    "FEAT_TOKENS_FROM_TRANSFERS && SCRAPER_MODE !== 'BLOCKS'",
    FEAT_TOKENS_FROM_TRANSFERS && SCRAPER_MODE !== 'BLOCKS',
);

export const FEAT_META_TRANSACTION_EXECUTED_EVENT = getBoolConfig(
    'FEAT_META_TRANSACTION_EXECUTED_EVENT',
    DEFAULT_FEAT_META_TRANSACTION_EXECUTED_EVENT,
);
validateAddress('EP_ADDRESS', EP_ADDRESS, 'FEAT_META_TRANSACTION_EXECUTED_EVENT', FEAT_META_TRANSACTION_EXECUTED_EVENT);

export const META_TRANSACTION_EXECUTED_START_BLOCK = getIntConfig('META_TRANSACTION_EXECUTED_START_BLOCK', -1);

validateStartBlock(
    'META_TRANSACTION_EXECUTED_START_BLOCK',
    META_TRANSACTION_EXECUTED_START_BLOCK,
    'FEAT_META_TRANSACTION_EXECUTED_EVENT',
    FEAT_META_TRANSACTION_EXECUTED_EVENT,
);

export const FEAT_ONCHAIN_GOVERNANCE = getBoolConfig('FEAT_ONCHAIN_GOVERNANCE', DEFAULT_FEAT_ONCHAIN_GOVERNANCE);

export const ONCHAIN_GOVERNANCE_START_BLOCK = getIntConfig('ONCHAIN_GOVERNANCE_START_BLOCK', -1);

validateStartBlock(
    'ONCHAIN_GOVERNANCE_START_BLOCK',
    ONCHAIN_GOVERNANCE_START_BLOCK,
    'FEAT_ONCHAIN_GOVERNANCE',
    FEAT_ONCHAIN_GOVERNANCE,
);

export const FEAT_WRAP_UNWRAP_NATIVE_EVENT = getBoolConfig(
    'FEAT_WRAP_UNWRAP_NATIVE_EVENT',
    DEFAULT_FEAT_WRAP_UNWRAP_NATIVE_EVENT,
);

export const FEAT_WRAP_UNWRAP_NATIVE_TRANSFER_EVENT = getBoolConfig(
    'FEAT_WRAP_UNWRAP_NATIVE_TRANSFER_EVENT',
    DEFAULT_FEAT_WRAP_UNWRAP_NATIVE_TRANSFER_EVENT,
);

export const WRAP_UNWRAP_NATIVE_START_BLOCK = FIRST_SEARCH_BLOCK;

export const WRAP_UNWRAP_NATIVE_CONTRACT_ADDRESS = process.env.WRAP_UNWRAP_NATIVE_CONTRACT_ADDRESS || '';
validateAddress(
    'WRAP_UNWRAP_NATIVE_CONTRACT_ADDRESS',
    WRAP_UNWRAP_NATIVE_CONTRACT_ADDRESS,
    'FEAT_WRAP_UNWRAP_NATIVE_EVENT',
    FEAT_WRAP_UNWRAP_NATIVE_EVENT,
);

export const KAFKA_BROKERS = process.env.KAFKA_BROKERS ? process.env.KAFKA_BROKERS.split(',') : [];
if (KAFKA_BROKERS.length === 0) {
    logger.warn('KAFKA_BROKERS is empty, disabling kafka');
}
export const KAFKA_AUTH_USER = process.env.KAFKA_AUTH_USER!;
export const KAFKA_AUTH_PASSWORD = process.env.KAFKA_AUTH_PASSWORD!;
export const KAFKA_SSL = getBoolConfig('KAFKA_SSL', false);

export const FEAT_SOCKET_BRIDGE_EVENT = getBoolConfig('FEAT_SOCKET_BRIDGE_EVENT', DEFAULT_FEAT_SOCKET_BRIDGE_EVENT);

export const SOCKET_BRIDGE_CONTRACT_ADDRESS = process.env.SOCKET_BRIDGE_CONTRACT_ADDRESS || '';
validateAddress(
    'SOCKET_BRIDGE_CONTRACT_ADDRESS',
    SOCKET_BRIDGE_CONTRACT_ADDRESS,
    'FEAT_SOCKET_BRIDGE_EVENT',
    FEAT_SOCKET_BRIDGE_EVENT,
);

export const BLOCK_RECEIPTS_MODE = process.env.BLOCK_RECEIPTS_MODE || DEFAULT_BLOCK_RECEIPTS_MODE;
if (!BLOCK_RECEIPTS_MODE_ENDPOINT.has(BLOCK_RECEIPTS_MODE)) {
    throwError(`Got invalid BLOCK_RECEIPTS_MODE, options are: ${BLOCK_RECEIPTS_MODE_ENDPOINT.keys()}`);
}

export const SOCKET_BRIDGE_EVENT_START_BLOCK = getIntConfig('SOCKET_BRIDGE_EVENT_START_BLOCK', -1);
validateStartBlock(
    'SOCKET_BRIDGE_EVENT_START_BLOCK',
    SOCKET_BRIDGE_EVENT_START_BLOCK,
    'FEAT_SOCKET_BRIDGE_EVENT',
    FEAT_SOCKET_BRIDGE_EVENT,
);

export const RESCRAPE_BLOCKS = getIntConfig('RESCRAPE_BLOCKS', DEFAULT_RESCRAPE_BLOCKS);

export const BLOCKS_REORG_CHECK_INCREMENT = getIntConfig(
    'BLOCKS_REORG_CHECK_INCREMENT',
    DEFAULT_BLOCKS_REORG_CHECK_INCREMENT,
);

export const FEAT_ERC20_TRANSFER_ALL = getBoolConfig('FEAT_ERC20_TRANSFER_ALL', DEFAULT_FEAT_ERC20_TRANSFER_ALL);

export const FEAT_SETTLER_ERC721_TRANSFER_EVENT = getBoolConfig(
    'FEAT_SETTLER_ERC721_TRANSFER_EVENT',
    DEFAULT_FEAT_SETTLER_ERC721_TRANSFER_EVENT,
);

export const FEAT_SETTLER_RFQ_ORDER_EVENT = getBoolConfig(
    'FEAT_SETTLER_RFQ_ORDER_EVENT',
    DEFAULT_FEAT_SETTLER_RFQ_ORDER_EVENT,
);

function getBoolConfig(env: string, defaultValue: boolean): boolean {
    if (Object.prototype.hasOwnProperty.call(process.env, env)) {
        return process.env[env] === 'true';
    }
    return defaultValue;
}

function getIntConfig(env: string, defaultValue: number): number {
    if (Object.prototype.hasOwnProperty.call(process.env, env)) {
        // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
        return parseInt(process.env[env]!);
    }
    return defaultValue;
}

function validateStartBlock(startBlockVar: string, startBlock: number, featureFlagVar: string, featureFlag: boolean) {
    if (startBlock === -1 && featureFlag) {
        throwError(
            `${featureFlagVar} is enabled but ${startBlockVar} is not set. Please set ${startBlockVar} or disable the feature`,
        );
    }
}

function validateAddress(addressVar: string, address: string, featureFlagVar: string, featureFlag: boolean) {
    if (address === '' && featureFlag) {
        throwError(
            `${featureFlagVar} is enabled but ${addressVar} is not set. Please set ${addressVar} or disable the feature`,
        );
    }
}