DF-21398 OnRe NAV EA (#3911)

* DF-21398 OnRe NAV EA

* update test-payload

* add rateLimit

* yarn lock file

* .pnp.cjs file

* yarn cache

* fixing tests

* update package versions

* fix dependencies

* Changes - Review 1

* fix test

* fix date to include UTC time

* Modify output; add ripcord

* Review 20 June - Part 1

* Update test snapshot

* OnRe EA - correct precision

* Change Response Type

* update snapshot

* refactor

* Update packages/sources/onre/src/endpoint/nav.ts

---------

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

Author: Subarna-Singh

.changeset/cool-lamps-admire.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/onre-adapter': major
+---
+
+OnRe EA

.pnp.cjs

@@ -0,0 +1,56 @@
+# ONRE
+
+![0.0.0](https://img.shields.io/github/package-json/v/smartcontractkit/external-adapters-js?filename=packages/sources/onre/package.json) ![v3](https://img.shields.io/badge/framework%20version-v3-blueviolet)
+
+This document was generated automatically. Please see [README Generator](../../scripts#readme-generator) for more info.
+
+## Environment Variables
+
+| Required? |     Name     |       Description        |  Type  | Options |                   Default                    |
+| :-------: | :----------: | :----------------------: | :----: | :-----: | :------------------------------------------: |
+|           | API_ENDPOINT | An API endpoint for OnRe | string |         | `https://onre-api-prod.ew.r.appspot.com/nav` |
+
+---
+
+## Data Provider Rate Limits
+
+|  Name   | Requests/credits per second | Requests/credits per minute | Requests/credits per hour | Note |
+| :-----: | :-------------------------: | :-------------------------: | :-----------------------: | :--: |
+| default |                             |              2              |                           |      |
+
+---
+
+## Input Parameters
+
+| Required? |   Name   |     Description     |  Type  |                                       Options                                        |  Default   |
+| :-------: | :------: | :-----------------: | :----: | :----------------------------------------------------------------------------------: | :--------: |
+|           | endpoint | The endpoint to use | string | [nav](#reserves-endpoint), [por](#reserves-endpoint), [reserves](#reserves-endpoint) | `reserves` |
+
+## Reserves Endpoint
+
+Supported names for this endpoint are: `nav`, `por`, `reserves`.
+
+### Input Params
+
+| Required? |    Name     | Aliases |       Description        |  Type  |      Options      |      Default      | Depends On | Not Valid With |
+| :-------: | :---------: | :-----: | :----------------------: | :----: | :---------------: | :---------------: | :--------: | :------------: |
+|    ✅     |   fundId    |         |         Fund id          | number |                   |                   |            |                |
+|           | reportValue |         | Which value to report on | string | `net_asset_value` | `net_asset_value` |            |                |
+
+### Example
+
+Request:
+
+```json
+{
+  "data": {
+    "endpoint": "reserves",
+    "fundId": 1,
+    "reportValue": "net_asset_value"
+  }
+}
+```
+
+---
+
+MIT License

packages/sources/onre/CHANGELOG.md

@@ -0,0 +1,40 @@
+{
+  "name": "@chainlink/onre-adapter",
+  "version": "0.0.0",
+  "description": "Chainlink onre adapter.",
+  "keywords": [
+    "Chainlink",
+    "LINK",
+    "blockchain",
+    "oracle",
+    "onre"
+  ],
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "files": [
+    "dist"
+  ],
+  "repository": {
+    "url": "https://github.com/smartcontractkit/external-adapters-js",
+    "type": "git"
+  },
+  "license": "MIT",
+  "scripts": {
+    "clean": "rm -rf dist && rm -f tsconfig.tsbuildinfo",
+    "prepack": "yarn build",
+    "build": "tsc -b",
+    "server": "node -e 'require(\"./index.js\").server()'",
+    "server:dist": "node -e 'require(\"./dist/index.js\").server()'",
+    "start": "yarn server:dist"
+  },
+  "devDependencies": {
+    "@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",
+    "tslib": "2.4.1"
+  }
+}

packages/sources/onre/README.md

@@ -0,0 +1,9 @@
+import { AdapterConfig } from '@chainlink/external-adapter-framework/config'
+
+export const config = new AdapterConfig({
+  API_ENDPOINT: {
+    description: 'An API endpoint for OnRe',
+    type: 'string',
+    default: 'https://onre-api-prod.ew.r.appspot.com/nav',
+  },
+})

packages/sources/onre/package.json

@@ -0,0 +1 @@
+export { endpoint as nav } from './nav'

packages/sources/onre/src/config/index.ts

@@ -0,0 +1,53 @@
+import { AdapterEndpoint } from '@chainlink/external-adapter-framework/adapter'
+import { InputParameters } from '@chainlink/external-adapter-framework/validation'
+import { config } from '../config'
+import { httpTransport } from '../transport/nav'
+
+export const NetAssetValue = 'net_asset_value'
+export const AssetsUnderManagement = 'assets_under_management'
+
+export const inputParameters = new InputParameters(
+  {
+    fundId: {
+      description: 'Fund id',
+      type: 'number',
+      required: true,
+    },
+    reportValue: {
+      description: 'Which value to report on as top-level result',
+      type: 'string',
+      default: NetAssetValue,
+      options: [NetAssetValue],
+    },
+  },
+  [
+    {
+      fundId: 1,
+      reportValue: NetAssetValue,
+    },
+  ],
+)
+
+export type NavResultResponse = {
+  Result: number
+  Data: {
+    navPerShare: number
+    navDate: string
+    currency: string
+    aum: string
+    fundId: number
+  }
+}
+
+export type BaseEndpointTypes = {
+  Parameters: typeof inputParameters.definition
+  Response: NavResultResponse
+  Settings: typeof config.settings
+}
+
+export const endpoint = new AdapterEndpoint({
+  name: 'reserves',
+  aliases: ['nav'],
+  transport: httpTransport,
+  inputParameters,
+})

packages/sources/onre/src/endpoint/index.ts

@@ -0,0 +1,20 @@
+import { expose, ServerInstance } from '@chainlink/external-adapter-framework'
+import { Adapter } from '@chainlink/external-adapter-framework/adapter'
+import { config } from './config'
+import { nav } from './endpoint'
+
+export const adapter = new Adapter({
+  defaultEndpoint: nav.name,
+  name: 'ONRE',
+  config,
+  endpoints: [nav],
+  rateLimiting: {
+    tiers: {
+      default: {
+        rateLimit1m: 2,
+      },
+    },
+  },
+})
+
+export const server = (): Promise<ServerInstance | undefined> => expose(adapter)

packages/sources/onre/src/endpoint/nav.ts

@@ -0,0 +1,107 @@
+import { HttpTransport } from '@chainlink/external-adapter-framework/transports'
+import { BaseEndpointTypes } from '../endpoint/nav'
+import { parseDateToTimestamp, sanityCheckData } from './utils'
+
+interface FundNavData {
+  net_asset_value_date: string
+  net_asset_value: string
+  assets_under_management: string
+  fund_name: string
+  fund_id: number
+}
+
+type ProviderResponseSchema = FundNavData[]
+
+export type FundNavDataWithTimestamp = Omit<FundNavData, 'net_asset_value_date'> & {
+  net_asset_value_date: number
+}
+
+export type HttpTransportTypes = BaseEndpointTypes & {
+  Provider: {
+    RequestBody: never
+    ResponseBody: ProviderResponseSchema
+  }
+}
+
+export const httpTransport = new HttpTransport<HttpTransportTypes>({
+  prepareRequests: (params, config) => {
+    return params.map((param) => {
+      return {
+        params: [param],
+        request: {
+          baseURL: config.API_ENDPOINT,
+        },
+      }
+    })
+  },
+
+  parseResponse: (params, response) => {
+    if (!response.data) {
+      return params.map((param) => {
+        return {
+          params: param,
+          response: {
+            errorMessage: `The data provider didn't return any value for ${param}`,
+            statusCode: 502,
+          },
+        }
+      })
+    }
+
+    return params.map((param) => {
+      const filteredData = response.data.filter((item) => item.fund_id === param.fundId)
+      if (filteredData.length === 0) {
+        return {
+          params: param,
+          response: {
+            errorMessage: `The data provider didn't return any value for fundId: ${param.fundId}`,
+            statusCode: 502,
+          },
+        }
+      }
+
+      const dataWithDateMs = filteredData.map((item) => {
+        return {
+          ...item,
+          net_asset_value_date: parseDateToTimestamp(item.net_asset_value_date),
+        }
+      })
+
+      const dataWithDateMsFiltered = dataWithDateMs.filter((item) =>
+        Number.isFinite(item.net_asset_value_date),
+      ) as FundNavDataWithTimestamp[]
+      const sortedData = dataWithDateMsFiltered.sort(
+        (a, b) => b.net_asset_value_date - a.net_asset_value_date,
+      )
+      const latestData = sortedData[0]
+
+      if (!sanityCheckData(latestData)) {
+        return {
+          params: param,
+          response: {
+            errorMessage: `The data by data provider for ${param} is null in value`,
+            statusCode: 502,
+          },
+        }
+      }
+
+      const resultData = {
+        navPerShare: Number(latestData.net_asset_value),
+        navDate: String(latestData.net_asset_value_date),
+        currency: 'USD',
+        aum: latestData.assets_under_management,
+        fundId: latestData.fund_id,
+      }
+
+      const result = Number(latestData.net_asset_value)
+
+      return {
+        params: param,
+        response: {
+          result: result,
+          data: resultData,
+        },
+      }
+    })
+  },
+})