From 51bf47bd1476a1b77bf404ec22919e042bc87b20 Mon Sep 17 00:00:00 2001 From: Paul Noel Date: Tue, 11 Mar 2025 11:49:04 -0500 Subject: [PATCH] cloud_functions: add alarmFastTransfer --- cloud_functions/scripts/deploy.sh | 11 ++ cloud_functions/src/alarmFastTransfer.ts | 129 +++++++++++++++++++++++ 2 files changed, 140 insertions(+) create mode 100644 cloud_functions/src/alarmFastTransfer.ts diff --git a/cloud_functions/scripts/deploy.sh b/cloud_functions/scripts/deploy.sh index 50ed4b6c..eb1fe407 100755 --- a/cloud_functions/scripts/deploy.sh +++ b/cloud_functions/scripts/deploy.sh @@ -177,6 +177,16 @@ if [ -z "$PG_HOST" ] || [ "$PG_HOST" == "localhost" ] || [ "$PG_HOST" == "127.0. exit 1 fi +if [ -z "$PG_FT_DATABASE" ]; then + echo "PG_FT_DATABASE must be specified" + exit 1 +fi + +if [ -z "$FT_MISSING_VAA_SLACK_CHANNEL_ID" ]; then + echo "FT_MISSING_VAA_SLACK_CHANNEL_ID must be specified" + exit 1 +fi + if [ -z "$PG_TOKEN_TRANSFER_TABLE" ]; then echo "PG_TOKEN_TRANSFER_TABLE must be specified" exit 1 @@ -232,6 +242,7 @@ if [ -z "$SOLANA_RPC" ]; then exit 1 fi +gcloud functions --project "$GCP_PROJECT" deploy alarm-fast-transfer --entry-point alarmFastTransfer --gen2 --runtime nodejs22 --trigger-http --allow-unauthenticated --timeout 300 --memory 512MB --region europe-west3 --set-env-vars FT_MISSING_VAA_SLACK_CHANNEL_ID=$FT_MISSING_VAA_SLACK_CHANNEL_ID,MISSING_VAA_SLACK_POST_URL=$MISSING_VAA_SLACK_POST_URL,MISSING_VAA_SLACK_BOT_TOKEN=$MISSING_VAA_SLACK_BOT_TOKEN,PG_USER=$PG_USER,PG_PASSWORD=$PG_PASSWORD,PG_FT_DATABASE=$PG_FT_DATABASE,PG_HOST=$PG_HOST,NETWORK=$NETWORK,FUNCTION=alarmFastTransfer gcloud functions --project "$GCP_PROJECT" deploy compute-guardian-set-info --entry-point computeGuardianSetInfo --gen2 --runtime nodejs22 --trigger-http --allow-unauthenticated --timeout 300 --memory 512MB --region europe-west3 --set-env-vars NETWORK=$NETWORK,FIRESTORE_GUARDIAN_SET_INFO_COLLECTION=$FIRESTORE_GUARDIAN_SET_INFO_COLLECTION,FUNCTION=computeGuardianSetInfo gcloud functions --project "$GCP_PROJECT" deploy compute-tvl --entry-point computeTVL --gen2 --runtime nodejs22 --trigger-http --no-allow-unauthenticated --timeout 300 --memory 1GB --region europe-west3 --set-env-vars PG_USER=$PG_USER,PG_PASSWORD=$PG_PASSWORD,PG_DATABASE=$PG_DATABASE,PG_HOST=$PG_HOST,PG_ATTEST_MESSAGE_TABLE=$PG_ATTEST_MESSAGE_TABLE,PG_TOKEN_METADATA_TABLE=$PG_TOKEN_METADATA_TABLE,PG_TOKEN_TRANSFER_TABLE=$PG_TOKEN_TRANSFER_TABLE,FIRESTORE_TVL_COLLECTION=$FIRESTORE_TVL_COLLECTION,NETWORK=$NETWORK,FUNCTION=computeTVL gcloud functions --project "$GCP_PROJECT" deploy compute-tvl-history --entry-point computeTVLHistory --gen2 --runtime nodejs22 --trigger-http --no-allow-unauthenticated --timeout 540 --memory 1GB --region europe-west3 --set-env-vars PG_USER=$PG_USER,PG_PASSWORD=$PG_PASSWORD,PG_DATABASE=$PG_DATABASE,PG_HOST=$PG_HOST,PG_ATTEST_MESSAGE_TABLE=$PG_ATTEST_MESSAGE_TABLE,PG_TOKEN_METADATA_TABLE=$PG_TOKEN_METADATA_TABLE,PG_TOKEN_TRANSFER_TABLE=$PG_TOKEN_TRANSFER_TABLE,FIRESTORE_TVL_HISTORY_COLLECTION=$FIRESTORE_TVL_HISTORY_COLLECTION,PG_TOKEN_PRICE_HISTORY_TABLE=$PG_TOKEN_PRICE_HISTORY_TABLE,NETWORK=$NETWORK,FUNCTION=computeTVLHistory diff --git a/cloud_functions/src/alarmFastTransfer.ts b/cloud_functions/src/alarmFastTransfer.ts new file mode 100644 index 00000000..b0939c4d --- /dev/null +++ b/cloud_functions/src/alarmFastTransfer.ts @@ -0,0 +1,129 @@ +import { + assertEnvironmentVariable, + formatAndSendToSlack, + SlackInfo, +} from '@wormhole-foundation/wormhole-monitor-common'; +import knex, { Knex } from 'knex'; + +let alarmSlackInfo: SlackInfo; +let initialized = false; +let pg: Knex; + +function initialize() { + pg = knex({ + client: 'pg', + connection: { + user: assertEnvironmentVariable('PG_USER'), + password: assertEnvironmentVariable('PG_PASSWORD'), + database: assertEnvironmentVariable('PG_FT_DATABASE'), + host: assertEnvironmentVariable('PG_HOST'), + }, + }); + console.log(`database = ${assertEnvironmentVariable('PG_FT_DATABASE')}`); + + alarmSlackInfo = { + channelId: assertEnvironmentVariable('FT_MISSING_VAA_SLACK_CHANNEL_ID'), + postUrl: assertEnvironmentVariable('MISSING_VAA_SLACK_POST_URL'), + botToken: assertEnvironmentVariable('MISSING_VAA_SLACK_BOT_TOKEN'), + bannerTxt: 'Wormhole Fast Transfer Alarm', + msg: '', + }; + console.log(`channelId = ${assertEnvironmentVariable('FT_MISSING_VAA_SLACK_CHANNEL_ID')}`); + console.log('initialized global variables'); + initialized = true; +} + +export async function alarmFastTransfer(req: any, res: any) { + res.set('Access-Control-Allow-Origin', '*'); + if (req.method === 'OPTIONS') { + // Send response to OPTIONS requests + res.set('Access-Control-Allow-Methods', 'GET'); + res.set('Access-Control-Allow-Headers', 'Content-Type'); + res.set('Access-Control-Max-Age', '3600'); + res.status(204).send(''); + return; + } + + try { + if (!initialized) { + initialize(); + } + + // Get the last 30 minutes of delayed orders. + // In this case, delayed means the execution time is greater than 20 seconds. + // This cloud function is scheduled to run every 30 minutes. + const alertOrders: DisplayRow[] = await getDelayedOrders(); + for (const order of alertOrders) { + const formattedAmountIn = formatBigInt(order.amountIn); + const formattedAmountOut = formatBigInt(order.amountOut); + alarmSlackInfo.msg = + `🚨 Delayed Order Alert!\n` + + `Source Chain: ${order.sourceChain}\n` + + `Sequence: ${order.sequence}\n` + + `Status: ${order.status}\n` + + `Order Timestamp: ${order.market_order_timestamp.toISOString()}\n` + + `Destination Chain: ${order.destinationChain}\n` + + `Execution Time: ${order.executionTime} Sec\n` + + `Amount In: ${formattedAmountIn}\n` + + `Amount Out: ${formattedAmountOut}`; + console.log(alarmSlackInfo.msg); + await formatAndSendToSlack(alarmSlackInfo); + } + } catch (e) { + console.error(e); + res.sendStatus(500); + } + res.status(200).send('successfully alarmed delayed fast transfers'); + return; +} + +// Format the amount in bigint to a string with 2 decimal places. +// We know that the bigint input is fixed 6 decimal places and we only need to show 2 decimal places. +const formatBigInt = (amt: bigint) => { + const str = (amt / 10_000n).toString().padStart(3, '0'); + return str.substring(0, str.length - 2) + '.' + str.substring(str.length - 2); +}; + +async function getDelayedOrders(): Promise { + console.log('getDelayedOrders'); + const result = await pg + .select( + 'mo.fast_vaa_id', + 'mo.status', + 'mo.market_order_timestamp', + 'mo.dst_chain AS destinationChain', + pg.raw( + 'EXTRACT(EPOCH FROM (fte.execution_time - mo.market_order_timestamp)) AS "executionTime"' + ), + 'mo.amount_in AS amountIn', + 'fte.user_amount' + ) + .from('market_orders AS mo') + .join('fast_transfer_executions AS fte', 'mo.fast_vaa_hash', '=', 'fte.fast_vaa_hash') + .where('mo.market_order_timestamp', '>=', pg.raw("NOW() - INTERVAL '30 MINUTES'")) // Get orders from last 30 minutes + .andWhereRaw('EXTRACT(EPOCH FROM (fte.execution_time - mo.market_order_timestamp)) > 20') + .orderBy('mo.market_order_timestamp', 'desc'); + + console.log('result', result); + return result.map((row) => ({ + sourceChain: row.fast_vaa_id.split('/')[0], + sequence: row.fast_vaa_id.split('/')[2], + status: row.status, + market_order_timestamp: row.market_order_timestamp, + destinationChain: row.destinationChain, + executionTime: row.executionTime, + amountIn: BigInt(row.amountIn), + amountOut: BigInt(row.user_amount), + })); +} + +type DisplayRow = { + sourceChain: number; // from fast_vaa_id + sequence: bigint; // from fast_vaa_id + status: string; // from MarketOrder + market_order_timestamp: Date; // from MarketOrder + destinationChain: number; // from MarketOrder + executionTime: number; // execution_time - market_order_timestamp + amountIn: bigint; // from MarketOrder + amountOut: bigint; // from FastTransferExecutions +};