19732484228

Committed 27 Nov 2025 10:03AM UTC coverage: 90.137% (-0.04%) from 90.176%

Build # 19732484228

Build Type

push

github

Committed by

web-flow

Commit Message

feat(portfolio): add X-Env testnet header for Zerion API requests (#2806)

* feat(portfolio): add X-Env testnet header for Zerion API requests

Add support for Zerion's testnet API by including the `X-Env: testnet`
header when querying testnet chains. The header is automatically applied
based on the chain's `isTestnet` property.

Changes:
- Update zerion-balances-api.service to use chain.isTestnet
- Update zerion-positions-api.service to use chain.isTestnet
- Update zerion-portfolio-api.service with isTestnet parameter
- Infer isTestnet from chainIds in portfolio API service
- Add separate cache entries for testnet vs mainnet portfolio data

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

* test(balances): add unit tests for getZerionHeaders helper

Add comprehensive tests for the Zerion API headers helper function
covering mainnet/testnet scenarios and undefined apiKey edge cases.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

* refactor(cache): simplify getZerionChainsCacheDir parameter

Use plain boolean parameter instead of object wrapper since there's only
one parameter. Addresses PR review feedback.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

---------

Co-authored-by: Claude <noreply@anthropic.com>

Run Details

2858 of 3551 branches covered (80.48%)

Branch coverage included in aggregate %.

21 of 34 new or added lines in 7 files covered. (61.76%)

3 existing lines in 2 files now uncovered.

13829 of 14962 relevant lines covered (92.43%)

619.78 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

94.44

/src/datasources/cache/cache.router.ts

import crypto from 'crypto';
import { CacheDir } from '@/datasources/cache/entities/cache-dir.entity';
import type { Address, Hash } from 'viem';
import type { TransactionInfo } from '@/modules/transactions/routes/entities/transaction-info.entity';

export class CacheRouter {
  private static readonly ACCOUNT_DATA_SETTINGS_KEY = 'account_data_settings';
  private static readonly ACCOUNT_DATA_TYPES_KEY = 'account_data_types';
  private static readonly ACCOUNT_KEY = 'account';
  private static readonly ALL_TRANSACTIONS_KEY = 'all_transactions';
  private static readonly AUTH_NONCE_KEY = 'auth_nonce';
  private static readonly BACKBONE_KEY = 'backbone';
  private static readonly BRIDGE_CHAINS_KEY = 'bridge_chains';
  private static readonly CHAIN_KEY = 'chain';
  private static readonly CHAINS_KEY = 'chains';
  private static readonly CONTRACTS_KEY = 'contracts';
  private static readonly COUNTERFACTUAL_SAFE_KEY = 'counterfactual_safe';
  private static readonly COUNTERFACTUAL_SAFES_KEY = 'counterfactual_safes';
  private static readonly CREATION_TRANSACTION_KEY = 'creation_transaction';
  private static readonly DECODED_DATA_KEY = 'decoded_data';
  private static readonly DELEGATES_KEY = 'delegates';
  private static readonly FIREBASE_OAUTH2_TOKEN_KEY = 'firebase_oauth2_token';
  private static readonly INCOMING_TRANSFERS_KEY = 'incoming_transfers';
  private static readonly INDEXING_KEY = 'indexing';
  private static readonly MESSAGE_KEY = 'message';
  private static readonly MESSAGES_KEY = 'messages';
  private static readonly MODULE_TRANSACTION_KEY = 'module_transaction';
  private static readonly MODULE_TRANSACTIONS_KEY = 'module_transactions';
  private static readonly MULTISIG_TRANSACTION_KEY = 'multisig_transaction';
  private static readonly MULTISIG_TRANSACTIONS_KEY = 'multisig_transactions';
  private static readonly NATIVE_COIN_PRICE_KEY = 'native_coin_price';
  private static readonly OWNERS_SAFE_KEY = 'owner_safes';
  private static readonly RATE_LIMIT_KEY = 'rate_limit';
  private static readonly RELAY_KEY = 'relay';
  private static readonly RPC_REQUESTS_KEY = 'rpc_requests';
  private static readonly SAFE_APPS_KEY = 'safe_apps';
  private static readonly SAFE_BALANCES_KEY = 'safe_balances';
  private static readonly SAFE_COLLECTIBLES_KEY = 'safe_collectibles';
  private static readonly SAFE_EXISTS_KEY = 'safe_exists';
  private static readonly SAFE_FIAT_CODES_KEY = 'safe_fiat_codes';
  private static readonly SAFE_KEY = 'safe';
  private static readonly SINGLETONS_KEY = 'singletons';
  private static readonly STAKING_DEDICATED_STAKING_STATS_KEY =
    'staking_dedicated_staking_stats';
  private static readonly STAKING_DEFI_VAULT_STATS_KEY =
    'staking_defi_vault_stats';
  private static readonly STAKING_DEFI_VAULT_STAKES_KEY =
    'staking_defi_vault_stakes';
  private static readonly STAKING_DEFI_MORPHO_EXTRA_REWARDS_KEY =
    'staking_defi_morpho_extra_rewards';
  private static readonly STAKING_DEPLOYMENTS_KEY = 'staking_deployments';
  private static readonly STAKING_REWARDS_FEE_KEY = 'staking_rewards_fee';
  private static readonly STAKING_NETWORK_STATS_KEY = 'staking_network_stats';
  private static readonly STAKING_POOLED_STAKING_STATS_KEY =
    'staking_pooled_staking_stats';
  private static readonly STAKING_STAKES_KEY = 'staking_stakes';
  private static readonly STAKING_TRANSACTION_STATUS_KEY =
    'staking_transaction_status';
  private static readonly TARGETED_MESSAGING_OUTREACHES =
    'targeted_messaging_outreaches';
  private static readonly TARGETED_MESSAGING_OUTREACH_FILE_PROCESSOR_LOCK =
    'targeted_messaging_outreach_file_processor_lock';
  private static readonly TARGETED_MESSAGING_SUBMISSION_KEY =
    'targeted_messaging_submission';
  private static readonly TARGETED_MESSAGING_TARGETED_SAFE_KEY =
    'targeted_messaging_targeted_safe';
  private static readonly TOKEN_KEY = 'token';
  private static readonly TOKEN_PRICE_KEY = 'token_price';
  private static readonly TOKENS_KEY = 'tokens';
  private static readonly TRANSFER_KEY = 'transfer';
  private static readonly TRANSFERS_KEY = 'transfers';
  private static readonly TRUSTED_FOR_DELEGATE_CALL_CONTRACTS_KEY =
    'trusted_contracts';
  private static readonly UNSUPPORTED_CHAIN_EVENT = 'unsupported_chain_event';
  private static readonly ZERION_BALANCES_KEY = 'zerion_balances';
  private static readonly ZERION_COLLECTIBLES_KEY = 'zerion_collectibles';
  private static readonly ZERION_POSITIONS_KEY = 'zerion_positions';
  private static readonly ZERION_CHAINS_KEY = 'zerion_chains';
  private static readonly PORTFOLIO_KEY = 'portfolio';
  private static readonly ORM_QUERY_CACHE_KEY = 'orm_query_cache';
  private static readonly TRANSACTIONS_EXPORT_KEY = 'transactions_export';
  private static readonly CONTRACT_ANALYSIS_KEY = 'contract_analysis';
  private static readonly RECIPIENT_ANALYSIS_KEY = 'recipient_analysis';

  static getAuthNonceCacheKey(nonce: string): string {
    return `${CacheRouter.AUTH_NONCE_KEY}_${nonce}`;
  }

  static getAuthNonceCacheDir(nonce: string): CacheDir {
    return new CacheDir(CacheRouter.getAuthNonceCacheKey(nonce), '');
  }

  static getBridgeChainsCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.BRIDGE_CHAINS_KEY, '');
  }

  static getBalancesCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.SAFE_BALANCES_KEY}_${args.safeAddress}`;
  }

  static getBalancesCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    trusted?: boolean;
    excludeSpam?: boolean;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getBalancesCacheKey(args),
      `${args.trusted}_${args.excludeSpam}`,
    );
  }

  static getZerionBalancesCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.ZERION_BALANCES_KEY}_${args.safeAddress}`;
  }

  static getZerionBalancesCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    fiatCode: string;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getZerionBalancesCacheKey(args),
      args.fiatCode.toUpperCase(),
    );
  }

  static getZerionCollectiblesCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.ZERION_COLLECTIBLES_KEY}_${args.safeAddress}`;
  }

  static getZerionCollectiblesCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getZerionCollectiblesCacheKey(args),
      `${args.limit}_${args.offset}`,
    );
  }

  static getZerionPositionsCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.ZERION_POSITIONS_KEY}_${args.safeAddress}`;
  }

  static getZerionPositionsCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    fiatCode: string;
    refresh?: string;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getZerionPositionsCacheKey(args),
      `${args.fiatCode.toUpperCase()}_${args.refresh ?? ''}`,
    );
  }

  static getRateLimitCacheKey(prefix: string): string {
    return `${prefix}_${CacheRouter.RATE_LIMIT_KEY}`;
  }

  static getSafeCacheDir(args: {
    chainId: string;
    safeAddress: Address;
  }): CacheDir {
    return new CacheDir(CacheRouter.getSafeCacheKey(args), '');
  }

  static getSafeCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.SAFE_KEY}_${args.safeAddress}`;
  }

  static getIsSafeCacheDir(args: {
    chainId: string;
    safeAddress: Address;
  }): CacheDir {
    return new CacheDir(CacheRouter.getIsSafeCacheKey(args), '');
  }

  static getIsSafeCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.SAFE_EXISTS_KEY}_${args.safeAddress}`;
  }

  static getBackboneCacheDir(chainId: string): CacheDir {
    return new CacheDir(`${chainId}_${CacheRouter.BACKBONE_KEY}`, '');
  }

  static getSingletonsCacheDir(chainId: string): CacheDir {
    return new CacheDir(`${chainId}_${CacheRouter.SINGLETONS_KEY}`, '');
  }

  static getCollectiblesCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    limit?: number;
    offset?: number;
    trusted?: boolean;
    excludeSpam?: boolean;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getCollectiblesKey(args),
      `${args.limit}_${args.offset}_${args.trusted}_${args.excludeSpam}`,
    );
  }

  static getCollectiblesKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.SAFE_COLLECTIBLES_KEY}_${args.safeAddress}`;
  }

  static getDelegatesCacheKey(args: {
    chainId: string;
    safeAddress?: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.DELEGATES_KEY}_${args.safeAddress}`;
  }

  static getDelegatesCacheDir(args: {
    chainId: string;
    safeAddress?: Address;
    delegate?: Address;
    delegator?: Address;
    label?: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getDelegatesCacheKey(args),
      `${args.delegate}_${args.delegator}_${args.label}_${args.limit}_${args.offset}`,
    );
  }

  static getFirebaseOAuth2TokenCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.FIREBASE_OAUTH2_TOKEN_KEY, '');
  }

  static getTransferCacheDir(args: {
    chainId: string;
    transferId: string;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.TRANSFER_KEY}_${args.transferId}`,
      '',
    );
  }

  static getTransfersCacheDir(args: {
    chainId: string;
    safeAddress: string;
    onlyErc20: boolean;
    onlyErc721: boolean;
    limit?: number;
    offset?: number;
    to?: string;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getTransfersCacheKey(args),
      `${args.onlyErc20}_${args.onlyErc721}_${args.limit}_${args.offset}_${args.to}`,
    );
  }

  static getTransfersCacheKey(args: {
    chainId: string;
    safeAddress: string;
  }): string {
    return `${args.chainId}_${CacheRouter.TRANSFERS_KEY}_${args.safeAddress}`;
  }

  static getModuleTransactionCacheDir(args: {
    chainId: string;
    moduleTransactionId: string;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.MODULE_TRANSACTION_KEY}_${args.moduleTransactionId}`,
      '',
    );
  }

  static getModuleTransactionsCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    to?: string;
    txHash?: string;
    module?: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getModuleTransactionsCacheKey(args),
      `${args.to}_${args.module}_${args.txHash}_${args.limit}_${args.offset}`,
    );
  }

  static getModuleTransactionsCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.MODULE_TRANSACTIONS_KEY}_${args.safeAddress}`;
  }

  static getIncomingTransfersCacheDir(args: {
    chainId: string;
    safeAddress: string;
    executionDateGte?: string;
    executionDateLte?: string;
    to?: string;
    value?: string;
    tokenAddress?: string;
    txHash?: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getIncomingTransfersCacheKey(args),
      `${args.executionDateGte}_${args.executionDateLte}_${args.to}_${args.value}_${args.tokenAddress}_${args.txHash}_${args.limit}_${args.offset}`,
    );
  }

  static getIncomingTransfersCacheKey(args: {
    chainId: string;
    safeAddress: string;
  }): string {
    return `${args.chainId}_${CacheRouter.INCOMING_TRANSFERS_KEY}_${args.safeAddress}`;
  }

  static getIndexingCacheDir(chainId: string): CacheDir {
    return new CacheDir(`${chainId}_${CacheRouter.INDEXING_KEY}`, '');
  }

  static getMultisigTransactionsCacheDir(args: {
    chainId: string;
    safeAddress: string;
    ordering?: string;
    executed?: boolean;
    trusted?: boolean;
    executionDateGte?: string;
    executionDateLte?: string;
    to?: string;
    value?: string;
    nonce?: string;
    nonceGte?: number;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getMultisigTransactionsCacheKey(args),
      `${args.ordering}_${args.executed}_${args.trusted}_${args.executionDateGte}_${args.executionDateLte}_${args.to}_${args.value}_${args.nonce}_${args.nonceGte}_${args.limit}_${args.offset}`,
    );
  }

  static getMultisigTransactionsCacheKey(args: {
    chainId: string;
    safeAddress: string;
  }): string {
    return `${args.chainId}_${CacheRouter.MULTISIG_TRANSACTIONS_KEY}_${args.safeAddress}`;
  }

  static getMultisigTransactionCacheDir(args: {
    chainId: string;
    safeTransactionHash: string;
  }): CacheDir {
    return new CacheDir(CacheRouter.getMultisigTransactionCacheKey(args), '');
  }

  static getMultisigTransactionCacheKey(args: {
    chainId: string;
    safeTransactionHash: string;
  }): string {
    return `${args.chainId}_${CacheRouter.MULTISIG_TRANSACTION_KEY}_${args.safeTransactionHash}`;
  }

  static getCreationTransactionCacheDir(args: {
    chainId: string;
    safeAddress: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.CREATION_TRANSACTION_KEY}_${args.safeAddress}`,
      '',
    );
  }

  static getDecodedDataCacheKey(args: {
    chainId: string;
    data: Address;
    to: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.DECODED_DATA_KEY}_${args.data}_${args.to}`;
  }

  static getDecodedDataCacheDir(args: {
    chainId: string;
    data: Address;
    to: Address;
  }): CacheDir {
    return new CacheDir(CacheRouter.getDecodedDataCacheKey(args), '');
  }

  static getContractsCacheKey(args: {
    chainId: string;
    address: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.CONTRACTS_KEY}_${args.address}`;
  }

  static getContractsCacheDir(args: {
    chainId: string;
    address: Address;
  }): CacheDir {
    return new CacheDir(CacheRouter.getContractsCacheKey(args), '');
  }

  static getTrustedForDelegateCallContractsCacheKey(chainId: string): string {
    return `${chainId}_${CacheRouter.TRUSTED_FOR_DELEGATE_CALL_CONTRACTS_KEY}`;
  }

  static getTrustedForDelegateCallContractsCacheDir(args: {
    chainId: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getTrustedForDelegateCallContractsCacheKey(args.chainId),
      `${args.limit}_${args.offset}`,
    );
  }

  static getAllTransactionsCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    ordering?: string;
    executed?: boolean;
    queued?: boolean;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getAllTransactionsKey(args),
      `${args.ordering}_${args.executed}_${args.queued}_${args.limit}_${args.offset}`,
    );
  }

  static getAllTransactionsKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.ALL_TRANSACTIONS_KEY}_${args.safeAddress}`;
  }

  static getTokenCacheDir(args: {
    chainId: string;
    address: string;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.TOKEN_KEY}_${args.address}`,
      '',
    );
  }

  static getTokensCacheKey(chainId: string): string {
    return `${chainId}_${CacheRouter.TOKENS_KEY}`;
  }

  static getTokensCacheDir(args: {
    chainId: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getTokensCacheKey(args.chainId),
      `${args.limit}_${args.offset}`,
    );
  }

  static getSafesByOwnerCacheDir(args: {
    chainId: string;
    ownerAddress: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.OWNERS_SAFE_KEY}_${args.ownerAddress}`,
      '',
    );
  }

  static getMessageByHashCacheKey(args: {
    chainId: string;
    messageHash: string;
  }): string {
    return `${args.chainId}_${CacheRouter.MESSAGE_KEY}_${args.messageHash}`;
  }

  static getMessageByHashCacheDir(args: {
    chainId: string;
    messageHash: string;
  }): CacheDir {
    return new CacheDir(this.getMessageByHashCacheKey(args), '');
  }

  static getMessagesBySafeCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.MESSAGES_KEY}_${args.safeAddress}`;
  }

  static getMessagesBySafeCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      this.getMessagesBySafeCacheKey(args),
      `${args.limit}_${args.offset}`,
    );
  }

  static getChainsCacheKey(): string {
    return CacheRouter.CHAINS_KEY;
  }

  static getChainsCacheDir(args: {
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getChainsCacheKey(),
      `${args.limit}_${args.offset}`,
    );
  }

  static getChainCacheKey(chainId: string): string {
    return `${chainId}_${CacheRouter.CHAIN_KEY}`;
  }

  static getChainCacheDir(chainId: string): CacheDir {
    return new CacheDir(CacheRouter.getChainCacheKey(chainId), '');
  }

  static getRelayKey(args: { chainId: string; address: Address }): string {
    return `${args.chainId}_${CacheRouter.RELAY_KEY}_${args.address}`;
  }

  static getRelayCacheDir(args: {
    chainId: string;
    address: Address;
  }): CacheDir {
    return new CacheDir(CacheRouter.getRelayKey(args), '');
  }

  static getSafeAppsKey(chainId: string): string {
    return `${chainId}_${CacheRouter.SAFE_APPS_KEY}`;
  }

  static getSafeAppsCacheDir(args: {
    chainId?: string;
    clientUrl?: string;
    onlyListed?: boolean;
    url?: string;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.SAFE_APPS_KEY}`,
      `${args.clientUrl}_${args.onlyListed}_${args.url}`,
    );
  }

  static getNativeCoinPriceCacheDir(args: {
    nativeCoinId: string;
    fiatCode: string;
  }): CacheDir {
    return new CacheDir(
      `${args.nativeCoinId}_${CacheRouter.NATIVE_COIN_PRICE_KEY}_${args.fiatCode.toUpperCase()}`,
      '',
    );
  }

  static getTokenPriceCacheDir(args: {
    chainName: string;
    fiatCode: string;
    tokenAddress: string;
  }): CacheDir {
    return new CacheDir(
      `${args.chainName}_${CacheRouter.TOKEN_PRICE_KEY}_${args.tokenAddress}_${args.fiatCode.toUpperCase()}`,
      '',
    );
  }

  static getPriceFiatCodesCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.SAFE_FIAT_CODES_KEY, '');
  }

  static getAccountCacheDir(address: Address): CacheDir {
    return new CacheDir(`${CacheRouter.ACCOUNT_KEY}_${address}`, '');
  }

  static getAccountDataTypesCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.ACCOUNT_DATA_TYPES_KEY, '');
  }

  static getAccountDataSettingsCacheDir(address: Address): CacheDir {
    return new CacheDir(
      `${CacheRouter.ACCOUNT_DATA_SETTINGS_KEY}_${address}`,
      '',
    );
  }

  static getCounterfactualSafeCacheDir(
    chainId: string,
    predictedAddress: Address,
  ): CacheDir {
    return new CacheDir(
      `${chainId}_${CacheRouter.COUNTERFACTUAL_SAFE_KEY}_${predictedAddress}`,
      '',
    );
  }

  static getCounterfactualSafesCacheDir(address: Address): CacheDir {
    return new CacheDir(
      `${CacheRouter.COUNTERFACTUAL_SAFES_KEY}_${address}`,
      '',
    );
  }

  static getRpcRequestsKey(chainId: string): string {
    return `${chainId}_${CacheRouter.RPC_REQUESTS_KEY}`;
  }

  static getRpcRequestsCacheDir(args: {
    chainId: string;
    method: string;
    params: string;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getRpcRequestsKey(args.chainId),
      `${args.method}_${args.params}`,
    );
  }

  static getStakingDeploymentsCacheDir(
    cacheType: 'earn' | 'staking',
  ): CacheDir {
    return new CacheDir(this.STAKING_DEPLOYMENTS_KEY, cacheType);
  }

  static getStakingRewardsFeeCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    contract: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${this.STAKING_REWARDS_FEE_KEY}_${args.contract}`,
      args.cacheType,
    );
  }

  static getStakingNetworkStatsCacheDir(
    cacheType: 'earn' | 'staking',
  ): CacheDir {
    return new CacheDir(this.STAKING_NETWORK_STATS_KEY, cacheType);
  }

  static getStakingDedicatedStakingStatsCacheDir(
    cacheType: 'earn' | 'staking',
  ): CacheDir {
    return new CacheDir(this.STAKING_DEDICATED_STAKING_STATS_KEY, cacheType);
  }

  static getStakingPooledStakingStatsCacheDir(args: {
    cacheType: 'earn' | 'staking';
    pool: Address;
  }): CacheDir {
    return new CacheDir(
      `${this.STAKING_POOLED_STAKING_STATS_KEY}_${args.pool}`,
      args.cacheType,
    );
  }

  static getStakingDefiVaultStatsCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    vault: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${this.STAKING_DEFI_VAULT_STATS_KEY}_${args.vault}`,
      args.cacheType,
    );
  }

  static getStakingDefiVaultStakesCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    safeAddress: Address;
    vault: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${this.STAKING_DEFI_VAULT_STAKES_KEY}_${args.safeAddress}_${args.vault}`,
      args.cacheType,
    );
  }

  static getStakingDefiMorphoExtraRewardsCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    safeAddress: Address;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${this.STAKING_DEFI_MORPHO_EXTRA_REWARDS_KEY}_${args.safeAddress}`,
      args.cacheType,
    );
  }

  /**
   * Calculated the chain/Safe-specific cache key of {@link Stake}.
   *
   * @param {string} args.chainId - Chain ID
   * @param {string} args.safeAddress - Safe address
   * @returns {string} - Cache key
   */
  static getStakingStakesCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.STAKING_STAKES_KEY}_${args.safeAddress}`;
  }

  /**
   * Calculate cache directory for staking stakes.
   *
   * Note: This function hashes the validators' public keys to keep the
   * cache field short and deterministic. Redis and other cache systems
   * may experience performance degradation with long fields.
   *
   * @param {string} args.cacheType - Cache type (earn or staking)
   * @param {string} args.chainId - Chain ID
   * @param {string} args.safeAddress - Safe address
   * @param {string} args.validatorsPublicKeys - Array of validators public keys
   * @returns {@link CacheDir} - Cache directory
   */
  static getStakingStakesCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    safeAddress: Address;
    validatorsPublicKeys: Array<Address>;
  }): CacheDir {
    const hash = crypto.createHash('sha256');
    hash.update(args.validatorsPublicKeys.join('_'));
    return new CacheDir(
      CacheRouter.getStakingStakesCacheKey(args),
      `${args.cacheType}_${hash.digest('hex')}`,
    );
  }

  static getUnsupportedChainEventCacheKey(chainId: string): string {
    return `${chainId}_${this.UNSUPPORTED_CHAIN_EVENT}`;
  }

  static getStakingTransactionStatusCacheDir(args: {
    cacheType: 'earn' | 'staking';
    chainId: string;
    txHash: Hash;
  }): CacheDir {
    return new CacheDir(
      `${args.chainId}_${CacheRouter.STAKING_TRANSACTION_STATUS_KEY}_${args.txHash}`,
      args.cacheType,
    );
  }

  static getTargetedSafeCacheKey(outreachId: number): string {
    return `${CacheRouter.TARGETED_MESSAGING_TARGETED_SAFE_KEY}_${outreachId}`;
  }

  static getTargetedSafeCacheDir(args: {
    outreachId: number;
    safeAddress: Address;
    chainId?: string;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getTargetedSafeCacheKey(args.outreachId),
      `${args.safeAddress}_${args.chainId ?? 'null'}`,
    );
  }

  static getSubmissionCacheKey(outreachId: number): string {
    return `${CacheRouter.TARGETED_MESSAGING_SUBMISSION_KEY}_${outreachId}`;
  }

  static getSubmissionCacheDir(args: {
    outreachId: number;
    safeAddress: Address;
    signerAddress: Address;
    chainId: string | null;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getSubmissionCacheKey(args.outreachId),
      `${args.safeAddress}_${args.signerAddress}_${args.chainId ?? 'null'}`,
    );
  }

  static getOutreachesCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.TARGETED_MESSAGING_OUTREACHES, '');
  }

  static getOutreachFileProcessorCacheKey(): string {
    return CacheRouter.TARGETED_MESSAGING_OUTREACH_FILE_PROCESSOR_LOCK;
  }

  static getOutreachFileProcessorCacheDir(): CacheDir {
    return new CacheDir(CacheRouter.getOutreachFileProcessorCacheKey(), '');
  }

  static getTransactionsExportCacheKey(args: {
    chainId: string;
    safeAddress: Address;
  }): string {
    return `${args.chainId}_${CacheRouter.TRANSACTIONS_EXPORT_KEY}_${args.safeAddress}`;
  }

  static getTransactionsExportCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    executionDateGte?: string;
    executionDateLte?: string;
    limit?: number;
    offset?: number;
  }): CacheDir {
    return new CacheDir(
      CacheRouter.getTransactionsExportCacheKey(args),
      `${args.executionDateGte}_${args.executionDateLte}_${args.limit}_${args.offset}`,
    );
  }

  /**
   * Gets the in-memory cache key for the given cacheDir.
   */
  static getMemoryKey(cacheDir: CacheDir): string {
    return `${cacheDir.key}:${cacheDir.field}`;
  }

  /**
   * Gets Redis cache key for the ORM query cache.
   *
   * @param {string} prefix - Prefix for the cache key
   * @param {string} chainId - Chain ID
   * @param {string} safeAddress - Safe address
   *
   * @returns {string} - Cache key
   */
  static getOrnCacheKey(
    prefix: string,
    chainId: string,
    safeAddress: Address,
  ): string {
    return `${CacheRouter.ORM_QUERY_CACHE_KEY}:${prefix}:${chainId}:${safeAddress}`;
  }

  /**
   * Gets cache directory for contract analysis results.
   *
   * @param {string} args.chainId - Chain ID
   * @param {[Address, boolean][]} args.contractPairs - Array of pairs: contract address and isDelegateCall flag
   * @returns {CacheDir} - Cache directory
   */
  static getContractAnalysisCacheDir(args: {
    chainId: string;
    contractPairs: Array<[Address, boolean]>;
  }): CacheDir {
    const contractsHash = crypto.createHash('sha256');
    contractsHash.update(
      args.contractPairs.sort((a, b) => a[0].localeCompare(b[0])).join(','),
    );
    return new CacheDir(
      `${args.chainId}_${CacheRouter.CONTRACT_ANALYSIS_KEY}`,
      contractsHash.digest('hex'),
    );
  }

  /**
   * Gets cache directory for recipient analysis results.
   *
   * @param {string} args.chainId - Chain ID
   * @param {string} args.safeAddress - Safe address
   * @param {Address[]} args.recipients - Array of recipient addresses
   * @param {TransactionInfo} args.txInfo - The transaction info
   * @returns {CacheDir} - Cache directory
   */
  static getRecipientAnalysisCacheDir(args: {
    chainId: string;
    safeAddress: Address;
    recipients: Array<Address>;
    txInfo?: TransactionInfo;
  }): CacheDir {
    const hash = crypto.createHash('sha256');
    hash.update(args.recipients.sort().join(','));
    if (args.txInfo) {
      try {
        hash.update(JSON.stringify(args.txInfo));
      } catch {
        // fallback: do not update hash if serialization fails
      }
    }
    return new CacheDir(
      `${args.chainId}_${CacheRouter.RECIPIENT_ANALYSIS_KEY}_${args.safeAddress}`,
      hash.digest('hex'),
    );
  }

  static getPortfolioCacheKey(args: { address: Address }): string {
    return `${CacheRouter.PORTFOLIO_KEY}_${args.address}_zerion`;
  }

  static getPortfolioCacheDir(args: {
    address: Address;
    fiatCode: string;
    trusted?: boolean;
    isTestnet?: boolean;
  }): CacheDir {
    const trustedSuffix = args.trusted ? '_trusted' : '';
    const testnetSuffix = args.isTestnet ? '_testnet' : '';
    return new CacheDir(
      CacheRouter.getPortfolioCacheKey(args),
      `${args.fiatCode.toUpperCase()}${trustedSuffix}${testnetSuffix}`,
    );
  }

  static getZerionChainsCacheDir(isTestnet: boolean): CacheDir {
    const field = isTestnet ? 'mapping_testnet' : 'mapping';
    return new CacheDir(CacheRouter.ZERION_CHAINS_KEY, field);
  }
}

safe-global / safe-client-gateway / 19732484228

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous