XRPL Wallet Monitor filter

gistfile1.txt

// Returns { matchingTransactions } or null

const CONFIG = {
  Wallets: [
    'rEmnE8iCKY21cesiywotSDoQgTyaNAvgYX',
  ],
};

function main(payload) {
  const wallets = new Set(CONFIG.Wallets);
  const matchingTransactions = [];

  const getDeliveredAmount = (tx) =>
    (tx?.metaData?.delivered_amount ??
     tx?.metaData?.DeliveredAmount ??
     tx?.Amount ?? null);

  for (const item of (payload?.data || [])) {
    const ledger = item.ledger || {};

    for (const tx of (ledger.transactions || [])) {
      if (tx.TransactionType !== 'Payment' || !tx.Account || !tx.Destination || !tx.metaData) {
        continue;
      }
      if (tx.metaData.TransactionResult !== 'tesSUCCESS') continue;

      if (!wallets.has(tx.Account) && !wallets.has(tx.Destination)) continue;

      const delivered = getDeliveredAmount(tx);
      if (delivered === null) continue;

      matchingTransactions.push(tx);
    }
  }

  return matchingTransactions.length ? { matchingTransactions } : null;
}