@ -9,10 +9,12 @@ import {
IXERC20__factory , IXERC20__factory ,
} from '@hyperlane-xyz/core' ; } from '@hyperlane-xyz/core' ;
import { ERC20__factory } from '@hyperlane-xyz/core' ; import { ERC20__factory } from '@hyperlane-xyz/core' ;
import { createWarpRouteConfigId } from '@hyperlane-xyz/registry' ;
import { import {
ChainMap , ChainMap ,
ChainMetadata , ChainMetadata ,
ChainName , ChainName ,
CoinGeckoTokenPriceGetter ,
CosmNativeTokenAdapter , CosmNativeTokenAdapter ,
CwNativeTokenAdapter , CwNativeTokenAdapter ,
MultiProtocolProvider , MultiProtocolProvider ,
@ -38,17 +40,41 @@ import { getEnvironmentConfig } from '../core-utils.js';
const logger = rootLogger . child ( { module : 'warp-balance-monitor' } ) ; const logger = rootLogger . child ( { module : 'warp-balance-monitor' } ) ;
const metricsRegister = new Registry ( ) ; const metricsRegister = new Registry ( ) ;
interface WarpRouteMetrics {
chain_name : ChainName ;
token_address : string ;
token_name : string ;
wallet_address : string ;
token_type : TokenType ;
warp_route_id : string ;
related_chain_names : string ;
}
type WarpRouteMetricLabels = keyof WarpRouteMetrics ;
const warpRouteMetricLabels : WarpRouteMetricLabels [ ] = [
'chain_name' ,
'token_address' ,
'token_name' ,
'wallet_address' ,
'token_type' ,
'warp_route_id' ,
'related_chain_names' ,
] ;
const warpRouteTokenBalance = new Gauge ( { const warpRouteTokenBalance = new Gauge ( {
name : 'hyperlane_warp_route_token_balance' , name : 'hyperlane_warp_route_token_balance' ,
help : 'HypERC20 token balance of a Warp Route' , help : 'HypERC20 token balance of a Warp Route' ,
registers : [ metricsRegister ] , registers : [ metricsRegister ] ,
labelNames : [ labelNames : warpRouteMetricLabels ,
'chain_name' , } ) ;
'token_address' ,
'token_name' , const warpRouteCollateralValue = new Gauge ( {
'wallet_address' , name : 'hyperlane_warp_route_collateral_value' ,
'token_type' , help : 'Total value of collateral held in a HypERC20Collateral or HypNative contract of a Warp Route' ,
] , registers : [ metricsRegister ] ,
labelNames : warpRouteMetricLabels ,
} ) ; } ) ;
const xERC20LimitsGauge = new Gauge ( { const xERC20LimitsGauge = new Gauge ( {
@ -66,6 +92,11 @@ interface xERC20Limit {
burnMax : number ; burnMax : number ;
} }
interface WarpRouteInfo {
balance : number ;
valueUSD? : number ;
}
export function readWarpRouteConfig ( filePath : string ) { export function readWarpRouteConfig ( filePath : string ) {
const config = readYaml ( filePath ) ; const config = readYaml ( filePath ) ;
if ( ! config ) throw new Error ( ` No warp config found at ${ filePath } ` ) ; if ( ! config ) throw new Error ( ` No warp config found at ${ filePath } ` ) ;
@ -112,7 +143,8 @@ async function main(): Promise<boolean> {
async function checkBalance ( async function checkBalance (
tokenConfig : WarpRouteConfig , tokenConfig : WarpRouteConfig ,
multiProtocolProvider : MultiProtocolProvider , multiProtocolProvider : MultiProtocolProvider ,
) : Promise < ChainMap < number > > { tokenPriceGetter : CoinGeckoTokenPriceGetter ,
) : Promise < ChainMap < WarpRouteInfo > > {
const output = objMap ( const output = objMap (
tokenConfig , tokenConfig ,
async ( chain : ChainName , token : WarpRouteConfig [ ChainName ] ) = > { async ( chain : ChainName , token : WarpRouteConfig [ ChainName ] ) = > {
@ -122,8 +154,12 @@ async function checkBalance(
case ProtocolType . Ethereum : { case ProtocolType . Ethereum : {
const provider = multiProtocolProvider . getEthersV5Provider ( chain ) ; const provider = multiProtocolProvider . getEthersV5Provider ( chain ) ;
const nativeBalance = await provider . getBalance ( token . hypAddress ) ; const nativeBalance = await provider . getBalance ( token . hypAddress ) ;
return parseFloat (
ethers . utils . formatUnits ( nativeBalance , token . decimals ) , return getNativeTokenWarpInfo (
nativeBalance ,
token . decimals ,
tokenPriceGetter ,
chain ,
) ; ) ;
} }
case ProtocolType . Sealevel : { case ProtocolType . Sealevel : {
@ -142,8 +178,12 @@ async function checkBalance(
const balance = ethers . BigNumber . from ( const balance = ethers . BigNumber . from (
await adapter . getBalance ( token . hypAddress ) , await adapter . getBalance ( token . hypAddress ) ,
) ; ) ;
return parseFloat (
ethers . utils . formatUnits ( balance , token . decimals ) , return getNativeTokenWarpInfo (
balance ,
token . decimals ,
tokenPriceGetter ,
chain ,
) ; ) ;
} }
case ProtocolType . Cosmos : { case ProtocolType . Cosmos : {
@ -156,8 +196,12 @@ async function checkBalance(
{ ibcDenom : token.ibcDenom } , { ibcDenom : token.ibcDenom } ,
) ; ) ;
const tokenBalance = await adapter . getBalance ( token . hypAddress ) ; const tokenBalance = await adapter . getBalance ( token . hypAddress ) ;
return parseFloat (
ethers . utils . formatUnits ( tokenBalance , token . decimals ) , return getNativeTokenWarpInfo (
tokenBalance ,
token . decimals ,
tokenPriceGetter ,
chain ,
) ; ) ;
} }
} }
@ -177,8 +221,11 @@ async function checkBalance(
token . hypAddress , token . hypAddress ,
) ; ) ;
return parseFloat ( return getCollateralTokenWarpInfo (
ethers . utils . formatUnits ( collateralBalance , token . decimals ) , collateralBalance ,
token . decimals ,
tokenPriceGetter ,
token . tokenCoinGeckoId ,
) ; ) ;
} }
case ProtocolType . Sealevel : { case ProtocolType . Sealevel : {
@ -198,8 +245,12 @@ async function checkBalance(
const collateralBalance = ethers . BigNumber . from ( const collateralBalance = ethers . BigNumber . from (
await adapter . getBalance ( token . hypAddress ) , await adapter . getBalance ( token . hypAddress ) ,
) ; ) ;
return parseFloat (
ethers . utils . formatUnits ( collateralBalance , token . decimals ) , return getCollateralTokenWarpInfo (
collateralBalance ,
token . decimals ,
tokenPriceGetter ,
token . tokenCoinGeckoId ,
) ; ) ;
} }
case ProtocolType . Cosmos : { case ProtocolType . Cosmos : {
@ -216,8 +267,12 @@ async function checkBalance(
const collateralBalance = ethers . BigNumber . from ( const collateralBalance = ethers . BigNumber . from (
await adapter . getBalance ( token . hypAddress ) , await adapter . getBalance ( token . hypAddress ) ,
) ; ) ;
return parseFloat (
ethers . utils . formatUnits ( collateralBalance , token . decimals ) , return getCollateralTokenWarpInfo (
collateralBalance ,
token . decimals ,
tokenPriceGetter ,
token . tokenCoinGeckoId ,
) ; ) ;
} }
} }
@ -232,9 +287,11 @@ async function checkBalance(
provider , provider ,
) ; ) ;
const syntheticBalance = await tokenContract . totalSupply ( ) ; const syntheticBalance = await tokenContract . totalSupply ( ) ;
return parseFloat ( return {
ethers . utils . formatUnits ( syntheticBalance , token . decimals ) , balance : parseFloat (
) ; ethers . utils . formatUnits ( syntheticBalance , token . decimals ) ,
) ,
} ;
} }
case ProtocolType . Sealevel : { case ProtocolType . Sealevel : {
if ( ! token . tokenAddress ) if ( ! token . tokenAddress )
@ -253,13 +310,15 @@ async function checkBalance(
const syntheticBalance = ethers . BigNumber . from ( const syntheticBalance = ethers . BigNumber . from (
await adapter . getTotalSupply ( ) , await adapter . getTotalSupply ( ) ,
) ; ) ;
return parseFloat ( return {
ethers . utils . formatUnits ( syntheticBalance , token . decimals ) , balance : parseFloat (
) ; ethers . utils . formatUnits ( syntheticBalance , token . decimals ) ,
) ,
} ;
} }
case ProtocolType . Cosmos : case ProtocolType . Cosmos :
// TODO - cosmos synthetic
// TODO - cosmos synthetic
return 0 ; return { balance : 0 } ;
} }
break ; break ;
} }
@ -275,9 +334,11 @@ async function checkBalance(
const xerc20 = IXERC20__factory . connect ( xerc20Address , provider ) ; const xerc20 = IXERC20__factory . connect ( xerc20Address , provider ) ;
const syntheticBalance = await xerc20 . totalSupply ( ) ; const syntheticBalance = await xerc20 . totalSupply ( ) ;
return parseFloat ( return {
ethers . utils . formatUnits ( syntheticBalance , token . decimals ) , balance : parseFloat (
) ; ethers . utils . formatUnits ( syntheticBalance , token . decimals ) ,
) ,
} ;
} }
default : default :
throw new Error ( throw new Error (
@ -307,8 +368,11 @@ async function checkBalance(
xerc20LockboxAddress , xerc20LockboxAddress ,
) ; ) ;
return parseFloat ( return getCollateralTokenWarpInfo (
ethers . utils . formatUnits ( collateralBalance , token . decimals ) , collateralBalance ,
token . decimals ,
tokenPriceGetter ,
token . tokenCoinGeckoId ,
) ; ) ;
} }
default : default :
@ -318,7 +382,7 @@ async function checkBalance(
} }
} }
} }
return 0 ; return { balance : 0 } ;
} , } ,
) ; ) ;
@ -327,22 +391,44 @@ async function checkBalance(
export function updateTokenBalanceMetrics ( export function updateTokenBalanceMetrics (
tokenConfig : WarpRouteConfig , tokenConfig : WarpRouteConfig ,
balances : ChainMap < number > , balances : ChainMap < WarpRouteInfo > ,
) { ) {
objMap ( tokenConfig , ( chain : ChainName , token : WarpRouteConfig [ ChainName ] ) = > { objMap ( tokenConfig , ( chain : ChainName , token : WarpRouteConfig [ ChainName ] ) = > {
warpRouteTokenBalance const metrics : WarpRouteMetrics = {
. labels ( { chain_name : chain ,
chain_name : chain , token_address : token.tokenAddress ? ? ethers . constants . AddressZero ,
token_address : token.tokenAddress ? ? ethers . constants . AddressZero , token_name : token.name ,
token_name : token.name , wallet_address : token.hypAddress ,
wallet_address : token.hypAddress , token_type : token.type ,
token_type : token.type , warp_route_id : createWarpRouteConfigId (
} ) token . symbol ,
. set ( balances [ chain ] ) ; Object . keys ( tokenConfig ) as ChainName [ ] ,
) ,
related_chain_names : Object.keys ( tokenConfig )
. filter ( ( chainName ) = > chainName !== chain )
. sort ( )
. join ( ',' ) ,
} ;
warpRouteTokenBalance . labels ( metrics ) . set ( balances [ chain ] . balance ) ;
if ( balances [ chain ] . valueUSD ) {
warpRouteCollateralValue
. labels ( metrics )
. set ( balances [ chain ] . valueUSD as number ) ;
logger . debug ( 'Collateral value updated for chain' , {
chain ,
related_chain_names : metrics.related_chain_names ,
warp_route_id : metrics.warp_route_id ,
token : metrics.token_name ,
value : balances [ chain ] . valueUSD ,
} ) ;
}
logger . debug ( 'Wallet balance updated for chain' , { logger . debug ( 'Wallet balance updated for chain' , {
chain , chain ,
token : token.name , related_chain_names : metrics.related_chain_names ,
balance : balances [ chain ] , warp_route_id : metrics.warp_route_id ,
token : metrics.token_name ,
balance : balances [ chain ] . balance ,
} ) ; } ) ;
} ) ; } ) ;
} }
@ -468,27 +554,120 @@ const getXERC20Limit = async (
} ; } ;
} ; } ;
async function getTokenPriceByChain (
chain : ChainName ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
) : Promise < number | undefined > {
try {
return await tokenPriceGetter . getTokenPrice ( chain ) ;
} catch ( e ) {
logger . warn ( 'Error getting token price' , e ) ;
return undefined ;
}
}
async function getNativeTokenValue (
chain : ChainName ,
balanceFloat : number ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
) : Promise < number | undefined > {
const price = await getTokenPriceByChain ( chain , tokenPriceGetter ) ;
logger . debug ( ` ${ chain } native token price ${ price } ` ) ;
if ( ! price ) return undefined ;
return balanceFloat * price ;
}
async function getNativeTokenWarpInfo (
balance : ethers.BigNumber | bigint ,
decimal : number ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
chain : ChainName ,
) : Promise < WarpRouteInfo > {
const balanceFloat = parseFloat ( ethers . utils . formatUnits ( balance , decimal ) ) ;
const value = await getNativeTokenValue (
chain ,
balanceFloat ,
tokenPriceGetter ,
) ;
return { balance : balanceFloat , valueUSD : value } ;
}
async function getCollateralTokenPrice (
tokenCoinGeckoId : string | undefined ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
) : Promise < number | undefined > {
if ( ! tokenCoinGeckoId ) return undefined ;
const prices = await tokenPriceGetter . getTokenPriceByIds ( [ tokenCoinGeckoId ] ) ;
if ( ! prices ) return undefined ;
return prices [ 0 ] ;
}
async function getCollateralTokenValue (
tokenCoinGeckoId : string | undefined ,
balanceFloat : number ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
) : Promise < number | undefined > {
const price = await getCollateralTokenPrice (
tokenCoinGeckoId ,
tokenPriceGetter ,
) ;
logger . debug ( ` ${ tokenCoinGeckoId } token price ${ price } ` ) ;
if ( ! price ) return undefined ;
return balanceFloat * price ;
}
async function getCollateralTokenWarpInfo (
balance : ethers.BigNumber | bigint ,
decimal : number ,
tokenPriceGetter : CoinGeckoTokenPriceGetter ,
tokenCoinGeckoId? : string ,
) : Promise < WarpRouteInfo > {
const balanceFloat = parseFloat ( ethers . utils . formatUnits ( balance , decimal ) ) ;
const value = await getCollateralTokenValue (
tokenCoinGeckoId ,
balanceFloat ,
tokenPriceGetter ,
) ;
return { balance : balanceFloat , valueUSD : value } ;
}
async function checkWarpRouteMetrics ( async function checkWarpRouteMetrics (
checkFrequency : number , checkFrequency : number ,
tokenConfig : WarpRouteConfig , tokenConfig : WarpRouteConfig ,
chainMetadata : ChainMap < ChainMetadata > , chainMetadata : ChainMap < ChainMetadata > ,
) { ) {
const tokenPriceGetter =
CoinGeckoTokenPriceGetter . withDefaultCoinGecko ( chainMetadata ) ;
setInterval ( async ( ) = > { setInterval ( async ( ) = > {
try { try {
const multiProtocolProvider = new MultiProtocolProvider ( chainMetadata ) ; const multiProtocolProvider = new MultiProtocolProvider ( chainMetadata ) ;
const balances = await checkBalance ( tokenConfig , multiProtocolProvider ) ; const balances = await checkBalance (
tokenConfig ,
multiProtocolProvider ,
tokenPriceGetter ,
) ;
logger . info ( 'Token Balances:' , balances ) ; logger . info ( 'Token Balances:' , balances ) ;
updateTokenBalanceMetrics ( tokenConfig , balances ) ; updateTokenBalanceMetrics ( tokenConfig , balances ) ;
} catch ( e ) { } catch ( e ) {
logger . error ( 'Error checking balances' , e ) ; logger . error ( 'Error checking balances' , e ) ;
} }
try { // only check xERC20 limits if there are xERC20 tokens in the config
const xERC20Limits = await getXERC20Limits ( tokenConfig , chainMetadata ) ; if (
logger . info ( 'xERC20 Limits:' , xERC20Limits ) ; Object . keys ( tokenConfig ) . some (
updateXERC20LimitsMetrics ( xERC20Limits ) ; ( chain ) = >
} catch ( e ) { tokenConfig [ chain ] . type === TokenType . XERC20 ||
logger . error ( 'Error checking xERC20 limits' , e ) ; tokenConfig [ chain ] . type === TokenType . XERC20Lockbox ,
)
) {
try {
const xERC20Limits = await getXERC20Limits ( tokenConfig , chainMetadata ) ;
logger . info ( 'xERC20 Limits:' , xERC20Limits ) ;
updateXERC20LimitsMetrics ( xERC20Limits ) ;
} catch ( e ) {
logger . error ( 'Error checking xERC20 limits' , e ) ;
}
} }
} , checkFrequency ) ; } , checkFrequency ) ;
} }
Mohammed Hussan
1 month ago
committed by
GitHub