Examples

// Connects to the MPS event stream (Socket.IO) and calls `onEvent` for every
// event, then resolves once a settlement reaches a terminal state (completed /
// dead) for the given wallet.

import * as io from "socket.io-client";

export interface SettlementResult {
  status: "completed" | "dead" | string;
  queueItemId: string;
  txHash: string | null;
}

export function watchSettlement(opts: {
  mpsUrl: string; // e.g. https://mps-api.mayan.finance
  apiKey: string;
  walletAddress: string; // resolve when this wallet reaches a terminal status
  onEvent?: (evt: any) => void;
}): Promise<SettlementResult> {
  const target = opts.walletAddress.toLowerCase();

  return new Promise((resolve, reject) => {
    const socket = io.connect(opts.mpsUrl, {
      transports: ["websocket"],
      extraHeaders: {
        'x-api-key': opts.apiKey,
      }
    });

    socket.on("connect", () => console.log("WS connected"));
    socket.on("connect_error", (err: Error) => reject(new Error(`WebSocket error: ${err.message}`)));

    // Every event arrives on the "event" channel as { type, data, timestamp }.
    socket.on("event", (evt: any) => {
      opts.onEvent?.(evt);

      // Only react to this wallet's terminal transition.
      const wallet = (evt.data?.walletAddress ?? "").toLowerCase();
      if (evt.type === "status_changed" && evt.data?.terminal && wallet === target) {
        socket.disconnect();
        resolve({ status: evt.data.status, queueItemId: evt.data.queueItemId, txHash: evt.data.txHash ?? null });
      }
    });
  });
}

// Fetches a Mayan quote with mpsDeposit enabled and returns the MPS deposit
// address on the source chain. Send the input token to it and MPS settles the
// swap to your destination — no signature required.

export async function getMpsDepositAddress(opts: {
  priceUrl: string;           // e.g. https://price-api.mayan.finance
  apiKey: string;             // your Mayan API key (the deposit address is tied to it)
  amountIn64: string;         // input amount in base units
  fromChain: string;          // source chain name, e.g. "base" | "solana"
  fromToken: string;          // input token address/mint
  toChain: string;            // destination chain name
  toToken: string;            // destination token address
  destinationAddress: string; // final recipient
  mpsUserId?: string;         // optional integrator-scoped id (else derived from your key)
}): Promise<string> {
  const res = await fetch(`${opts.priceUrl}/v3/quote?apiKey=${opts.apiKey}`, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      amountIn64: opts.amountIn64,
      fromChain: opts.fromChain,
      fromToken: opts.fromToken,
      toChain: opts.toChain,
      toToken: opts.toToken,
      slippageBps: "auto",
      destinationAddress: opts.destinationAddress,
      mpsDeposit: true,
      ...(opts.mpsUserId ? { mpsUserId: opts.mpsUserId } : {}),
      solanaProgram: "FC4eXxkyrMPTjiYUpp4EAnkmwMbQyZ6NDCh1kfLn6vsf",
      forwarderAddress: "0x337685fdaB40D39bd02028545a4FfA7D287cC3E2",
      swift: true, mctp: true, fastMctp: true, monoChain: true, fullList: true,
      sdkVersion: "15_2_2",
    }),
  });
  if (!res.ok) throw new Error(`quote failed: ${res.status} ${await res.text()}`);

  const { quotes } = await res.json();
  // All eligible quotes carry the same address; take the first non-null one.
  const address = quotes?.map((q: any) => q.mpsDepositAddress).find(Boolean);
  if (!address) {
    throw new Error(
      "No mpsDepositAddress in quotes — is the amount above the token's minimum deposit?",
    );
  }
  return address as string;
}

import { getMpsDepositAddress } from "./mps-quote";
import { watchSettlement } from "./listen";

const MPS_URL = process.env.MPS_URL || "https://mps-api.mayan.finance";
const PRICE_URL = process.env.PRICE_URL || "https://price-api.mayan.finance";
const API_KEY = process.env.MAYAN_API_KEY;
if (!API_KEY) throw new Error("Set MAYAN_API_KEY");

const USDC_BASE = "0x833589fcd6edb6e08f4c7c32d4f71b54bda02913";
const USDC_ARB = "0xaf88d065e77c8cC2239327C5EDb3A432268e5831"; // USDC on Arbitrum (dest)
const DEST_WALLET = process.env.DEST_WALLET || "0xEab4Fb2De5a05Ba392eB2614bd2293592d455A4f";

// 1. Get the MPS deposit address from a quote (source = Base).
const depositAddress = await getMpsDepositAddress({
  priceUrl: PRICE_URL,
  apiKey: API_KEY,
  amountIn64: "5000000", // ~5 USDC (6 decimals)
  fromChain: "base",
  fromToken: USDC_BASE,
  toChain: "arbitrum",
  toToken: USDC_ARB,
  destinationAddress: DEST_WALLET,
});

console.log(`\n➡️  Send ~5 USDC to this address on BASE:\n   ${depositAddress}\n`);
console.log("Waiting for the deposit and settlement (Ctrl-C to stop)...\n");

// 2. Watch the event stream until the settlement is terminal.
const result = await watchSettlement({
  mpsUrl: MPS_URL,
  apiKey: API_KEY,
  walletAddress: depositAddress,
  onEvent: (evt) => {
    if (evt.type === "deposit_detected") {
      console.log(`💰 deposit detected — queued=${evt.data.queued}${evt.data.ignoredReason ? ` (${evt.data.ignoredReason})` : ""}`);
    } else if (evt.type === "status_changed") {
      const err = evt.data.error ? ` [${evt.data.error.code}]` : "";
      console.log(`   → ${evt.data.status}${err} (retry ${evt.data.retryCount})`);
    }
  },
});

// 3. Report the outcome.
if (result.status === "completed") {
  console.log(`\n✅ Settled — USDC delivered on Arbitrum.`);
  if (result.txHash) console.log(`   Explorer: https://explorer.mayan.finance/tx/${result.txHash}`);
} else {
  console.log(`\n❌ Ended as "${result.status}". Check GET /swaps for the error.`);
}
process.exit(0);

import { getMpsDepositAddress } from "./mps-quote";
import { watchSettlement } from "./listen";

const MPS_URL = process.env.MPS_URL || "https://mps-api.mayan.finance";
const PRICE_URL = process.env.PRICE_URL || "https://price-api.mayan.finance";
const API_KEY = process.env.MAYAN_API_KEY;
if (!API_KEY) throw new Error("Set MAYAN_API_KEY");

const USDC_SOLANA = "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v";
const USDC_ARB = "0xaf88d065e77c8cC2239327C5EDb3A432268e5831"; // USDC on Arbitrum (dest)
const DEST_WALLET = process.env.DEST_WALLET || "0xEab4Fb2De5a05Ba392eB2614bd2293592d455A4f";

// 1. Get the MPS deposit address from a quote (source = Solana → a Solana vault).
//    The destination can be any supported deposit-address chain; here it's Arbitrum.
const depositAddress = await getMpsDepositAddress({
  priceUrl: PRICE_URL,
  apiKey: API_KEY,
  amountIn64: "5000000", // ~5 USDC (6 decimals)
  fromChain: "solana",
  fromToken: USDC_SOLANA,
  toChain: "arbitrum",
  toToken: USDC_ARB,
  destinationAddress: DEST_WALLET,
});

console.log(`\n➡️  Send ~5 USDC to this vault on SOLANA:\n   ${depositAddress}\n`);
console.log("Waiting for the deposit and settlement (Ctrl-C to stop)...\n");

// 2. Watch the event stream until the settlement is terminal.
const result = await watchSettlement({
  mpsUrl: MPS_URL,
  apiKey: API_KEY,
  walletAddress: depositAddress,
  onEvent: (evt) => {
    if (evt.type === "deposit_detected") {
      console.log(`💰 deposit detected — queued=${evt.data.queued}${evt.data.ignoredReason ? ` (${evt.data.ignoredReason})` : ""}`);
    } else if (evt.type === "status_changed") {
      const err = evt.data.error ? ` [${evt.data.error.code}]` : "";
      console.log(`   → ${evt.data.status}${err} (retry ${evt.data.retryCount})`);
    }
  },
});

// 3. Report the outcome.
if (result.status === "completed") {
  console.log(`\n✅ Settled — USDC delivered on Arbitrum.`);
  if (result.txHash) console.log(`   Explorer: https://explorer.mayan.finance/tx/${result.txHash}`);
} else {
  console.log(`\n❌ Ended as "${result.status}". Check GET /swaps for the error.`);
}
process.exit(0);