Fix partner processTx signatures

Author: cursoragent

src/partners/nexchange.ts

@@ -68,6 +68,10 @@ export type NexchangeCurrencyInfoMap = Record<string, NexchangeCurrencyMeta>
 const QUERY_LOOKBACK = 1000 * 60 * 60 * 24 * 5 // 5 days
 const LIMIT = 200
 const MAX_ERROR_TEXT_LENGTH = 500
+const CACHE_TTL_MS = 24 * 60 * 60 * 1000 // 24 hours
+
+let currencyCache: NexchangeCurrencyInfoMap | undefined
+let currencyCacheTimestamp = 0
 
 const statusMap: { [key: string]: Status } = {
   released: 'complete',
@@ -176,6 +180,13 @@ function truncateForError(text: string): string {
 export async function fetchNexchangeCurrencyMap(): Promise<
   NexchangeCurrencyInfoMap
 > {
+  if (
+    currencyCache != null &&
+    Date.now() - currencyCacheTimestamp < CACHE_TTL_MS
+  ) {
+    return currencyCache
+  }
+
   const response = await retryFetch(CURRENCY_URL, { method: 'GET' })
   if (!response.ok) {
     const text = await response.text()
@@ -189,9 +200,21 @@ export async function fetchNexchangeCurrencyMap(): Promise<
   for (const currency of currencies) {
     map[currency.code.toUpperCase()] = currency
   }
+  currencyCache = map
+  currencyCacheTimestamp = Date.now()
   return map
 }
 
+async function loadNexchangeCurrencyMap(
+  pluginParams: PluginParams
+): Promise<NexchangeCurrencyInfoMap> {
+  const { currencyMap } = (pluginParams as unknown) as {
+    currencyMap?: NexchangeCurrencyInfoMap
+  }
+  if (currencyMap != null) return currencyMap
+  return await fetchNexchangeCurrencyMap()
+}
+
 /**
  * Returned by `resolveNexchangeAsset`.  The shape is consistent across all
  * exit branches so callers can rely on the field set.  `chainPluginId`,
@@ -315,7 +338,7 @@ export async function queryNexchange(
     // audit-orders endpoint omits, so it is required for chain/token
     // enrichment.  Fetch it up front; a failure aborts the run (saving
     // nothing) rather than persisting a batch of unenriched transactions.
-    const currencyMap = await fetchNexchangeCurrencyMap()
+    await fetchNexchangeCurrencyMap()
 
     while (true) {
       const params: string[] = [
@@ -341,7 +364,7 @@ export async function queryNexchange(
       const { orders, nextCursor, hasMore } = asNexchangeOrdersResponse(json)
 
       for (const rawOrder of orders) {
-        const standardTx = processNexchangeTx(rawOrder, currencyMap)
+        const standardTx = await processNexchangeTx(rawOrder, pluginParams)
         txByOrderId.set(standardTx.orderId, standardTx)
         if (standardTx.isoDate > latestIsoDate) {
           latestIsoDate = standardTx.isoDate
@@ -382,11 +405,12 @@ export const nexchange: PartnerPlugin = {
   pluginId: 'nexchange'
 }
 
-export function processNexchangeTx(
+export async function processNexchangeTx(
   rawTx: unknown,
-  currencyMap: NexchangeCurrencyInfoMap
-): StandardTx {
+  pluginParams: PluginParams
+): Promise<StandardTx> {
   const tx = asNexchangeOrder(rawTx)
+  const currencyMap = await loadNexchangeCurrencyMap(pluginParams)
   const lowerStatus = tx.status.toLowerCase()
   const status = statusMap[lowerStatus] ?? 'other'
   const { isoDate, timestamp } = parseApiDate(tx.createdAt)

src/partners/xgram.ts

@@ -281,6 +281,23 @@ async function fetchCurrencyCache(
   return currencyCache
 }
 
+async function loadXgramCurrencies(
+  pluginParams: PluginParams
+): Promise<XgramCurrencies> {
+  const { currencies } = (pluginParams as unknown) as {
+    currencies?: XgramCurrencies
+  }
+  if (currencies != null) return currencies
+
+  const { log } = pluginParams
+  const { apiKeys } = asStandardPluginParams(pluginParams)
+  const { apiKey } = apiKeys
+  if (apiKey == null) {
+    throw new Error('Xgram apiKey required for asset info lookup')
+  }
+  return await fetchCurrencyCache(apiKey, log)
+}
+
 function isNativeTicker(chainPluginId: string, currencyCode: string): boolean {
   return NATIVE_TICKERS[chainPluginId]?.has(currencyCode.toUpperCase()) ?? false
 }
@@ -375,7 +392,7 @@ export const queryXgram = async (
   if (previousTimestamp < 0) previousTimestamp = 0
   const targetIsoDate = new Date(previousTimestamp).toISOString()
 
-  const currencies = await fetchCurrencyCache(apiKey, log)
+  await fetchCurrencyCache(apiKey, log)
 
   // Because Xgram pages from newest to oldest, the watermark can only be
   // advanced once the entire newer-than-target range has been fetched and
@@ -427,7 +444,7 @@ export const queryXgram = async (
     }
     let oldestIsoDate = '999999999999999999999999999999999999'
     for (const rawTx of txs) {
-      const standardTx = processXgramTx(rawTx, currencies)
+      const standardTx = await processXgramTx(rawTx, pluginParams)
       if (standardTx.isoDate < oldestIsoDate) {
         oldestIsoDate = standardTx.isoDate
       }
@@ -462,11 +479,12 @@ export const xgram: PartnerPlugin = {
   pluginId: 'xgram'
 }
 
-export function processXgramTx(
+export async function processXgramTx(
   rawTx: unknown,
-  currencies: XgramCurrencies
-): StandardTx {
+  pluginParams: PluginParams
+): Promise<StandardTx> {
   const tx: XgramTxTx = asXgramTx(rawTx)
+  const currencies = await loadXgramCurrencies(pluginParams)
   const { isoDate, timestamp } = parseXgramDate(tx.date)
   const depositCurrency = tx['x-fromCcy'].toUpperCase()
   const payoutCurrency = tx['x-toCcy'].toUpperCase()

test/nexchange.test.ts

@@ -9,6 +9,7 @@ import {
   resolveNexchangeAsset,
   toQueryIsoDate
 } from '../src/partners/nexchange'
+import { PluginParams } from '../src/types'
 
 const currencyMap: NexchangeCurrencyInfoMap = {
   BTC: {
@@ -92,6 +93,19 @@ const currencyMap: NexchangeCurrencyInfoMap = {
   }
 }
 
+const testLog = Object.assign(() => {}, {
+  warn: () => {},
+  error: () => {}
+})
+const pluginParams: PluginParams & {
+  currencyMap: NexchangeCurrencyInfoMap
+} = {
+  settings: {},
+  apiKeys: {},
+  log: testLog,
+  currencyMap
+}
+
 function makeRawOrder(overrides: { [key: string]: any } = {}): unknown {
   return {
     orderId: 'NEX-DEFAULT',
@@ -116,10 +130,10 @@ function makeRawOrder(overrides: { [key: string]: any } = {}): unknown {
 
 describe('nexchange plugin', () => {
   describe('processNexchangeTx', () => {
-    it('maps Edge audit order payload into StandardTx with chain plugin and token ids', () => {
-      const tx = processNexchangeTx(
+    it('maps Edge audit order payload into StandardTx with chain plugin and token ids', async () => {
+      const tx = await processNexchangeTx(
         makeRawOrder({ orderId: 'NEX-ABCD1234' }),
-        currencyMap
+        pluginParams
       )
 
       expect(tx.orderId).to.equal('NEX-ABCD1234')
@@ -159,10 +173,10 @@ describe('nexchange plugin', () => {
       ['something-else', 'other']
     ]
     for (const [rawStatus, expected] of statusCases) {
-      it(`maps status "${rawStatus}" to "${expected}"`, () => {
-        const tx = processNexchangeTx(
+      it(`maps status "${rawStatus}" to "${expected}"`, async () => {
+        const tx = await processNexchangeTx(
           makeRawOrder({ status: rawStatus }),
-          currencyMap
+          pluginParams
         )
         expect(tx.status).to.equal(expected)
       })

test/xgram.test.ts

@@ -2,6 +2,7 @@ import { expect } from 'chai'
 import { describe, it } from 'mocha'
 
 import { processXgramTx, XgramCurrencies } from '../src/partners/xgram'
+import { PluginParams } from '../src/types'
 
 const currencies: XgramCurrencies = {
   BTC: {
@@ -31,9 +32,22 @@ const currencies: XgramCurrencies = {
   }
 }
 
+const testLog = Object.assign(() => {}, {
+  warn: () => {},
+  error: () => {}
+})
+const pluginParams: PluginParams & {
+  currencies: XgramCurrencies
+} = {
+  settings: {},
+  apiKeys: {},
+  log: testLog,
+  currencies
+}
+
 describe('processXgramTx', () => {
-  it('maps source and destination asset IDs', () => {
-    const tx = processXgramTx(
+  it('maps source and destination asset IDs', async () => {
+    const tx = await processXgramTx(
       {
         id: 'dyv3a2tdbgipvh0',
         'x-status': 'x-completed',
@@ -49,7 +63,7 @@ describe('processXgramTx', () => {
         date: '27.05.2026 20:57:28',
         txId: 'payout-hash'
       },
-      currencies
+      pluginParams
     )
 
     expect(tx.status).equals('complete')
@@ -66,8 +80,8 @@ describe('processXgramTx', () => {
     expect(tx.isoDate).equals('2026-05-27T20:57:28.000Z')
   })
 
-  it('uses expected amounts and chain-specific token IDs for pending rows', () => {
-    const tx = processXgramTx(
+  it('uses expected amounts and chain-specific token IDs for pending rows', async () => {
+    const tx = await processXgramTx(
       {
         id: 'tmah3a2td9cp20q0',
         'x-status': 'x-new',
@@ -83,7 +97,7 @@ describe('processXgramTx', () => {
         date: '27.05.2026 20:56:54',
         txId: null
       },
-      currencies
+      pluginParams
     )
 
     expect(tx.status).equals('pending')
@@ -97,8 +111,8 @@ describe('processXgramTx', () => {
     expect(tx.payoutTokenId).equals(null)
   })
 
-  it('maps historical native currencies missing from the currency API', () => {
-    const tx = processXgramTx(
+  it('maps historical native currencies missing from the currency API', async () => {
+    const tx = await processXgramTx(
       {
         id: 'talr3a0e49fplpog',
         'x-status': 'x-timeout',
@@ -114,7 +128,7 @@ describe('processXgramTx', () => {
         date: '12.05.2026 20:07:51',
         txId: null
       },
-      currencies
+      pluginParams
     )
 
     expect(tx.status).equals('expired')