Re-factor tokenized-equity (#4651)

* Re-factor tokenized-equity

* Validate rpc in endpoint

Author: mxiao-cll

.changeset/rude-plums-fix.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/tokenized-equity-adapter': patch
+---
+
+Code re-factor

packages/composites/tokenized-equity/src/config/index.ts

@@ -1,11 +1,6 @@
 import { AdapterConfig } from '@chainlink/external-adapter-framework/config'
 
 export const config = new AdapterConfig({
-  ETHEREUM_RPC_URL: {
-    description: 'RPC URL of a Mainnet ETH node',
-    type: 'string',
-    required: true,
-  },
   DATA_ENGINE_ADAPTER_URL: {
     description: 'URL of data engine ea',
     type: 'string',
@@ -16,6 +11,11 @@ export const config = new AdapterConfig({
     type: 'string',
     required: true,
   },
+  ETHEREUM_RPC_URL: {
+    description: 'RPC URL of a Mainnet ETH node',
+    type: 'string',
+    default: '',
+  },
   ETHEREUM_RPC_CHAIN_ID: {
     description: 'The chain id to connect to',
     type: 'number',

packages/composites/tokenized-equity/src/endpoint/index.ts

@@ -1 +1 @@
-export { endpoint as price } from './price'
+export { endpoint as ondo } from './ondo'

…s/tokenized-equity/src/endpoint/price.ts …es/tokenized-equity/src/endpoint/ondo.tspackages/composites/tokenized-equity/src/endpoint/price.ts renamed to packages/composites/tokenized-equity/src/endpoint/ondo.ts packages/composites/tokenized-equity/src/endpoint/price.ts renamed to packages/composites/tokenized-equity/src/endpoint/ondo.ts

@@ -4,7 +4,7 @@ import { InputParameters } from '@chainlink/external-adapter-framework/validatio
 import { AdapterInputError } from '@chainlink/external-adapter-framework/validation/error'
 import { TypeFromDefinition } from '@chainlink/external-adapter-framework/validation/input-params'
 import { config } from '../config'
-import { priceTransport } from '../transport/transport'
+import { ondoTransport } from '../transport/ondoTransport'
 
 export const inputParameters = new InputParameters(
   {
@@ -118,11 +118,18 @@ export type BaseEndpointTypes = {
 export type Smoother = TypeFromDefinition<BaseEndpointTypes['Parameters']>['smoother']
 
 export const endpoint = new AdapterEndpoint({
-  name: 'price',
+  name: 'ondo',
   aliases: [],
-  transport: priceTransport,
+  transport: ondoTransport,
   inputParameters,
-  customInputValidation: (req): AdapterInputError | undefined => {
+  customInputValidation: (req, adapterSettings): AdapterInputError | undefined => {
+    if (!adapterSettings.ETHEREUM_RPC_URL) {
+      throw new AdapterInputError({
+        message: 'Missing ETHEREUM_RPC_URL',
+        statusCode: 400,
+      })
+    }
+
     const { sessionBoundaries, sessionBoundariesTimeZone } = req.requestContext.data
 
     sessionBoundaries.forEach((s) => {

packages/composites/tokenized-equity/src/index.ts

@@ -1,13 +1,13 @@
 import { expose, ServerInstance } from '@chainlink/external-adapter-framework'
 import { Adapter } from '@chainlink/external-adapter-framework/adapter'
 import { config } from './config'
-import { price } from './endpoint'
+import { ondo } from './endpoint'
 
 export const adapter = new Adapter({
-  defaultEndpoint: price.name,
+  defaultEndpoint: ondo.name,
   name: 'TOKENIZED_EQUITY',
   config,
-  endpoints: [price],
+  endpoints: [ondo],
 })
 
 export const server = (): Promise<ServerInstance | undefined> => expose(adapter)

packages/composites/tokenized-equity/src/lib/smoother/smoother.ts

@@ -1,5 +1,5 @@
 // Algorithm by @kalanyuz and @eshaqiri
-import { Smoother } from '../../endpoint/price'
+import { Smoother } from '../../endpoint/ondo'
 import { EmaFilter } from './ema'
 import { KalmanFilter } from './kalman'
 import { deScale, scale } from './utils'

…/tokenized-equity/src/transport/price.ts …enized-equity/src/transport/ondoPrice.tspackages/composites/tokenized-equity/src/transport/price.ts renamed to packages/composites/tokenized-equity/src/transport/ondoPrice.ts packages/composites/tokenized-equity/src/transport/price.ts renamed to packages/composites/tokenized-equity/src/transport/ondoPrice.ts

@@ -2,7 +2,7 @@ import { Requester } from '@chainlink/external-adapter-framework/util/requester'
 import { JsonRpcProvider } from 'ethers'
 
 import { AdapterError } from '@chainlink/external-adapter-framework/validation/error'
-import { Smoother } from '../endpoint/price'
+import { Smoother } from '../endpoint/ondo'
 import { getRegistryData } from '../lib/registry'
 import { calculateSecondsFromTransition } from '../lib/session/session'
 import { processUpdate } from '../lib/smoother/smoother'

…enized-equity/src/transport/transport.ts …ed-equity/src/transport/ondoTransport.tspackages/composites/tokenized-equity/src/transport/transport.ts renamed to packages/composites/tokenized-equity/src/transport/ondoTransport.ts packages/composites/tokenized-equity/src/transport/transport.ts renamed to packages/composites/tokenized-equity/src/transport/ondoTransport.ts

@@ -5,14 +5,14 @@ import { AdapterResponse, makeLogger, sleep } from '@chainlink/external-adapter-
 import { Requester } from '@chainlink/external-adapter-framework/util/requester'
 import { AdapterError } from '@chainlink/external-adapter-framework/validation/error'
 import { JsonRpcProvider } from 'ethers'
-import { BaseEndpointTypes, inputParameters, Smoother } from '../endpoint/price'
-import { calculatePrice } from './price'
+import { BaseEndpointTypes, inputParameters, Smoother } from '../endpoint/ondo'
+import { calculatePrice } from './ondoPrice'
 
-const logger = makeLogger('PriceTransport')
+const logger = makeLogger('OndoTransport')
 
 type RequestParams = typeof inputParameters.validated
 
-export class PriceTransport extends SubscriptionTransport<BaseEndpointTypes> {
+export class OndoTransport extends SubscriptionTransport<BaseEndpointTypes> {
   requester!: Requester
   provider!: JsonRpcProvider
   dataEngineUrl!: string
@@ -132,4 +132,4 @@ const dedupeParams = (params: RequestParams[]) => {
   return Array.from(seen.values())
 }
 
-export const priceTransport = new PriceTransport()
+export const ondoTransport = new OndoTransport()

…equity/test/unit/transport/price.test.ts …ty/test/unit/transport/ondoPrice.test.tspackages/composites/tokenized-equity/test/unit/transport/price.test.ts renamed to packages/composites/tokenized-equity/test/unit/transport/ondoPrice.test.ts packages/composites/tokenized-equity/test/unit/transport/price.test.ts renamed to packages/composites/tokenized-equity/test/unit/transport/ondoPrice.test.ts

@@ -4,7 +4,7 @@ import { getRegistryData } from '../../../src/lib/registry'
 import { calculateSecondsFromTransition } from '../../../src/lib/session/session'
 import { processUpdate } from '../../../src/lib/smoother/smoother'
 import { getPrice } from '../../../src/lib/streams'
-import { calculatePrice } from '../../../src/transport/price'
+import { calculatePrice } from '../../../src/transport/ondoPrice'
 
 jest.mock('../../../src/lib/streams', () => ({ getPrice: jest.fn() }))
 const mockGetPrice = getPrice as jest.MockedFunction<typeof getPrice>