Create new production release

.gitignore

@@ -42,6 +42,8 @@ dist-ssr
 **/failedRampStateRecovery.json
 **/lastRampState.json
 **/lastRampStateOnramp.json
+**/lastRampStateMykoboEur.json
+**/lastRampStateMykoboEurOnramp.json
 
 
 *storybook.log

apps/api/.env.example

@@ -51,10 +51,6 @@ COINGECKO_API_KEY=your-coingecko-api-key
 COINGECKO_API_URL=https://pro-api.coingecko.com/api/v3
 SUBSCAN_API_KEY=your-subscan-api-key
 
-# EUR / Monerium
-MONERIUM_CLIENT_ID_APP=your-monerium-client-id
-MONERIUM_CLIENT_SECRET=your-monerium-client-secret
-
 # Price Feed Cache Configuration
 CRYPTO_CACHE_TTL_MS=300000
 FIAT_CACHE_TTL_MS=300000

apps/api/.gitignore

@@ -49,3 +49,5 @@ jspm_packages
 */failedRampStateRecovery.json
 */lastRampState.json
 */lastRampStateOnramp.json
+*/lastRampStateMykoboEur.json
+*/lastRampStateMykoboEurOnramp.json

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

@@ -0,0 +1,131 @@
+import { MykoboApiError, MykoboApiService, MykoboProfile } from "@vortexfi/shared";
+import { Request, Response } from "express";
+import httpStatus from "http-status";
+import { isAddress } from "viem";
+import logger from "../../config/logger";
+import { upsertMykoboCustomerFromProfile } from "../services/mykobo/mykobo-customer.service";
+
+const PROFILE_TEXT_FIELDS = [
+  "first_name",
+  "last_name",
+  "additional_name",
+  "email_address",
+  "mobile_number",
+  "birth_date",
+  "birth_country_code",
+  "address_line_1",
+  "city",
+  "id_country_code",
+  "id_type",
+  "bank_account_number",
+  "bank_number",
+  "wallet_address",
+  "source_of_funds",
+  "tax_country",
+  "tax_id",
+  "tax_id_name",
+  "memo"
+] as const;
+
+const PROFILE_FILE_FIELDS = ["front", "back", "face", "utility_bill"] as const;
+
+const toFrontendProfile = (p: MykoboProfile) => ({
+  bankAccountNumber: p.bank_account_number,
+  createdAt: p.created_at,
+  emailAddress: p.email_address,
+  firstName: p.first_name,
+  kycStatus: {
+    receivedAt: p.kyc_status.received_at,
+    reviewStatus: p.kyc_status.review_status
+  },
+  lastName: p.last_name
+});
+
+const emailsMatch = (a: string | undefined, b: string | undefined): boolean =>
+  !!a && !!b && a.trim().toLowerCase() === b.trim().toLowerCase();
+
+export const getProfileController = async (req: Request, res: Response): Promise<void> => {
+  const { email, memo } = req.query;
+  const userEmail = req.userEmail;
+
+  if (!userEmail) {
+    res.status(httpStatus.UNAUTHORIZED).json({ error: "Authenticated user email missing" });
+    return;
+  }
+  if (!email || typeof email !== "string" || !emailsMatch(email, userEmail)) {
+    res.status(httpStatus.BAD_REQUEST).json({ error: "Invalid email parameter" });
+    return;
+  }
+
+  try {
+    const memoParam = typeof memo === "string" && memo.length > 0 ? memo : undefined;
+    const { profile } = await MykoboApiService.getInstance().getProfileByEmail(userEmail, memoParam);
+    if (!emailsMatch(profile.email_address, userEmail)) {
+      res.status(httpStatus.NOT_FOUND).json({ error: "Profile not found" });
+      return;
+    }
+    if (req.userId) {
+      try {
+        await upsertMykoboCustomerFromProfile(req.userId, userEmail, profile);
+      } catch (mirrorError) {
+        logger.error("Failed to update Mykobo customer mirror in getProfileController:", mirrorError);
+      }
+    }
+    res.json({ profile: toFrontendProfile(profile) });
+  } catch (error) {
+    if (error instanceof MykoboApiError && error.status === 404) {
+      res.status(httpStatus.NOT_FOUND).json({ error: "Profile not found" });
+      return;
+    }
+    logger.error("Error in getProfileController:", error);
+    res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ error: "Internal Server Error" });
+  }
+};
+
+export const createProfileController = async (req: Request, res: Response): Promise<void> => {
+  const userEmail = req.userEmail;
+  if (!userEmail) {
+    res.status(httpStatus.UNAUTHORIZED).json({ error: "Authenticated user email missing" });
+    return;
+  }
+
+  try {
+    const body = (req.body ?? {}) as Record<string, unknown>;
+
+    const walletAddress = body.wallet_address;
+    if (typeof walletAddress !== "string" || !isAddress(walletAddress)) {
+      res.status(httpStatus.BAD_REQUEST).json({ error: "Invalid wallet_address" });
+      return;
+    }
+
+    const formData = new FormData();
+    for (const field of PROFILE_TEXT_FIELDS) {
+      if (field === "email_address") continue;
+      const value = body[field];
+      if (typeof value === "string" && value.length > 0) {
+        formData.append(field, value);
+      }
+    }
+    formData.append("email_address", userEmail);
+
+    const files = (req as Request & { files?: Record<string, Express.Multer.File[]> }).files;
+    if (files && typeof files === "object") {
+      for (const fieldname of PROFILE_FILE_FIELDS) {
+        const file = files[fieldname]?.[0];
+        if (!file) continue;
+        formData.append(fieldname, new Blob([new Uint8Array(file.buffer)], { type: file.mimetype }), file.originalname);
+      }
+    }
+
+    const { profile } = await MykoboApiService.getInstance().createProfile(formData);
+    res.status(httpStatus.CREATED).json({ profile: toFrontendProfile(profile) });
+  } catch (error) {
+    if (error instanceof MykoboApiError) {
+      logger.warn(`Mykobo /profiles upstream error: status=${error.status}`);
+      res.status(error.status).json({ error: "Mykobo profile creation failed" });
+      return;
+    }
+    logger.error("Error in createProfileController:", error);
+    res.status(httpStatus.INTERNAL_SERVER_ERROR).json({ error: "Internal Server Error" });
+  }
+};

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

@@ -3,7 +3,6 @@ import {
   PendulumFundEphemeralErrorResponse,
   PendulumFundEphemeralRequest,
   PendulumFundEphemeralResponse,
-  StellarTokenConfig,
   TOKEN_CONFIG,
   XCMTokenConfig
 } from "@vortexfi/shared";
@@ -66,7 +65,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]) => {
+    Object.entries(TOKEN_CONFIG).map(async ([token, tokenConfig]: [string, XCMTokenConfig]) => {
       logger.info(`Checking token ${token} balance...`);
       if (!tokenConfig.pendulumCurrencyId) {
         throw new Error(`Token ${token} does not have a currency id.`);

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

@@ -15,6 +15,7 @@ import { NextFunction, Request, Response } from "express";
 import httpStatus from "http-status";
 import logger from "../../config/logger";
 import { APIError } from "../errors/api-error";
+import { enrichAdditionalDataWithClientIp } from "../helpers/clientIp";
 import { assertQuoteOwnership, assertRampOwnership } from "../middlewares/ownershipAuth";
 import rampService from "../services/ramp/ramp.service";
 
@@ -36,9 +37,10 @@ export const registerRamp = async (req: Request, res: Response<RampProcess>, nex
 
     await assertQuoteOwnership(req, quoteId);
 
-    // Start ramping process
+    const enrichedAdditionalData = await enrichAdditionalDataWithClientIp(additionalData, req);
+
     const ramp = await rampService.registerRamp({
-      additionalData,
+      additionalData: enrichedAdditionalData,
       quoteId,
       signingAccounts,
       userId: req.userId

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

@@ -19,22 +19,6 @@ export const DUMP_SHEET_COMMON_HEADERS = [
   "outputTokenType"
 ];
 
-export const DUMP_SHEET_HEADER_VALUES_ASSETHUB_TO_STELLAR = [
-  ...DUMP_SHEET_COMMON_HEADERS,
-  "offramperAddress",
-  "stellarEphemeralPublicKey",
-  "spacewalkRedeemTx",
-  "stellarOfframpTx",
-  "stellarCleanupTx"
-];
-
-export const DUMP_SHEET_HEADER_VALUES_EVM_TO_STELLAR = [
-  ...DUMP_SHEET_COMMON_HEADERS,
-  "offramperAddress",
-  "squidRouterReceiverId",
-  "squidRouterReceiverHash"
-];
-
 export const DUMP_SHEET_HEADER_VALUES_ASSETHUB_TO_BRLA = [
   ...DUMP_SHEET_COMMON_HEADERS,
   "offramperAddress",
@@ -65,11 +49,9 @@ export const DUMP_SHEET_HEADER_VALUES_BRLA_TO_ASSETHUB = [
 
 export const FLOW_HEADERS: Record<FlowType, FlowHeaders> = {
   "assethub-to-brla": DUMP_SHEET_HEADER_VALUES_ASSETHUB_TO_BRLA,
-  "assethub-to-stellar": DUMP_SHEET_HEADER_VALUES_ASSETHUB_TO_STELLAR,
   "brla-to-assethub": DUMP_SHEET_HEADER_VALUES_BRLA_TO_ASSETHUB,
   "brla-to-evm": DUMP_SHEET_HEADER_VALUES_BRLA_TO_EVM,
-  "evm-to-brla": DUMP_SHEET_HEADER_VALUES_EVM_TO_BRLA,
-  "evm-to-stellar": DUMP_SHEET_HEADER_VALUES_EVM_TO_STELLAR
+  "evm-to-brla": DUMP_SHEET_HEADER_VALUES_EVM_TO_BRLA
 };
 export const storeData = async (req: Request, res: Response<StoreDataResponse | StoreDataErrorResponse>): Promise<void> => {
   if (!spreadsheet.storageSheetId) {