Data Engine v11

Author: mxiao-cll

.changeset/hungry-walls-admire.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/data-engine-adapter': minor
+---
+
+Add v11 schema

.pnp.cjs

@@ -36,7 +36,7 @@
     "typescript": "5.8.3"
   },
   "dependencies": {
-    "@chainlink/data-streams-sdk": "^1.0.4",
+    "@chainlink/data-streams-sdk": "1.2.0",
     "@chainlink/external-adapter-framework": "2.8.0",
     "tslib": "2.4.1"
   }

.yarn/cache/@chainlink-data-streams-sdk-npm-1.0.4-d97dafd3a1-32e33c3e87.zip renamed to .yarn/cache/@chainlink-data-streams-sdk-npm-1.2.0-dfeb351ad4-6ee4c81187.zip

@@ -0,0 +1,45 @@
+import { AdapterEndpoint } from '@chainlink/external-adapter-framework/adapter'
+import { InputParameters } from '@chainlink/external-adapter-framework/validation'
+import { config } from '../config'
+import { deutscheBoerseV11Transport } from '../transport/deutscheBoerseV11'
+
+export const inputParameters = new InputParameters(
+  {
+    feedId: {
+      required: true,
+      type: 'string',
+      description: 'The feedId for Deutsche Boerse feed with v11 schema',
+    },
+  },
+  [
+    {
+      feedId: '0x0008707410e2c111fb0e80cab2fa004b215eea2d95b106e700243f9ebcc8fbd9',
+    },
+  ],
+)
+
+export type BaseEndpointTypes = {
+  Parameters: typeof inputParameters.definition
+  Response: {
+    Result: null
+    Data: {
+      mid: string
+      lastSeenTimestampNs: string
+      bid: string
+      bidVolume: number
+      ask: string
+      askVolume: number
+      lastTradedPrice: string
+      marketStatus: number
+      decimals: number
+    }
+  }
+  Settings: typeof config.settings
+}
+
+export const endpoint = new AdapterEndpoint({
+  name: 'deutscheBoerse-v11',
+  aliases: [],
+  transport: deutscheBoerseV11Transport,
+  inputParameters,
+})

packages/sources/data-engine/package.json

@@ -1,2 +1,3 @@
 export { endpoint as cryptoV3 } from './cryptoV3'
+export { endpoint as deutscheBoerseV11 } from './deutscheBoerseV11'
 export { endpoint as rwaV8 } from './rwaV8'

packages/sources/data-engine/src/endpoint/deutscheBoerseV11.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 { cryptoV3, rwaV8 } from './endpoint'
+import { cryptoV3, deutscheBoerseV11, rwaV8 } from './endpoint'
 
 export const adapter = new Adapter({
   defaultEndpoint: cryptoV3.name,
   name: 'DATA_ENGINE',
   config,
-  endpoints: [cryptoV3, rwaV8],
+  endpoints: [cryptoV3, rwaV8, deutscheBoerseV11],
 })
 
 export const server = (): Promise<ServerInstance | undefined> => expose(adapter)

packages/sources/data-engine/src/endpoint/index.ts

@@ -3,6 +3,7 @@ import { Requester } from '@chainlink/external-adapter-framework/util/requester'
 import { AdapterError } from '@chainlink/external-adapter-framework/validation/error'
 
 import { BaseEndpointTypes as CryptoV3Types } from './endpoint/cryptoV3'
+import { BaseEndpointTypes as DeutscheBoerseV11Types } from './endpoint/deutscheBoerseV11'
 import { BaseEndpointTypes as RwaV8Types } from './endpoint/rwaV8'
 
 export const getCryptoPrice = async (feedId: string, url: string, requester: Requester) =>
@@ -11,6 +12,9 @@ export const getCryptoPrice = async (feedId: string, url: string, requester: Req
 export const getRwaPrice = async (feedId: string, url: string, requester: Requester) =>
   callEA<RwaV8Types['Response']['Data']>(feedId, 'rwa-v8', url, requester)
 
+export const getDeutscheBoersePrice = async (feedId: string, url: string, requester: Requester) =>
+  callEA<DeutscheBoerseV11Types['Response']['Data']>(feedId, 'deutscheBoerse-v11', url, requester)
+
 const callEA = async <T>(feedId: string, endpoint: string, url: string, requester: Requester) => {
   const requestConfig = {
     baseURL: url,

packages/sources/data-engine/src/index.ts

@@ -0,0 +1,24 @@
+import { DecodedV11Report } from '@chainlink/data-streams-sdk'
+import { BaseEndpointTypes } from '../endpoint/deutscheBoerseV11'
+import { createDataEngineTransport, DECIMALS } from './wsTransportBase'
+
+export const deutscheBoerseV11Transport = createDataEngineTransport<
+  BaseEndpointTypes,
+  DecodedV11Report
+>({
+  schemaVersion: 'V11',
+  loggerName: 'deutscheBoerseV11Transport',
+  extractData: (decoded) => {
+    return {
+      mid: decoded.mid.toString(),
+      lastSeenTimestampNs: decoded.lastSeenTimestampNs.toString(),
+      bid: decoded.bid.toString(),
+      bidVolume: decoded.bidVolume,
+      ask: decoded.ask.toString(),
+      askVolume: decoded.askVolume,
+      lastTradedPrice: decoded.lastTradedPrice.toString(),
+      marketStatus: decoded.marketStatus,
+      decimals: DECIMALS,
+    }
+  },
+})

packages/sources/data-engine/src/lib.ts

@@ -17,6 +17,28 @@ exports[`execute crypto-v3 endpoint should return success 1`] = `
 }
 `;
 
+exports[`execute deutscheBoerse-v11 endpoint should return success 1`] = `
+{
+  "data": {
+    "ask": "225350000000000000000",
+    "askVolume": 2426047410323587000,
+    "bid": "225300000000000000000",
+    "bidVolume": 2426047410323587000,
+    "decimals": 18,
+    "lastSeenTimestampNs": "1763378650248000000",
+    "lastTradedPrice": "221900000000000000000",
+    "marketStatus": 0,
+    "mid": "225325000000000000000",
+  },
+  "result": null,
+  "statusCode": 200,
+  "timestamps": {
+    "providerDataReceivedUnixMs": 3134,
+    "providerDataStreamEstablishedUnixMs": 3030,
+  },
+}
+`;
+
 exports[`execute rwa-v8 endpoint should return success 1`] = `
 {
   "data": {