Standardize Xgram transaction processor

Author: cursoragent

src/partners/xgram.ts

@@ -375,8 +375,6 @@ export const queryXgram = async (
   if (previousTimestamp < 0) previousTimestamp = 0
   const targetIsoDate = new Date(previousTimestamp).toISOString()
 
-  const currencies = 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
   // processed without error. Track the candidate watermark separately and only
@@ -427,7 +425,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,7 +460,20 @@ export const xgram: PartnerPlugin = {
   pluginId: 'xgram'
 }
 
-export function processXgramTx(
+export async function processXgramTx(
+  rawTx: unknown,
+  pluginParams: PluginParams
+): Promise<StandardTx> {
+  const { log } = pluginParams
+  const { apiKeys } = asStandardPluginParams(pluginParams)
+  const { apiKey } = apiKeys
+  if (apiKey == null) throw new Error('Missing Xgram apiKey')
+  const currencies = await fetchCurrencyCache(apiKey, log)
+
+  return processXgramTxWithCurrencies(rawTx, currencies)
+}
+
+export function processXgramTxWithCurrencies(
   rawTx: unknown,
   currencies: XgramCurrencies
 ): StandardTx {

test/xgram.test.ts

@@ -1,7 +1,10 @@
 import { expect } from 'chai'
 import { describe, it } from 'mocha'
 
-import { processXgramTx, XgramCurrencies } from '../src/partners/xgram'
+import {
+  processXgramTxWithCurrencies,
+  XgramCurrencies
+} from '../src/partners/xgram'
 
 const currencies: XgramCurrencies = {
   BTC: {
@@ -33,7 +36,7 @@ const currencies: XgramCurrencies = {
 
 describe('processXgramTx', () => {
   it('maps source and destination asset IDs', () => {
-    const tx = processXgramTx(
+    const tx = processXgramTxWithCurrencies(
       {
         id: 'dyv3a2tdbgipvh0',
         'x-status': 'x-completed',
@@ -67,7 +70,7 @@ describe('processXgramTx', () => {
   })
 
   it('uses expected amounts and chain-specific token IDs for pending rows', () => {
-    const tx = processXgramTx(
+    const tx = processXgramTxWithCurrencies(
       {
         id: 'tmah3a2td9cp20q0',
         'x-status': 'x-new',
@@ -98,7 +101,7 @@ describe('processXgramTx', () => {
   })
 
   it('maps historical native currencies missing from the currency API', () => {
-    const tx = processXgramTx(
+    const tx = processXgramTxWithCurrencies(
       {
         id: 'talr3a0e49fplpog',
         'x-status': 'x-timeout',