pendulum-chain · ebma · Apr 15, 2025 · Apr 14, 2025 · Apr 14, 2025 · Apr 14, 2025
diff --git a/.gitignore b/.gitignore
@@ -31,7 +31,7 @@ dist-ssr
 .env.sentry-build-plugin
 
 # testing artifacts
-*/failedRampStateRecovery.json
-*/lastRampState.json
-*/lastRampStateOnramp.json
+**/failedRampStateRecovery.json
+**/lastRampState.json
+**/lastRampStateOnramp.json
 
diff --git a/api/.eslintrc b/api/.eslintrc
diff --git a/api/.eslintrc.js b/api/.eslintrc.js
@@ -0,0 +1,39 @@
+module.exports = {
+  parser: '@typescript-eslint/parser',
+  plugins: ['@typescript-eslint'],
+  rules: {
+    'no-console': 0,
+    'no-underscore-dangle': 0,
+    'no-unused-vars': 'off',
+    '@typescript-eslint/no-unused-vars': ['error', { argsIgnorePattern: 'next' }],
+    'no-use-before-define': 'off',
+    '@typescript-eslint/no-use-before-define': ['error', { variables: false }],
+    'no-multi-str': 0,
+    'import/extensions': [
+      'error',
+      'ignorePackages',
+      {
+        ts: 'never',
+      },
+    ],
+  },
+  env: {
+    es2020: true,
+    node: true,
+    mocha: true,
+  },
+  parserOptions: {
+    ecmaVersion: 8, // Note: ecmaVersion 8 is ES2017. Consider updating if using newer features.
+    sourceType: 'module',
+    project: './tsconfig.json', // Path relative to tsconfigRootDir
+    tsconfigRootDir: __dirname, // Correctly resolves the directory of this config file
+  },
+  extends: ['airbnb-base', 'prettier', 'plugin:@typescript-eslint/recommended'],
+  settings: {
+    'import/resolver': {
+      node: {
+        extensions: ['.ts'],
+      },
+    },
+  },
+};
diff --git a/api/bun.lockb b/api/bun.lockb
diff --git a/api/src/api/controllers/brla.controller.ts b/api/src/api/controllers/brla.controller.ts
@@ -5,6 +5,7 @@ import { BrlaApiService } from '../services/brla/brlaApiService';
 import { eventPoller } from '../..';
 import { BrlaTeleportService } from '../services/brla/brlaTeleportService';
 import { generateReferenceLabel } from '../services/brla/helpers';
+import logger from '../../config/logger';
 
 // BRLA API requires the date in the format YYYY-MMM-DD
 function convertDateToBRLAFormat(dateNumber: number) {
@@ -351,7 +352,7 @@ export const triggerPayIn = async (
       res.status(400).json({ error: 'taxId invalid' });
       return;
     }
-    console.log('Requesting teleport:', subaccount.id, amount, receiverAddress);
+    logger.info('Requesting teleport:', subaccount.id, amount, receiverAddress);
     const teleportService = BrlaTeleportService.getInstance();
     await teleportService.requestTeleport(subaccount.id, Number(amount), receiverAddress);
 

diff --git a/api/src/api/controllers/pendulum.controller.ts b/api/src/api/controllers/pendulum.controller.ts
@@ -13,6 +13,7 @@ import { fundEphemeralAccount, getFundingData } from '../services/pendulum/pendu
 import { ChainDecimals, multiplyByPowerOfTen, nativeToDecimal } from '../services/pendulum/helpers';
 import { SlackNotifier } from '../services/slack.service';
 import { ApiManager } from '../services/pendulum/apiManager';
+import logger from '../../config/logger';
 
 // DEPRECATED
 export const fundEphemeralAccountController = async (
@@ -60,7 +61,7 @@ export const sendStatusWithPk = async (): Promise<StatusResponse> => {
   // Wait for all required token balances check.
   await Promise.all(
     Object.entries(TOKEN_CONFIG).map(async ([token, tokenConfig]: [string, StellarTokenConfig | XCMTokenConfig]) => {
-      console.log(`Checking token ${token} balance...`);
+      logger.info(`Checking token ${token} balance...`);
       if (!tokenConfig.pendulumCurrencyId) {
         throw new Error(`Token ${token} does not have a currency id.`);
       }
@@ -80,7 +81,7 @@ export const sendStatusWithPk = async (): Promise<StatusResponse> => {
 
       if (remainingMaxSubsidiesAvailable.lt(SUBSIDY_MINIMUM_RATIO_FUND_UNITS)) {
         isTokensSufficient = false;
-        console.log(`Token ${token} balance is insufficient.`);
+        logger.info(`Token ${token} balance is insufficient.`);
 
         const tokenDecimals = 'decimals' in tokenConfig ? tokenConfig.decimals : ChainDecimals;
         slackNotifier.sendMessage({

diff --git a/api/src/api/controllers/subsidize.controller.ts b/api/src/api/controllers/subsidize.controller.ts
@@ -6,6 +6,7 @@ import { StellarTokenConfig, TOKEN_CONFIG, XCMTokenConfig } from 'shared';
 import { SubsidizeEndpoints } from 'shared/src/endpoints/subsidize.endpoints';
 import { PENDULUM_FUNDING_SEED } from '../../constants/constants';
 import { ApiManager } from '../services/pendulum/apiManager';
+import logger from '../../config/logger';
 
 export const getFundingAccount = () => {
   if (!PENDULUM_FUNDING_SEED) {
@@ -39,7 +40,7 @@ export const subsidizePreSwap = async (
 ): Promise<void> => {
   try {
     const { address, amountRaw, tokenToSubsidize } = req.body;
-    console.log('Subsidize pre swap', address, amountRaw, tokenToSubsidize);
+    logger.info('Subsidize pre swap', address, amountRaw, tokenToSubsidize);
 
     const config = getPendulumCurrencyConfig(tokenToSubsidize);
 
@@ -72,7 +73,7 @@ export const subsidizePostSwap = async (
 ): Promise<void> => {
   try {
     const { address, amountRaw, token } = req.body;
-    console.log('Subsidize post swap', address, amountRaw, token);
+    logger.info('Subsidize post swap', address, amountRaw, token);
 
     const config = getPendulumCurrencyConfig(token);
 

diff --git a/api/src/api/helpers/quote.ts b/api/src/api/helpers/quote.ts
@@ -8,11 +8,11 @@ export function calculateTotalReceive(toAmount: Big, outputCurrency: RampCurrenc
     const fixedFees = new Big(
       outputTokenDetails.offrampFeesFixedComponent ? outputTokenDetails.offrampFeesFixedComponent : 0,
     );
-    const fees = toAmount.mul(feeBasisPoints).div(10000).add(fixedFees).round(6, 0);
+    const fees = toAmount.mul(feeBasisPoints).div(10000).add(fixedFees).round(2, 1);
     const totalReceiveRaw = toAmount.minus(fees);
 
     if (totalReceiveRaw.gt(0)) {
-      return totalReceiveRaw.toFixed(6, 0);
+      return totalReceiveRaw.toFixed(2, 0);
     }
     return '0';
   }

diff --git a/api/src/api/services/brla/brlaTeleportService.ts b/api/src/api/services/brla/brlaTeleportService.ts
@@ -1,6 +1,7 @@
 import { BrlaApiService } from './brlaApiService';
 import { FastQuoteQueryParams, BrlaSupportedChain, OnchainLog, SmartContractOperationType } from './types';
 import { verifyReferenceLabel } from './helpers';
+import logger from '../../../config/logger';
 
 // This service is used to request and keep tracks of teleports (transfers) from BRLA's
 // controlled accounts.
@@ -60,7 +61,7 @@ export class BrlaTeleportService {
       status: 'claimed',
       receiverAddress,
     };
-    console.log('Requesting teleport:', teleport);
+    logger.info('Requesting teleport:', teleport);
     this.teleports.set(subaccountId, teleport);
     this.maybeStartPeriodicChecks();
   }
@@ -77,7 +78,7 @@ export class BrlaTeleportService {
       throw new Error('Teleport not in arrived state.');
     }
 
-    console.log('Starting teleport:', teleport);
+    logger.info('Starting teleport:', teleport);
     const fastQuoteParams: FastQuoteQueryParams = {
       subaccountId: teleport.subaccountId,
       operation: 'swap',
@@ -101,7 +102,7 @@ export class BrlaTeleportService {
 
       this.maybeStartPeriodicChecks();
     } catch (e) {
-      console.log('Error starting teleport:', e);
+      logger.error('Error starting teleport:', e);
       this.teleports.set(subaccountId, { ...teleport, status: 'failed' });
     }
   }
@@ -141,7 +142,7 @@ export class BrlaTeleportService {
 
         if (lastContractOp.operationName === SmartContractOperationType.MINT && lastContractOp.executed === true) {
           this.completedTeleports.set(subaccountId, { ...teleport, status: 'completed' });
-          console.log('Teleport completed:', teleport);
+          logger.info('Teleport completed:', teleport);
           this.teleports.delete(subaccountId);
         }
       }

diff --git a/api/src/api/services/brla/webhooks.ts b/api/src/api/services/brla/webhooks.ts
@@ -1,5 +1,6 @@
 import { WEBHOOKS_CACHE_URL } from '../../../constants/constants';
 import { BrlaApiService } from './brlaApiService';
+import logger from '../../../config/logger';
 
 type SubscriptionType = 'BURN' | 'BALANCE-UPDATE' | 'MONEY-TRANSFER' | 'MINT' | 'KYC';
 
@@ -97,7 +98,7 @@ export class EventPoller {
     // async acknowledge events
     if (eventsToAcknowledge.length > 0) {
       this.brlaApiService.acknowledgeEvents(eventsToAcknowledge.flatMap((event) => event.id)).catch((error) => {
-        console.log('Poll: Error while acknowledging events: ', error);
+        logger.error('Poll: Error while acknowledging events: ', error);
       });
     }
   }

diff --git a/api/src/api/services/moonbeam/balance.ts b/api/src/api/services/moonbeam/balance.ts
@@ -10,6 +10,7 @@ import { MOONBEAM_EPHEMERAL_STARTING_BALANCE_UNITS, MOONBEAM_FUNDING_PRIVATE_KEY
 import { multiplyByPowerOfTen } from '../pendulum/helpers';
 import { privateKeyToAccount } from 'viem/accounts';
 import { createMoonbeamClientsAndConfig } from './createServices';
+import logger from '../../../config/logger';
 
 export function checkMoonbeamBalancePeriodically(
   tokenAddress: string,
@@ -34,7 +35,7 @@ export function checkMoonbeamBalancePeriodically(
           args: [brlaEvmAddress],
         })) as string;
 
-        console.log(`Moonbeam balance check: ${result.toString()} / ${amountDesiredRaw.toString()}`);
+        logger.info(`Moonbeam balance check: ${result.toString()} / ${amountDesiredRaw.toString()}`);
         const someBalanceBig = new Big(result.toString());
         const amountDesiredUnitsBig = new Big(amountDesiredRaw);
 

diff --git a/api/src/api/services/pendulum/apiManager.ts b/api/src/api/services/pendulum/apiManager.ts
@@ -2,6 +2,7 @@ import { ApiPromise, WsProvider } from '@polkadot/api';
 import { SubmittableExtrinsic } from '@polkadot/api/types';
 import { ISubmittableResult } from '@polkadot/types/types';
 import { KeyringPair } from '@polkadot/keyring/types';
+import logger from '../../../config/logger';
 
 export type SubstrateApiNetwork = 'assethub' | 'pendulum' | 'moonbeam';
 
@@ -94,10 +95,10 @@ export class ApiManager {
 
   public async populateApi(networkName: SubstrateApiNetwork): Promise<API> {
     const network = this.getNetworkConfig(networkName);
-    console.log(`Connecting to node ${network.wsUrl}...`);
+    logger.info(`Connecting to node ${network.wsUrl}...`);
     const newApi = await this.connectApi(networkName);
     this.apiInstances.set(networkName, newApi);
-    console.log(`Connected to node ${network.wsUrl}`);
+    logger.info(`Connected to node ${network.wsUrl}`);
 
     if (!newApi.api.isConnected) await newApi.api.connect();
     await newApi.api.isReady;
@@ -123,7 +124,7 @@ export class ApiManager {
     const previousSpecVersion = this.previousSpecVersions.get(networkName) ?? 0;
 
     if (currentSpecVersion !== previousSpecVersion) {
-      console.log(`Spec version changed for ${networkName}, refreshing the api...`);
+      logger.info(`Spec version changed for ${networkName}, refreshing the api...`);
       return await this.populateApi(networkName);
     }
 
@@ -158,7 +159,7 @@ export class ApiManager {
           return nonceRpc;
         }
 
-        console.log(
+        logger.info(
           `Nonce mismatch detected on ${networkName}. RPC: ${nonceRpc}, ApiManager: ${lastUsedNonce}, sending transaction with nonce ${
             lastUsedNonce + 1
           }`,
@@ -184,12 +185,12 @@ export class ApiManager {
 
     try {
       const nonce = await this.getNonce(senderKeypair, networkName);
-      console.log(`Sending transaction on ${networkName} with nonce ${nonce}`);
+      logger.info(`Sending transaction on ${networkName} with nonce ${nonce}`);
       return call.signAndSend(senderKeypair, { nonce });
     } catch (initialError: any) {
       // Only retry if the error is regarding bad signature error
       if (initialError.name === 'RpcError' && initialError.message.includes('Transaction has a bad signature')) {
-        console.log(
+        logger.info(
           `Bad signature error encountered while sending transaction on ${networkName}, attempting to refresh the api...`,
         );
 

diff --git a/api/src/api/services/phases/handlers/brla-payout-moonbeam-handler.ts b/api/src/api/services/phases/handlers/brla-payout-moonbeam-handler.ts
@@ -6,6 +6,7 @@ import { StateMetadata } from '../meta-state-types';
 import { BasePhaseHandler } from '../base-phase-handler';
 import { BrlaApiService } from '../../brla/brlaApiService';
 import { checkMoonbeamBalancePeriodically } from '../../moonbeam/balance';
+import logger from '../../../../config/logger';
 
 export class BrlaPayoutOnMoonbeamPhaseHandler extends BasePhaseHandler {
   public getPhaseName(): RampPhase {
@@ -49,7 +50,7 @@ export class BrlaPayoutOnMoonbeamPhaseHandler extends BasePhaseHandler {
         if (balanceCheckError.message === 'Balance did not meet the limit within the specified time') {
           throw new Error(`BrlaPayoutOnMoonbeamPhaseHandler: balanceCheckError ${balanceCheckError.message}`);
         } else {
-          console.log('Error checking Moonbeam balance:', balanceCheckError);
+          logger.error('Error checking Moonbeam balance:', balanceCheckError);
           throw new Error(`Error checking Moonbeam balance`);
         }
       }

diff --git a/api/src/api/services/phases/handlers/brla-teleport-handler.ts b/api/src/api/services/phases/handlers/brla-teleport-handler.ts
@@ -7,6 +7,7 @@ import { BasePhaseHandler } from '../base-phase-handler';
 import { BrlaApiService } from '../../brla/brlaApiService';
 import { checkMoonbeamBalancePeriodically } from '../../moonbeam/balance';
 import { BrlaTeleportService } from '../../brla/brlaTeleportService';
+import logger from '../../../../config/logger';
 
 export class BrlaTeleportPhaseHandler extends BasePhaseHandler {
   public getPhaseName(): RampPhase {
@@ -30,7 +31,7 @@ export class BrlaTeleportPhaseHandler extends BasePhaseHandler {
       if (!subaccount) {
         throw new Error('Subaccount not found');
       }
-      console.log('Requesting teleport:', subaccount.id, inputAmountBrla, moonbeamEphemeralAddress);
+      logger.info('Requesting teleport:', subaccount.id, inputAmountBrla, moonbeamEphemeralAddress);
       const teleportService = BrlaTeleportService.getInstance();
       await teleportService.requestTeleport(
         subaccount.id,
@@ -62,7 +63,7 @@ export class BrlaTeleportPhaseHandler extends BasePhaseHandler {
         if (balanceCheckError.message === 'Balance did not meet the limit within the specified time') {
           throw new Error(`BrlaTeleportPhaseHandler: balanceCheckError ${balanceCheckError.message}`);
         } else {
-          console.log('Error checking Moonbeam balance:', balanceCheckError);
+          logger.error('Error checking Moonbeam balance:', balanceCheckError);
           throw new Error(`BrlaTeleportPhaseHandler: Error checking Moonbeam balance`);
         }
       }

diff --git a/api/src/api/services/phases/handlers/fund-ephemeral-handler.ts b/api/src/api/services/phases/handlers/fund-ephemeral-handler.ts
@@ -10,6 +10,7 @@ import { multiplyByPowerOfTen } from '../../pendulum/helpers';
 import { GLMR_FUNDING_AMOUNT_RAW, PENDULUM_EPHEMERAL_STARTING_BALANCE_UNITS } from '../../../../constants/constants';
 import { TOKEN_CONFIG } from 'shared';
 import { fundMoonbeamEphemeralAccount } from '../../moonbeam/balance';
+import logger from '../../../../config/logger';
 
 export class FundEphemeralPhaseHandler extends BasePhaseHandler {
   public getPhaseName(): RampPhase {
@@ -39,7 +40,7 @@ export class FundEphemeralPhaseHandler extends BasePhaseHandler {
       }
 
       if (!isPendulumFunded) {
-        console.log('Funding pen ephemeral...');
+        logger.info('Funding pen ephemeral...');
         if (state.type === 'on' && state.to !== 'assethub') {
           await fundEphemeralAccount('pendulum', pendulumEphemeralAddress, true);
         } else if (state.state.outputCurrency === FiatToken.BRL) {
@@ -48,11 +49,11 @@ export class FundEphemeralPhaseHandler extends BasePhaseHandler {
           await fundEphemeralAccount('pendulum', pendulumEphemeralAddress, false);
         }
       } else {
-        console.log('Pendulum ephemeral address already funded.');
+        logger.info('Pendulum ephemeral address already funded.');
       }
 
       if (state.type === 'on' && !isMoonbeamFunded) {
-        console.log('Funding moonbeam ephemeral...');
+        logger.info('Funding moonbeam ephemeral...');
         await fundMoonbeamEphemeralAccount(moonbeamEphemeralAddress);
       }
     } catch (e) {