cloud_functions: handle bigint amount

Author: panoel

cloud_functions/src/alarmFastTransfer.ts

@@ -54,8 +54,8 @@ export async function alarmFastTransfer(req: any, res: any) {
     // This cloud function is scheduled to run every 30 minutes.
     const alertOrders: DisplayRow[] = await getDelayedOrders();
     for (const order of alertOrders) {
-      const formattedAmountIn = (Number(order.amountIn) / 1_000_000).toFixed(2);
-      const formattedAmountOut = (Number(order.amountOut) / 1_000_000).toFixed(2);
+      const formattedAmountIn = formatBigInt(order.amountIn);
+      const formattedAmountOut = formatBigInt(order.amountOut);
       alarmSlackInfo.msg =
         `🚨 Delayed Order Alert!\n` +
         `Source Chain: ${order.sourceChain}\n` +
@@ -77,6 +77,11 @@ export async function alarmFastTransfer(req: any, res: any) {
   return;
 }
 
+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<DisplayRow[]> {
   console.log('getDelayedOrders');
   const result = await pg
@@ -112,11 +117,11 @@ async function getDelayedOrders(): Promise<DisplayRow[]> {
 
 type DisplayRow = {
   sourceChain: number; // from fast_vaa_id
-  sequence: BigInt; // 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
+  amountIn: bigint; // from MarketOrder
+  amountOut: bigint; // from FastTransferExecutions
 };