14799879024

Committed 02 May 2025 05:10PM UTC coverage: 44.434% (-0.7%) from 45.12%

Build # 14799879024

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #12024 from hicommonwealth/rotorsoft/9823-replace-moment-libs

Replace moment in libs, fixex tests

Run Details

1663 of 4120 branches covered (40.36%)

Branch coverage included in aggregate %.

6 of 9 new or added lines in 4 files covered. (66.67%)

49 existing lines in 6 files now uncovered.

3027 of 6435 relevant lines covered (47.04%)

39.03 hits per line

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

2.63

/libs/model/src/services/tokenBalanceCache/tokenBalanceCache.ts

import { logger, stats } from '@hicommonwealth/core';
import { BalanceSourceType } from '@hicommonwealth/shared';
import { getCosmosBalances, getEvmBalances } from './providers';
import { getSolanaBalances } from './providers/getSolanaBalances';
import {
  Balances,
  GetBalancesOptions,
  GetCosmosBalancesOptions,
  GetErcBalanceOptions,
  GetEvmBalancesOptions,
  GetSPLBalancesOptions,
} from './types';

const log = logger(import.meta);

/**
 * This is the main function through which all balances should be fetched.
 * This function supports all balance sources and is fully compatible with Redis caching.
 */
export async function getBalances(
  options: GetBalancesOptions,
  ttl?: number,
): Promise<Balances> {
  if (options.addresses.length === 0) return {};

  let balances: Balances = {};

  try {
    if (
      options.balanceSourceType === BalanceSourceType.CosmosNative ||
      options.balanceSourceType === BalanceSourceType.CW20 ||
      options.balanceSourceType === BalanceSourceType.CW721
    ) {
      balances = await getCosmosBalances(options, ttl);
    } else if (
      options.balanceSourceType == BalanceSourceType.SPL ||
      options.balanceSourceType == BalanceSourceType.SOLNFT
    ) {
      balances = await getSolanaBalances(options, ttl);
    } else {
      balances = await getEvmBalances(options as GetEvmBalancesOptions, ttl);
    }
  } catch (e) {
    const chainId =
      options.balanceSourceType == BalanceSourceType.SPL
        ? 'solana'
        : (options as GetEvmBalancesOptions).sourceOptions.evmChainId ||
          (options as GetCosmosBalancesOptions).sourceOptions.cosmosChainId;
    const contractAddress =
      (options as GetSPLBalancesOptions).mintAddress ||
      (options as GetErcBalanceOptions).sourceOptions.contractAddress;
    const msg =
      `Failed to fetch balance(s) for ${options.addresses.length} address(es)` +
      `on chain ${chainId}${contractAddress && ' for contract '}${
        contractAddress || ''
      }`;

    log.error(msg, e instanceof Error ? e : undefined, {
      fingerprint: `TBC: ${chainId} - ${contractAddress}`,
      addresses: options.addresses.slice(0, 5),
      contractAddress: (options as GetErcBalanceOptions).sourceOptions
        .contractAddress,
      evmChainId: (options as GetEvmBalancesOptions).sourceOptions.evmChainId,
      cosmosChainId: (options as GetCosmosBalancesOptions).sourceOptions
        .cosmosChainId,
    });
  }

  stats().incrementBy(
    'tbc.successful.balance.fetch',
    Object.keys(balances).length,
    {
      balance_source_type: options.balanceSourceType,
    },
  );
  return balances;
}

1	import { logger, stats } from '@hicommonwealth/core';
2	import { BalanceSourceType } from '@hicommonwealth/shared';
3	import { getCosmosBalances, getEvmBalances } from './providers';
4	import { getSolanaBalances } from './providers/getSolanaBalances';
5	import {
6	Balances,
7	GetBalancesOptions,
8	GetCosmosBalancesOptions,
9	GetErcBalanceOptions,
10	GetEvmBalancesOptions,
11	GetSPLBalancesOptions,
12	} from './types';
13
14	const log = logger(import.meta);	33✔
15
16	/**
17	* This is the main function through which all balances should be fetched.
18	* This function supports all balance sources and is fully compatible with Redis caching.
19	*/
20	export async function getBalances(
21	options: GetBalancesOptions,
22	ttl?: number,
23	): Promise<Balances> {
UNCOV 24	if (options.addresses.length === 0) return {};	×
25
UNCOV 26	let balances: Balances = {};	×
27
UNCOV 28	try {	×
UNCOV 29	if (	×
30	options.balanceSourceType === BalanceSourceType.CosmosNative \|\|	×
31	options.balanceSourceType === BalanceSourceType.CW20 \|\|
32	options.balanceSourceType === BalanceSourceType.CW721
33	) {
34	balances = await getCosmosBalances(options, ttl);	×
UNCOV 35	} else if (	×
36	options.balanceSourceType == BalanceSourceType.SPL \|\|	×
37	options.balanceSourceType == BalanceSourceType.SOLNFT
38	) {
39	balances = await getSolanaBalances(options, ttl);	×
40	} else {
UNCOV 41	balances = await getEvmBalances(options as GetEvmBalancesOptions, ttl);	×
42	}
43	} catch (e) {
44	const chainId =
45	options.balanceSourceType == BalanceSourceType.SPL	×
46	? 'solana'
47	: (options as GetEvmBalancesOptions).sourceOptions.evmChainId \|\|	×
48	(options as GetCosmosBalancesOptions).sourceOptions.cosmosChainId;
49	const contractAddress =
50	(options as GetSPLBalancesOptions).mintAddress \|\|	×
51	(options as GetErcBalanceOptions).sourceOptions.contractAddress;
52	const msg =
53	`Failed to fetch balance(s) for ${options.addresses.length} address(es)` +	×
54	`on chain ${chainId}${contractAddress && ' for contract '}${	×
55	contractAddress \|\| ''	×
56	}`;
57
58	log.error(msg, e instanceof Error ? e : undefined, {	×
59	fingerprint: `TBC: ${chainId} - ${contractAddress}`,
60	addresses: options.addresses.slice(0, 5),
61	contractAddress: (options as GetErcBalanceOptions).sourceOptions
62	.contractAddress,
63	evmChainId: (options as GetEvmBalancesOptions).sourceOptions.evmChainId,
64	cosmosChainId: (options as GetCosmosBalancesOptions).sourceOptions
65	.cosmosChainId,
66	});
67	}
68
UNCOV 69	stats().incrementBy(	×
70	'tbc.successful.balance.fetch',
71	Object.keys(balances).length,
72	{
73	balance_source_type: options.balanceSourceType,
74	},
75	);
UNCOV 76	return balances;	×
77	}

hicommonwealth / commonwealth / 14799879024

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