bitfinexcom · tarcisiozf · Sep 16, 2025 · Aug 28, 2025 · Aug 28, 2025 · Aug 28, 2025
diff --git a/test/5-queue-load.spec.js b/test/5-queue-load.spec.js
@@ -47,7 +47,14 @@ describe('Queue load', () => {
 
     mockRESTv2Srv = createMockRESTv2SrvWithDate(start, end, null, {
       ledgers: { limit },
-      user_info: null
+      user_info: null,
+      symbols: null,
+      map_symbols: null,
+      inactive_currencies: null,
+      margin_currencies: null,
+      inactive_symbols: null,
+      futures: null,
+      currencies: null
     })
 
     await rmAllFiles(tempDirPath)

diff --git a/workers/loc.api/generate-report-file/report.file.job.data.js b/workers/loc.api/generate-report-file/report.file.job.data.js
@@ -894,7 +894,8 @@ class ReportFileJobData {
         note: 'NOTE'
       },
       formatSettings: {
-        mtsUpdated: 'date'
+        mtsUpdated: 'date',
+        currency: 'prepareCurrency'
       }
     }
 

diff --git a/workers/loc.api/queue/write-data-to-stream/helpers.js b/workers/loc.api/queue/write-data-to-stream/helpers.js
@@ -14,6 +14,32 @@ const _validTxtTimeZone = (val, timezone, format) => {
 }
 
 const _formatters = {
+  prepareCurrency: (ccy, params) => {
+    const currencyName = params?.allDataFields?.currencyName
+    const currencyNameMap = params?.symbols?.currencyNameMap
+
+    if (
+      !ccy ||
+      typeof ccy !== 'string' ||
+      !currencyName ||
+      typeof currencyName !== 'string' ||
+      !currencyNameMap ||
+      typeof currencyNameMap !== 'object'
+    ) {
+      return ccy
+    }
+    if (
+      ccy !== 'USDt' &&
+      ccy !== 'UST'
+    ) {
+      return ccy
+    }
+
+    const ccyId = currencyName.replace('TETHER', '')
+    const name = currencyNameMap[ccyId]
+
+    return name ?? ccy
+  },
   date: (
     val,
     {
@@ -112,22 +138,27 @@ const _dataFormatter = (data, formatSettings, params) => {
   const objArr = isArray ? clonedData : [clonedData]
 
   for (const obj of objArr) {
+    const formatterParams = {
+      ...params,
+      allDataFields: obj
+    }
+
     for (const [key, val] of Object.entries(formatSettings)) {
       try {
         if (
           typeof obj[key] !== 'undefined' &&
           val &&
           typeof val === 'object'
         ) {
-          obj[key] = _dataFormatter(obj[key], val, params)
+          obj[key] = _dataFormatter(obj[key], val, formatterParams)
 
           continue
         }
         if (
           typeof obj[key] !== 'undefined' &&
           typeof _formatters[val] === 'function'
         ) {
-          obj[key] = _formatters[val](obj[key], params)
+          obj[key] = _formatters[val](obj[key], formatterParams)
 
           continue
         }

diff --git a/workers/loc.api/queue/write-data-to-stream/index.js b/workers/loc.api/queue/write-data-to-stream/index.js
@@ -45,6 +45,18 @@ module.exports = (
   const currIterationArgs = cloneDeep(_args)
 
   const getData = rService[method].bind(rService)
+  const getSymbols = rService.getSymbols.bind(rService)
+  const symbols = (await getDataFromApi({
+    getData: getSymbols,
+    args: {},
+    callerName: 'REPORT_FILE_WRITER',
+    shouldNotInterrupt: true
+  })) ?? {}
+  symbols.currencyNameMap = symbols.currencies.reduce((accum, curr) => {
+    accum[curr?.id] = curr?.name
+
+    return accum
+  }, {})
 
   let count = 0
   let serialRequestsCount = 0
@@ -101,7 +113,7 @@ module.exports = (
         res,
         stream,
         formatSettings,
-        { ..._args.params },
+        { ..._args.params, symbols },
         method
       )
       processorQueue.emit('progress', 100)
@@ -142,7 +154,7 @@ module.exports = (
       res,
       stream,
       formatSettings,
-      { ..._args.params },
+      { ..._args.params, symbols },
       method
     )