[WIP] Add Alfredpay ARS support

.clinerules/01-general-rules.md

@@ -7,7 +7,7 @@
 
 ## Architecture Decision Records
 
-Create ADRs in /docs/adr for:
+Create ADRs in /docs/adr for:  
 
 - Major dependency changes
 - Architectural pattern changes

.github/workflows/autodeploy.yaml

@@ -3,7 +3,7 @@ run-name: Gitlab Pipeline Executor
 on:
   push:
     branches:
-      - staging
+      - main
 jobs:
   Execute-Gitlab-Pipeline:
     runs-on: ubuntu-latest
@@ -13,4 +13,4 @@ jobs:
       - name: Triggers Gitlab Pipeline
         run: |
           ls ${{ github.workspace }}
-          curl -X POST -F token=${{ secrets.GITLAB_TRIGGER }} -F "ref=development" -F "variables[PRODUCTION]=N" -F "variables[STAGING]=N" -F "variables[STAGVTX]=Y" -F "variables[PRODPOL]=N" -F "variables[STAGPOL]=N" https://gitlab.com/api/v4/projects/${{ secrets.PROJECT_ID }}/trigger/pipeline
+          curl -X POST -F token=${{ secrets.GITLAB_TRIGGER }} -F "ref=development" -F "variables[PRODVTX]=Y" https://gitlab.com/api/v4/projects/${{ secrets.PROJECT_ID }}/trigger/pipeline

apps/api/src/api/controllers/alfredpay.controller.ts

@@ -130,8 +130,20 @@ export class AlfredpayController {
 
       const alfredpayService = AlfredpayApiService.getInstance();
 
-      const newCustomer = await alfredpayService.createCustomer(userEmail, AlfredpayCustomerType.INDIVIDUAL, country);
-      const customerId = newCustomer.customerId;
+      let customerId: string;
+      try {
+        const newCustomer = await alfredpayService.createCustomer(userEmail, AlfredpayCustomerType.INDIVIDUAL, country);
+        customerId = newCustomer.customerId;
+      } catch (error) {
+        const errorMessage = (error as Error)?.message || "";
+        if (errorMessage.includes("409") || errorMessage.includes("already registered")) {
+          logger.info("Customer already exists in Alfredpay, fetching existing customer");
+          const existingCustomer = await alfredpayService.findCustomer(userEmail, country);
+          customerId = existingCustomer.customerId;
+        } else {
+          throw error;
+        }
+      }
 
       await AlfredPayCustomer.create({
         alfredPayId: customerId,
@@ -340,7 +352,7 @@ export class AlfredpayController {
         const linkResponse = await alfredpayService.getKybRedirectLink(alfredPayCustomer.alfredPayId);
         await alfredPayCustomer.update({ status: AlfredPayStatus.Consulted });
         return res.json(linkResponse as AlfredpayGetKybRedirectLinkResponse);
-      } else if (country === "MX" || country === "CO") {
+      } else if (country === "MX" || country === "CO" || country === "AR") {
         // MX/CO use API-based (form) KYC — no redirect link needed.
         // Just reset status so the user can re-fill the form.
         await alfredPayCustomer.update({ status: AlfredPayStatus.Consulted });
@@ -379,8 +391,20 @@ export class AlfredpayController {
 
       const alfredpayService = AlfredpayApiService.getInstance();
 
-      const newCustomer = await alfredpayService.createCustomer(userEmail, type, country);
-      const customerId = newCustomer.customerId;
+      let customerId: string;
+      try {
+        const newCustomer = await alfredpayService.createCustomer(userEmail, type, country);
+        customerId = newCustomer.customerId;
+      } catch (error) {
+        const errorMessage = (error as Error)?.message || "";
+        if (errorMessage.includes("409") || errorMessage.includes("already registered")) {
+          logger.info("Business customer already exists in Alfredpay, fetching existing customer");
+          const existingCustomer = await alfredpayService.findCustomer(userEmail, country);
+          customerId = existingCustomer.customerId;
+        } else {
+          throw error;
+        }
+      }
 
       await AlfredPayCustomer.create({
         alfredPayId: customerId,
@@ -443,7 +467,7 @@ export class AlfredpayController {
 
   static async submitKycInformation(req: Request, res: Response) {
     try {
-      const { country, ...kycData } = req.body as SubmitKycInformationRequest & { country: string };
+      const { country, ...kycData } = req.body as SubmitKycInformationRequest;
       const userId = req.userId!;
 
       const alfredPayCustomer = await AlfredPayCustomer.findOne({
@@ -455,7 +479,21 @@ export class AlfredpayController {
       }
 
       const alfredpayService = AlfredpayApiService.getInstance();
-      const result = await alfredpayService.submitKycInformation(alfredPayCustomer.alfredPayId, { ...kycData, country });
+      let result: Awaited<ReturnType<typeof alfredpayService.submitKycInformation>>;
+      try {
+        result = await alfredpayService.submitKycInformation(alfredPayCustomer.alfredPayId, { ...kycData, country });
+      } catch (error) {
+        const errorMessage = (error as Error)?.message || "";
+        if (errorMessage.includes("422") && errorMessage.includes("KYC record cannot be retried")) {
+          logger.info("KYC record cannot be retried, fetching existing submission");
+          const existingSubmission = await alfredpayService.getLastKycSubmission(alfredPayCustomer.alfredPayId);
+          result = { submissionId: existingSubmission.submissionId } as Awaited<
+            ReturnType<typeof alfredpayService.submitKycInformation>
+          >;
+        } else {
+          throw error;
+        }
+      }
 
       res.json(result);
     } catch (error) {
@@ -481,7 +519,12 @@ export class AlfredpayController {
       if (!alfredPayCustomer) {
         return res.status(404).json({ error: "Alfredpay customer not found" });
       }
-
+      console.log("Received request to submit KYC file with data:", {
+        country,
+        fileName: req.file.originalname,
+        fileType,
+        submissionId
+      });
       const fileBlob = new File([new Uint8Array(req.file.buffer)], req.file.originalname, { type: req.file.mimetype });
       const alfredpayService = AlfredpayApiService.getInstance();
       await alfredpayService.submitKycFile(
@@ -537,7 +580,21 @@ export class AlfredpayController {
       }
 
       const alfredpayService = AlfredpayApiService.getInstance();
-      const result = await alfredpayService.submitKybInformation(alfredPayCustomer.alfredPayId, { ...kybData, country });
+      let result: Awaited<ReturnType<typeof alfredpayService.submitKybInformation>>;
+      try {
+        result = await alfredpayService.submitKybInformation(alfredPayCustomer.alfredPayId, { ...kybData, country });
+      } catch (error) {
+        const errorMessage = (error as Error)?.message || "";
+        if (errorMessage.includes("422") && errorMessage.includes("KYC record cannot be retried")) {
+          logger.info("KYB record cannot be retried, fetching existing submission");
+          const existingSubmission = await alfredpayService.getLastKybSubmission(alfredPayCustomer.alfredPayId);
+          result = { submissionId: existingSubmission.submissionId } as Awaited<
+            ReturnType<typeof alfredpayService.submitKybInformation>
+          >;
+        } else {
+          throw error;
+        }
+      }
 
       res.json(result);
     } catch (error) {
@@ -729,6 +786,11 @@ export class AlfredpayController {
           accountType: accountType ?? "",
           metadata: { accountHolderName: accountName, documentNumber, documentType }
         };
+      } else if (alfredpayFiatAccountType === AlfredpayFiatAccountType.COELSA) {
+        fiatAccountFields = {
+          accountNumber,
+          accountType: accountType ?? ""
+        };
       } else {
         // BANK_USA — external accounts need address fields inside metadata
         fiatAccountFields = isExternal

apps/api/src/api/middlewares/validators.ts

@@ -14,6 +14,7 @@ import {
   PriceProvider,
   QuoteError,
   RampDirection,
+  SubmitKycInformationRequest,
   TokenConfig,
   VALID_CRYPTO_CURRENCIES,
   VALID_FIAT_CURRENCIES,
@@ -483,6 +484,34 @@ export const validateGetWidgetUrlInput: RequestHandler<unknown, unknown, GetWidg
   next();
 };
 
+const countryValidators: Record<string, (body: SubmitKycInformationRequest) => string | null> = {
+  AR: ({ phoneNumber, cuit, nationalities, pep }) => {
+    if (!phoneNumber) return "Phone number is required for Argentina";
+    if (!phoneNumber.startsWith("+54")) return "Phone number must use Argentina country code (+54)";
+    if (cuit && !/^\d{11}$/.test(cuit)) return "CUIT must be exactly 11 digits";
+    if (nationalities && !nationalities.every(n => /^[A-Z]{2}$/.test(n))) return "Nationalities must use alpha-2 country codes";
+    if (typeof pep !== "boolean") return "PEP declaration is required for Argentina";
+    return null;
+  }
+};
+
+export const validateKycSubmission: RequestHandler = (req, res, next) => {
+  const body = req.body as SubmitKycInformationRequest;
+  const validator = countryValidators[body.country];
+
+  if (!validator) {
+    return next();
+  }
+
+  const error = validator(body);
+  if (error) {
+    res.status(httpStatus.BAD_REQUEST).json({ error });
+    return;
+  }
+
+  next();
+};
+
 export const validateStartKyc2: RequestHandler = (req, res, next) => {
   const { documentType } = req.body as AveniaKYCDataUploadRequest;
 

apps/api/src/api/routes/v1/alfredpay.route.ts

@@ -3,6 +3,7 @@ import multer from "multer";
 import { AlfredpayController } from "../../controllers/alfredpay.controller";
 import { validateResultCountry } from "../../middlewares/alfredpay.middleware";
 import { requireAuth } from "../../middlewares/supabaseAuth";
+import { validateKycSubmission } from "../../middlewares/validators";
 
 const router = Router();
 const upload = multer({ limits: { fileSize: 5 * 1024 * 1024 }, storage: multer.memoryStorage() });
@@ -18,7 +19,13 @@ router.post("/createBusinessCustomer", requireAuth, validateResultCountry, Alfre
 router.get("/getKybRedirectLink", requireAuth, validateResultCountry, AlfredpayController.getKybRedirectLink);
 
 // MXN/CO API-based KYC
-router.post("/submitKycInformation", requireAuth, validateResultCountry, AlfredpayController.submitKycInformation);
+router.post(
+  "/submitKycInformation",
+  requireAuth,
+  validateResultCountry,
+  validateKycSubmission,
+  AlfredpayController.submitKycInformation
+);
 router.post("/submitKycFile", requireAuth, upload.single("file"), validateResultCountry, AlfredpayController.submitKycFile);
 router.post("/sendKycSubmission", requireAuth, validateResultCountry, AlfredpayController.sendKycSubmission);
 

apps/api/src/api/services/phases/handlers/brla-onramp-mint-handler.ts

@@ -85,9 +85,7 @@ export class BrlaOnrampMintHandler extends BasePhaseHandler {
     // transferred to the ephemeral. We accept a balance of at least 95% of the
     // pre-computed expected amount to account for fee differences between quote
     // creation time and execution time.
-    const recoveryThresholdRaw = new Big(preComputedExpectedAmountRaw)
-      .times(EPHEMERAL_FUNDED_TOLERANCE_FACTOR)
-      .toFixed(0, 0);
+    const recoveryThresholdRaw = new Big(preComputedExpectedAmountRaw).times(EPHEMERAL_FUNDED_TOLERANCE_FACTOR).toFixed(0, 0);
 
     if (await this.ephemeralAlreadyFunded(tokenDetails.erc20AddressSourceChain, evmEphemeralAddress, recoveryThresholdRaw)) {
       logger.info(
@@ -149,10 +147,7 @@ export class BrlaOnrampMintHandler extends BasePhaseHandler {
     // Derive the expected on-chain amount from the live quote's outputAmount rather than
     // the stale pre-computed metadata value. The live quote accounts for the actual fees
     // applied at execution time, so this is the amount that will truly arrive on Base.
-    const expectedAmountReceived = multiplyByPowerOfTen(
-      new Big(aveniaQuote.outputAmount),
-      tokenDetails.decimals
-    ).toFixed(0, 0);
+    const expectedAmountReceived = multiplyByPowerOfTen(new Big(aveniaQuote.outputAmount), tokenDetails.decimals).toFixed(0, 0);
 
     logger.info(
       `BrlaOnrampMintHandler: Live Avenia quote output is ${aveniaQuote.outputAmount} BRLA (raw: ${expectedAmountReceived}). Pre-computed metadata value was ${preComputedExpectedAmountRaw}.`

apps/api/src/api/services/priceFeed.service.ts

@@ -116,7 +116,7 @@ export class PriceFeedService {
     logger.debug(`Cache miss for ${cacheKey}. Fetching from CoinGecko API.`);
 
     try {
-      logger.debug(`Fetching price for ${tokenId} in ${vsCurrency} from CoinGecko`);
+      logger.info(`Fetching price for ${tokenId} in ${vsCurrency} from CoinGecko`);
 
       // Construct the API URL
       const url = new URL(`${this.coingeckoApiBaseUrl}/simple/price`);
@@ -200,7 +200,7 @@ export class PriceFeedService {
     }
 
     // Check if the currency has a Pendulum representative (Nabla pool).
-    // Currencies like MXN and COP are TokenType.Fiat with no Pendulum pool — use CoinGecko for those.
+    // Currencies like MXN, COP, and ARS are TokenType.Fiat with no Pendulum pool — use CoinGecko for those.
     let outputTokenPendulumDetails;
     try {
       outputTokenPendulumDetails = getPendulumDetails(toCurrency);

apps/api/src/api/services/quote/core/helpers.ts

@@ -31,6 +31,7 @@ export const SUPPORTED_CHAINS: {
     from: [
       EPaymentMethod.PIX as DestinationType,
       EPaymentMethod.SEPA as DestinationType,
+      EPaymentMethod.CBU as DestinationType,
       EPaymentMethod.ACH as DestinationType,
       EPaymentMethod.SPEI as DestinationType
     ],

apps/api/src/api/services/quote/engines/finalize/onramp.ts

@@ -49,7 +49,8 @@ export class OnRampFinalizeEngine extends BaseFinalizeEngine {
     } else if (
       request.inputCurrency === FiatToken.USD ||
       request.inputCurrency === FiatToken.MXN ||
-      request.inputCurrency === FiatToken.COP
+      request.inputCurrency === FiatToken.COP ||
+      request.inputCurrency === FiatToken.ARS
     ) {
       // evmToEvm is set when Squid Router ran (e.g. USDC Polygon → USDT Arbitrum).
       // When destination is USDC on Polygon, Squid Router is skipped (skipRouteCalculation)

apps/api/src/api/services/quote/engines/initialize/offramp-from-evm-alfredpay.ts

@@ -30,7 +30,6 @@ export class OffRampFromEvmInitializeEngine extends BaseInitializeEngine {
       rampType: req.rampType,
       toNetwork: this.network
     };
-
     const bridgeQuote = await getEvmBridgeQuote(quoteRequest);
 
     ctx.evmToEvm = {

apps/api/src/api/services/quote/routes/route-resolver.ts

@@ -70,9 +70,10 @@ export class RouteResolver {
       case "wire":
       case "ach":
       case "spei":
+      case "cbu":
         return offrampEvmToAlfredpayStrategy;
       case "sepa":
-      case "cbu":
+
       default:
         return offrampToStellarStrategy;
     }

apps/api/src/api/services/transactions/onramp/routes/alfredpay-to-evm.ts

@@ -72,7 +72,8 @@ export async function prepareAlfredpayToEvmOnrampTransactions({
   const fiatToCountry: Partial<Record<FiatToken, AlfredPayCountry>> = {
     [FiatToken.USD]: AlfredPayCountry.US,
     [FiatToken.MXN]: AlfredPayCountry.MX,
-    [FiatToken.COP]: AlfredPayCountry.CO
+    [FiatToken.COP]: AlfredPayCountry.CO,
+    [FiatToken.ARS]: AlfredPayCountry.AR
   };
   const customerCountry = fiatToCountry[quote.inputCurrency as FiatToken];
   if (!customerCountry) {

apps/frontend/src/components/Alfredpay/AlfredpayKycFlow.tsx

@@ -1,5 +1,6 @@
 import { useCallback } from "react";
 import { useAlfredpayKycActor, useAlfredpayKycSelector } from "../../contexts/rampState";
+import { ArKycFormScreen } from "./ArKycFormScreen";
 import { ColKycFormScreen } from "./ColKycFormScreen";
 import { CustomerDefinitionScreen } from "./CustomerDefinitionScreen";
 import { DoneScreen } from "./DoneScreen";
@@ -59,6 +60,7 @@ export const AlfredpayKycFlow = () => {
   const kycOrKyb = context.business ? "KYB" : "KYC";
   const isMxn = context.country === "MX";
   const isCo = context.country === "CO";
+  const isAr = context.country === "AR";
 
   if (
     stateValue === "CheckingStatus" ||
@@ -86,8 +88,13 @@ export const AlfredpayKycFlow = () => {
     return <ColKycFormScreen onSubmit={submitForm} />;
   }
 
-  if (stateValue === "UploadingDocuments" && (isMxn || isCo)) {
-    return <MxnDocumentUploadScreen onSubmit={submitFiles} />;
+  if (stateValue === "FillingKycForm" && isAr) {
+    return <ArKycFormScreen onSubmit={submitForm} />;
+  }
+
+  if (stateValue === "UploadingDocuments" && (isMxn || isCo || isAr)) {
+    const includeSelfie = isAr;
+    return <MxnDocumentUploadScreen includeSelfie={includeSelfie} onSubmit={submitFiles} />;
   }
 
   if (stateValue === "FillingKybForm") {