Deposit from Stellar to Tempo

const TEMPO_API_KEY = process.env.TEMPO_API_KEY!;
const USDC_ISSUER = 'GA5ZSEJYB37JRC5AVCIA5MOP4RHTM335X2KGX3IHOJAPP5RE34K4KZVN';

async function quoteDeposit({
  recipient,
  refundAddress,
  amount
}: {
  recipient: string; // Tempo wallet address
  refundAddress: string; // Stellar wallet address
  amount: string; // USDC base units, e.g. '10000000' for 1 USDC
}) {
  const query = new URLSearchParams({
    sourceChain: 'stellar:pubnet',
    sourceToken: `USDC-${USDC_ISSUER}`,
    destinationToken: 'ousd',
    recipient,
    refundAddress,
    amount,
    subsidize: 'false'
  });

  const response = await fetch(`https://api.tempo.xyz/v1/routes/deposit-addresses/quote?${query}`, {
    headers: {'tempo-api-key': TEMPO_API_KEY}
  });
  if (!response.ok) {
    throw new Error(`Tempo Routes returned ${response.status}: ${await response.text()}`);
  }
  const quote = await response.json();

  console.log('Send:', quote.sourceAmount.formatted, 'USDC');
  console.log('Receive:', quote.destinationAmount.formatted, 'OUSD');
  console.log('Fees:', quote.fees);
  console.log('Expires at:', quote.quote.expiresAt);
  return quote;
}

const TEMPO_API_KEY = process.env.TEMPO_API_KEY!;
const USDC_ISSUER = 'GA5ZSEJYB37JRC5AVCIA5MOP4RHTM335X2KGX3IHOJAPP5RE34K4KZVN';

async function createDepositAddress({
  recipient,
  refundAddress,
  amount,
  idempotencyKey
}: {
  recipient: string; // Tempo wallet address
  refundAddress: string; // Stellar wallet address
  amount: string; // USDC base units
  idempotencyKey: string; // stored with the user record
}) {
  const response = await fetch('https://api.tempo.xyz/v2/routes/deposit-addresses', {
    method: 'POST',
    headers: {
      'tempo-api-key': TEMPO_API_KEY,
      'idempotency-key': idempotencyKey,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      sourceChain: 'stellar:pubnet',
      sourceToken: `USDC-${USDC_ISSUER}`,
      destinationToken: 'ousd',
      recipient,
      refundAddresses: {stellar: refundAddress},
      amount,
      subsidize: false
    })
  });
  if (!response.ok) {
    throw new Error(`Tempo Routes returned ${response.status}: ${await response.text()}`);
  }
  const depositAddress = await response.json();

  // When a route's terms change, `addresses` can list more than one Stellar address. Use the active one.
  const stellarEntry = depositAddress.addresses.find(
    (entry: {family: string; status: string}) =>
      entry.family === 'stellar' && entry.status === 'active'
  );
  if (!stellarEntry) {
    throw new Error('The deposit address cannot accept deposits yet');
  }

  console.log('Deposit address ID:', depositAddress.id);
  console.log('Send USDC on Stellar to:', stellarEntry.address);
  return {id: depositAddress.id, address: stellarEntry.address, addressId: stellarEntry.id};
}

const TEMPO_API_KEY = process.env.TEMPO_API_KEY!;
// `action-required` is not final, but the deposit needs attention before it can move on.
const STOP_POLLING_STATUSES = ['completed', 'refunded', 'action-required'];
const POLL_INTERVAL_MS = 10_000;
const POLL_TIMEOUT_MS = 15 * 60_000;

async function getTempo(path: string) {
  const response = await fetch(`https://api.tempo.xyz${path}`, {
    headers: {'tempo-api-key': TEMPO_API_KEY}
  });
  if (!response.ok) {
    throw new Error(`Tempo Routes returned ${response.status}: ${await response.text()}`);
  }
  return response.json();
}

type DepositSearch = {
  depositAddress: string; // Stellar deposit address from step 2
  transactionHash: string; // Stellar transaction hash from step 3
};

// Reads every page of the address's deposits. Returns undefined until Tempo detects the transaction.
async function findDeposit({depositAddress, transactionHash}: DepositSearch) {
  let cursor: string | null = null;
  do {
    const query = new URLSearchParams({depositAddress, limit: '50'});
    if (cursor) query.set('cursor', cursor);
    const page = await getTempo(`/v1/routes/deposits?${query}`);
    const deposit = page.data.find((item: {sourceTransactionHashes: string[]}) =>
      item.sourceTransactionHashes.includes(transactionHash)
    );
    if (deposit) return deposit;
    cursor = page.nextCursor;
  } while (cursor);
  return undefined;
}

async function waitForDeposit(search: DepositSearch) {
  const deadline = Date.now() + POLL_TIMEOUT_MS;
  let deposit = await findDeposit(search);
  while (!deposit || !STOP_POLLING_STATUSES.includes(deposit.status)) {
    if (Date.now() > deadline) {
      throw new Error(
        `Deposit still ${deposit?.status ?? 'not detected'} after ${POLL_TIMEOUT_MS} ms`
      );
    }
    console.log('Deposit status:', deposit?.status ?? 'not detected yet');
    await new Promise((resolve) => setTimeout(resolve, POLL_INTERVAL_MS));
    deposit = deposit
      ? await getTempo(`/v1/routes/deposits/${deposit.id}`)
      : await findDeposit(search);
  }
  console.log('Deposit:', deposit.id, deposit.status);
  return deposit;
}