Fix caching bug in transport (#3998)

* fix caching bug in transport

* add changeset for fix

Author: cl-mayowa

.changeset/violet-dolls-fold.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/the-network-firm-adapter': patch
+---
+
+This changeset contains fix for caching bug in the TNF EA

packages/sources/the-network-firm/src/transport/reserve.ts

@@ -34,17 +34,19 @@ export const getApiKey = (client: string) => {
 
 export const httpTransport = new HttpTransport<HttpTransportTypes>({
   prepareRequests: (params, config) => {
-    const client = params[0].client
-    return {
-      params,
-      request: {
-        baseURL: config.ALT_API_ENDPOINT,
-        url: client,
-        headers: {
-          apikey: getApiKey(client),
+    return params.map((param) => {
+      const client = param.client
+      return {
+        params: [param],
+        request: {
+          baseURL: config.ALT_API_ENDPOINT,
+          url: client,
+          headers: {
+            apikey: getApiKey(client),
+          },
         },
-      },
-    }
+      }
+    })
   },
   parseResponse: (params, response) => {
     return params.map((param) => {

packages/sources/the-network-firm/test/integration/__snapshots__/reserve.test.ts.snap

@@ -14,26 +14,26 @@ exports[`execute reserve endpoint should fail if client name is not present or w
 exports[`execute reserve endpoint should return success for emgemx 1`] = `
 {
   "data": {
-    "result": "1000000",
+    "result": "5100005",
     "ripcord": false,
   },
-  "result": "1000000",
+  "result": "5100005",
   "statusCode": 200,
   "timestamps": {
     "providerDataReceivedUnixMs": 978347471111,
     "providerDataRequestedUnixMs": 978347471111,
-    "providerIndicatedTimeUnixMs": 1751500917131,
+    "providerIndicatedTimeUnixMs": 1748007917250,
   },
 }
 `;
 
 exports[`execute reserve endpoint should return success for m0 1`] = `
 {
   "data": {
-    "result": "1000000",
+    "result": "2344889.68",
     "ripcord": false,
   },
-  "result": "1000000",
+  "result": "2344889.68",
   "statusCode": 200,
   "timestamps": {
     "providerDataReceivedUnixMs": 978347471111,
@@ -46,10 +46,10 @@ exports[`execute reserve endpoint should return success for m0 1`] = `
 exports[`execute reserve endpoint should return success for re 1`] = `
 {
   "data": {
-    "result": "1000000",
+    "result": "333.99882",
     "ripcord": false,
   },
-  "result": "1000000",
+  "result": "333.99882",
   "statusCode": 200,
   "timestamps": {
     "providerDataReceivedUnixMs": 978347471111,
@@ -62,10 +62,10 @@ exports[`execute reserve endpoint should return success for re 1`] = `
 exports[`execute reserve endpoint should return success for uranium 1`] = `
 {
   "data": {
-    "result": "1000000",
+    "result": "75000000",
     "ripcord": false,
   },
-  "result": "1000000",
+  "result": "75000000",
   "statusCode": 200,
   "timestamps": {
     "providerDataReceivedUnixMs": 978347471111,

packages/sources/the-network-firm/test/integration/fixtures.ts

@@ -243,6 +243,20 @@ export const mockEmgemxResponseSuccess = (): nock.Scope =>
     })
     .persist()
 
+export const mockReserveEmgemxResponseSuccess = (): nock.Scope =>
+  nock('http://test-endpoint-new', {
+    encodedQueryParams: true,
+  })
+    .get('/emgemx-tdfkf3')
+    .reply(200, {
+      totalReserve: '5100005',
+      totalToken: '100000',
+      ripcord: false,
+      ripcordDetails: [],
+      timestamp: '2025-05-23T13:45:17.250Z',
+    })
+    .persist()
+
 export const mockEmgemxResponseRipcordFailure = (): nock.Scope =>
   nock('http://test-endpoint-new', {
     encodedQueryParams: true,
@@ -269,14 +283,15 @@ export const mockUraniumResponseSuccess = (): nock.Scope =>
       ripcordDetails: [],
       timestamp: '2025-07-03T00:01:57.131Z',
     })
+    .persist()
 
-export const mockUraniumReserveResponseSuccess = (): nock.Scope =>
+export const mockReserveUraniumResponseSuccess = (): nock.Scope =>
   nock('http://test-endpoint-new', {
     encodedQueryParams: true,
   })
-    .get('/uranium-digital-qohmmjqaf4jk-reserve')
+    .get('/uranium-digital-qohmmjqaf4jk')
     .reply(200, {
-      totalReserve: '1000000',
+      totalReserve: '75000000',
       totalToken: '100000',
       ripcord: false,
       ripcordDetails: [],
@@ -296,6 +311,7 @@ export const mockUraniumResponseRipcordSuccess = (): nock.Scope =>
       ripcordDetails: ['Integrations'],
       timestamp: '2025-07-03T00:01:57.131Z',
     })
+    .persist()
 
 export const mockUraniumResponseFailure = (): nock.Scope =>
   nock('http://test-endpoint-new', {
@@ -316,7 +332,7 @@ export const mockM0ResponseSuccess = (): nock.Scope =>
   })
     .get('/m0-stablecoin-inpd83')
     .reply(200, {
-      totalReserve: '1000000',
+      totalReserve: '2344889.68',
       totalToken: '100000',
       ripcord: false,
       ripcordDetails: [],
@@ -330,7 +346,7 @@ export const mockReResponseSuccess = (): nock.Scope =>
   })
     .get('/re-protocol-8tawlm')
     .reply(200, {
-      totalReserve: '1000000',
+      totalReserve: '333.99882',
       totalToken: '100000',
       ripcord: false,
       ripcordDetails: [],

packages/sources/the-network-firm/test/integration/reserve.test.ts

@@ -4,10 +4,10 @@ import {
 } from '@chainlink/external-adapter-framework/util/testing-utils'
 import * as nock from 'nock'
 import {
-  mockEmgemxResponseSuccess,
   mockM0ResponseSuccess,
   mockReResponseSuccess,
-  mockUraniumReserveResponseSuccess,
+  mockReserveEmgemxResponseSuccess,
+  mockReserveUraniumResponseSuccess,
 } from './fixtures'
 
 describe('execute', () => {
@@ -21,7 +21,7 @@ describe('execute', () => {
     spy = jest.spyOn(Date, 'now').mockReturnValue(mockDate.getTime())
 
     process.env.ALT_API_ENDPOINT = 'http://test-endpoint-new'
-    process.env.URANIUM_DIGITAL_QOHMMJQAF4JK_RESERVE_API_KEY = 'uranium-api-key'
+    process.env.URANIUM_DIGITAL_QOHMMJQAF4JK_API_KEY = 'uranium-api-key'
     process.env.EMGEMX_TDFKF3_API_KEY = 'emgemx-api-key'
     process.env.M0_STABLECOIN_INPD83_API_KEY = 'm0-api-key'
     process.env.RE_PROTOCOL_8TAWLM_API_KEY = 're-api-key'
@@ -45,10 +45,10 @@ describe('execute', () => {
     it('should return success for uranium', async () => {
       const data = {
         endpoint: 'reserve',
-        client: 'uranium-digital-qohmmjqaf4jk-reserve',
+        client: 'uranium-digital-qohmmjqaf4jk',
       }
 
-      mockUraniumReserveResponseSuccess()
+      mockReserveUraniumResponseSuccess()
 
       const response = await testAdapter.request(data)
       expect(response.statusCode).toBe(200)
@@ -61,7 +61,7 @@ describe('execute', () => {
         client: 'emgemx-tdfkf3',
       }
 
-      mockEmgemxResponseSuccess()
+      mockReserveEmgemxResponseSuccess()
 
       const response = await testAdapter.request(data)
       expect(response.statusCode).toBe(200)