Add nextNavPerShare to libre (#4161)

* Add nextNavPerShare to libre

* Fix typo

* Add new field

* Rename

* Update packages/sources/nav-libre/src/transport/nav.ts

---------

Co-authored-by: mmcallister-cll <139181225+mmcallister-cll@users.noreply.github.com>

Author: mxiao-cll

.changeset/dry-jobs-battle.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/nav-libre-adapter': minor
+---
+
+Report nextNavPerShare

packages/sources/nav-libre/src/endpoint/nav.ts

@@ -23,7 +23,9 @@ export type BaseEndpointTypes = {
     Result: number
     Data: {
       navPerShare: number
+      nextNavPerShare: number
       navDate: string
+      navDateTimestampMs: number
       globalFundID: number
     }
   }

packages/sources/nav-libre/src/transport/fund.ts

@@ -2,6 +2,10 @@ import { Requester } from '@chainlink/external-adapter-framework/util/requester'
 import { AdapterError } from '@chainlink/external-adapter-framework/validation/error'
 import { getRequestHeaders } from './authentication'
 
+export const ACCOUNTING_DATE_KEY = 'Accounting Date'
+export const NAV_PER_SHARE_KEY = 'NAV Per Share'
+export const NEXT_NAV_PRICE_KEY = 'Next NAV Price'
+
 interface FundResponse {
   Data: {
     'Trading Level Net ROR': {
@@ -18,9 +22,9 @@ interface FundResponse {
       YTD: number
       ITD: number
     }
-    'NAV Per Share': number
-    'Next NAV Price': number
-    'Accounting Date': string
+    [NAV_PER_SHARE_KEY]: number
+    [NEXT_NAV_PRICE_KEY]: number
+    [ACCOUNTING_DATE_KEY]: string
     'Ending Balance': number
   }[]
 }

packages/sources/nav-libre/src/transport/nav.ts

@@ -1,5 +1,5 @@
 import { BaseEndpointTypes, inputParameters } from '../endpoint/nav'
-import { getFund } from './fund'
+import { ACCOUNTING_DATE_KEY, getFund, NAV_PER_SHARE_KEY, NEXT_NAV_PRICE_KEY } from './fund'
 import { getFundDates } from './fund-dates'
 
 import { EndpointContext } from '@chainlink/external-adapter-framework/adapter'
@@ -31,11 +31,16 @@ export class NavLibreTransport extends SubscriptionTransport<BaseEndpointTypes>
     this.config = adapterSettings
   }
   async backgroundHandler(context: EndpointContext<BaseEndpointTypes>, entries: RequestParams[]) {
-    await Promise.all(entries.map(async (param) => this.handleRequest(context, param)))
-    await sleep(context.adapterSettings.BACKGROUND_EXECUTE_MS)
+    await Promise.all(entries.map(async (param) => this.handleRequest(param)))
+    // Only sleep more if we have requests, avoids long startup delay for first asset
+    if (entries.length == 0) {
+      await sleep(1_000)
+    } else {
+      await sleep(context.adapterSettings.BACKGROUND_EXECUTE_MS)
+    }
   }
 
-  async handleRequest(_context: EndpointContext<BaseEndpointTypes>, param: RequestParams) {
+  async handleRequest(param: RequestParams) {
     let response: AdapterResponse<BaseEndpointTypes['Response']>
     try {
       response = await this._handleRequest(param)
@@ -91,8 +96,6 @@ export class NavLibreTransport extends SubscriptionTransport<BaseEndpointTypes>
       requester: this.requester,
     })
 
-    const ACCOUNTING_DATE_KEY = 'Accounting Date'
-    const NAV_PER_SHARE_KEY = 'NAV Per Share'
     // Find the latest NAV entry by Accounting Date
     const latest = fund.reduce((latestRow, row) =>
       parseDateString(row[ACCOUNTING_DATE_KEY]) > parseDateString(latestRow[ACCOUNTING_DATE_KEY])
@@ -107,7 +110,9 @@ export class NavLibreTransport extends SubscriptionTransport<BaseEndpointTypes>
       data: {
         globalFundID: param.globalFundID,
         navPerShare: latest[NAV_PER_SHARE_KEY],
+        nextNavPerShare: latest[NEXT_NAV_PRICE_KEY],
         navDate: latest[ACCOUNTING_DATE_KEY],
+        navDateTimestampMs: parseDateString(latest[ACCOUNTING_DATE_KEY]).getTime(),
       },
       timestamps: {
         providerDataRequestedUnixMs,

packages/sources/nav-libre/test/integration/__snapshots__/adapter.test.ts.snap

@@ -5,7 +5,9 @@ exports[`execute nav endpoint should return success 1`] = `
   "data": {
     "globalFundID": 1234,
     "navDate": "01-01-2024",
+    "navDateTimestampMs": 1704067200000,
     "navPerShare": 123.45,
+    "nextNavPerShare": 124.56,
   },
   "result": 123.45,
   "statusCode": 200,

packages/sources/nav-libre/test/unit/nav.test.ts

@@ -42,8 +42,8 @@ const FUND_DATES_RES = makeStub('fundDatesRes', {
 })
 
 const FUND_ROWS = [
-  { 'NAV Per Share': 50, 'Accounting Date': '06-10-2025' },
-  { 'NAV Per Share': 150, 'Accounting Date': '06-25-2025' },
+  { 'NAV Per Share': 50, 'Next NAV Price': 51, 'Accounting Date': '06-10-2025' },
+  { 'NAV Per Share': 150, 'Next NAV Price': 151, 'Accounting Date': '06-25-2025' },
 ]
 
 const FUND_RES = makeStub('fundRes', {
@@ -65,7 +65,7 @@ describe('NavLibreTransport – handleRequest', () => {
 
     const param = makeStub('param', { globalFundID: FUND_ID } as typeof navInputParams.validated)
 
-    await transport.handleRequest({ adapterSettings } as any, param)
+    await transport.handleRequest(param)
 
     expect(responseCache.write).toHaveBeenCalledTimes(1)
 
@@ -76,7 +76,9 @@ describe('NavLibreTransport – handleRequest', () => {
       data: {
         globalFundID: FUND_ID,
         navPerShare: 150,
+        nextNavPerShare: 151,
         navDate: '06-25-2025',
+        navDateTimestampMs: 1750809600000,
       },
       timestamps: expect.objectContaining({
         providerDataRequestedUnixMs: expect.any(Number),
@@ -107,7 +109,7 @@ describe('NavLibreTransport – handleRequest', () => {
 
     const param = makeStub('param', { globalFundID: FUND_ID } as typeof navInputParams.validated)
 
-    await transport.handleRequest({ adapterSettings } as any, param)
+    await transport.handleRequest(param)
 
     expect(responseCache.write).toHaveBeenCalledTimes(1)
     const cached = getCachedResponse()
@@ -122,15 +124,15 @@ describe('NavLibreTransport – handleRequest', () => {
     requester.request.mockResolvedValueOnce(shortSpanDates)
 
     const fundRows = [
-      { 'NAV Per Share': 42, 'Accounting Date': '06-30-2025' },
-      { 'NAV Per Share': 43, 'Accounting Date': '07-01-2025' },
+      { 'NAV Per Share': 42, 'Next NAV Price': 142, 'Accounting Date': '06-30-2025' },
+      { 'NAV Per Share': 43, 'Next NAV Price': 143, 'Accounting Date': '07-01-2025' },
     ]
     const fundRes = makeStub('fundRes', { response: { data: { Data: fundRows } } })
     requester.request.mockResolvedValueOnce(fundRes)
 
     const param = makeStub('param', { globalFundID: FUND_ID } as typeof navInputParams.validated)
 
-    await transport.handleRequest({ adapterSettings } as any, param)
+    await transport.handleRequest(param)
 
     expect(requester.request).toHaveBeenNthCalledWith(
       2,
@@ -148,7 +150,7 @@ describe('NavLibreTransport – handleRequest', () => {
     )
     const param = makeStub('param', { globalFundID: FUND_ID } as typeof navInputParams.validated)
 
-    await transport.handleRequest({ adapterSettings } as any, param)
+    await transport.handleRequest(param)
 
     const cached = getCachedResponse()
     expect(cached.statusCode).toBe(400)