Refactors to use SubscribeTransport for multi HTTP requests

Author: mohamed-mehany

.pnp.cjs

@@ -28,18 +28,16 @@
     "start": "yarn server:dist"
   },
   "devDependencies": {
-    "@types/async-retry": "^1",
     "@types/crypto-js": "^4",
-    "@types/jest": "27.5.2",
-    "@types/node": "16.18.119",
-    "nock": "13.5.5",
-    "typescript": "5.6.3"
+    "@types/jest": "^29.5.14",
+    "@types/node": "22.14.1",
+    "nock": "13.5.6",
+    "typescript": "5.8.3"
   },
   "dependencies": {
     "@chainlink/external-adapter-framework": "2.6.0",
-    "async-retry": "^1.3.3",
     "crypto-js": "^4.2.0",
-    "dayjs": "^1.11.13",
+    "date-fns": "^4.1.0",
     "tslib": "2.4.1",
     "uuid": "^11.1.0"
   }

.yarn/cache/uuid-npm-11.1.0-61d0d08928-d2da43b49b.zip

@@ -16,11 +16,17 @@ export const config = new AdapterConfig({
   API_ENDPOINT: {
     description: 'An API endpoint for Data Provider',
     type: 'string',
-    default: 'https://api.navfundservices.com/',
+    default: 'https://api.navfundservices.com',
   },
   MAX_RETRIES: {
     description: 'Maximum attempts of sending a request',
     type: 'number',
     default: 3,
   },
+  BACKGROUND_EXECUTE_MS: {
+    description:
+      'The amount of time the background execute should sleep before performing the next request',
+    type: 'number',
+    default: 120_000, // one call per two minute
+  },
 })

packages/sources/nav-libre/package.json

@@ -1,8 +1,7 @@
 import { AdapterEndpoint } from '@chainlink/external-adapter-framework/adapter'
 import { InputParameters } from '@chainlink/external-adapter-framework/validation'
-import dayjs from 'dayjs'
 import { config } from '../config'
-import { httpTransport } from '../transport/nav'
+import { navLibreTransport } from '../transport/nav'
 
 export const inputParameters = new InputParameters(
   {
@@ -11,24 +10,10 @@ export const inputParameters = new InputParameters(
       type: 'number',
       description: 'The global fund ID for the Libre fund',
     },
-    fromDate: {
-      required: false,
-      type: 'string',
-      description: 'Start date in MM-DD-YYYY format (defaults to 7 days ago)',
-      default: dayjs().subtract(7, 'day').format('MM-DD-YYYY'),
-    },
-    toDate: {
-      required: false,
-      type: 'string',
-      description: 'End date in MM-DD-YYYY format (defaults to today)',
-      default: dayjs().format('MM-DD-YYYY'),
-    },
   },
   [
     {
       globalFundID: 139767,
-      fromDate: '12-30-2024',
-      toDate: '01-15-2025',
     },
   ],
 )
@@ -47,7 +32,6 @@ export type BaseEndpointTypes = {
 
 export const endpoint = new AdapterEndpoint({
   name: 'nav',
-  aliases: [],
-  transport: httpTransport,
+  transport: navLibreTransport,
   inputParameters,
 })

packages/sources/nav-libre/src/config/index.ts

@@ -0,0 +1,32 @@
+import { differenceInBusinessDays, format, isValid, parse, subBusinessDays } from 'date-fns'
+
+// Date format used by the NavLibre API
+export const DATE_FORMAT = 'MM-dd-yyyy'
+export const MAX_BUSINESS_DAYS = 7
+
+/**
+ * Parse a string in MM-DD-YYYY format.
+ * Throws if the string is missing or malformed.
+ */
+export function parseDateString(dateStr: string): Date {
+  const parsed = parse(dateStr, DATE_FORMAT, new Date())
+  if (!isValid(parsed)) {
+    throw new Error(`date must be in ${DATE_FORMAT} format: got "${dateStr}"`)
+  }
+  return parsed
+}
+
+/** Ensure the window is <= N business days. Returns the (possibly adjusted) from-date. */
+export function clampToBusinessWindow(
+  from: Date,
+  to: Date,
+  maxBusinessDays = MAX_BUSINESS_DAYS,
+): Date {
+  const span = differenceInBusinessDays(to, from)
+  return span > maxBusinessDays ? subBusinessDays(to, maxBusinessDays) : from
+}
+
+/** Convenience formatter so every outbound string is consistent. */
+export function toDateString(d: Date): string {
+  return format(d, DATE_FORMAT)
+}