Feature/df 18971 gsr lwba endpoint

.changeset/rotten-humans-reply.md

@@ -0,0 +1,5 @@
+---
+'@chainlink/gsr-adapter': minor
+---
+
+Added LWBA endpoint for GSR EA

packages/sources/gsr/src/endpoint/price.ts

@@ -9,15 +9,24 @@ import { transport } from '../transport/price'
 
 const inputParameters = new InputParameters(priceEndpointInputParametersDefinition)
 
+// Additional fields are due to lwba endpoint
+type EPResponse = SingleNumberResultResponse & {
+  Data: {
+    mid: number
+    bid: number
+    ask: number
+  }
+}
+
 export type BaseEndpointTypes = {
   Parameters: typeof inputParameters.definition
   Settings: typeof config.settings
-  Response: SingleNumberResultResponse
+  Response: EPResponse
 }
 
 export const endpoint = new CryptoPriceEndpoint({
   name: 'price',
-  aliases: ['price-ws', 'crypto'],
+  aliases: ['price-ws', 'crypto', 'crypto-lwba', 'cryptolwba', 'crypto_lwba'],
   transport,
   inputParameters,
 })

packages/sources/gsr/src/index.ts

@@ -4,7 +4,7 @@ import { config } from './config'
 import { price } from './endpoint'
 
 export const adapter = new PriceAdapter({
-  defaultEndpoint: 'price',
+  defaultEndpoint: price.name,
   name: 'GSR',
   endpoints: [price],
   config,

packages/sources/gsr/src/transport/authutils.ts

@@ -0,0 +1,52 @@
+import crypto from 'crypto'
+import axios from 'axios'
+import { config } from '../config'
+import { makeLogger } from '@chainlink/external-adapter-framework/util'
+
+const logger = makeLogger('GSR Auth Token Utils')
+
+interface TokenError {
+  success: false
+  ts: number
+  error: string
+}
+
+interface TokenSuccess {
+  success: true
+  ts: number
+  token: string
+  validUntil: string
+}
+
+type AccessTokenResponse = TokenError | TokenSuccess
+
+const currentTimeNanoSeconds = (): number => new Date(Date.now()).getTime() * 1000000
+
+const generateSignature = (userId: string, publicKey: string, privateKey: string, ts: number) =>
+  crypto
+    .createHmac('sha256', privateKey)
+    .update(`userId=${userId}&apiKey=${publicKey}&ts=${ts}`)
+    .digest('hex')
+
+export const getToken = async (settings: typeof config.settings) => {
+  logger.debug('Fetching new access token')
+
+  const userId = settings.WS_USER_ID
+  const publicKey = settings.WS_PUBLIC_KEY
+  const privateKey = settings.WS_PRIVATE_KEY
+  const ts = currentTimeNanoSeconds()
+  const signature = generateSignature(userId, publicKey, privateKey, ts)
+  const response = await axios.post<AccessTokenResponse>(`${settings.API_ENDPOINT}/token`, {
+    apiKey: publicKey,
+    userId,
+    ts,
+    signature,
+  })
+
+  if (!response.data.success) {
+    logger.error('Unable to get access token')
+    throw new Error(response.data.error)
+  }
+
+  return response.data.token
+}

packages/sources/gsr/src/transport/price.ts

@@ -1,9 +1,7 @@
-import crypto from 'crypto'
-import { config } from '../config'
 import { BaseEndpointTypes } from '../endpoint/price'
 import { WebSocketTransport } from '@chainlink/external-adapter-framework/transports'
-import axios from 'axios'
 import { makeLogger, ProviderResult } from '@chainlink/external-adapter-framework/util'
+import { getToken } from './authutils'
 
 const logger = makeLogger('GSR WS price')
 
@@ -12,6 +10,8 @@ type WsMessage = {
   data: {
     symbol: string
     price: number
+    bidPrice: number
+    askPrice: number
     ts: number
   }
 }
@@ -22,52 +22,6 @@ export type WsTransportTypes = BaseEndpointTypes & {
   }
 }
 
-export interface TokenError {
-  success: false
-  ts: number
-  error: string
-}
-
-export interface TokenSuccess {
-  success: true
-  ts: number
-  token: string
-  validUntil: string
-}
-
-export type AccessTokenResponse = TokenError | TokenSuccess
-
-const currentTimeNanoSeconds = (): number => new Date(Date.now()).getTime() * 1000000
-
-const generateSignature = (userId: string, publicKey: string, privateKey: string, ts: number) =>
-  crypto
-    .createHmac('sha256', privateKey)
-    .update(`userId=${userId}&apiKey=${publicKey}&ts=${ts}`)
-    .digest('hex')
-
-const getToken = async (settings: typeof config.settings) => {
-  logger.debug('Fetching new access token')
-
-  const userId = settings.WS_USER_ID
-  const publicKey = settings.WS_PUBLIC_KEY
-  const privateKey = settings.WS_PRIVATE_KEY
-  const ts = currentTimeNanoSeconds()
-  const signature = generateSignature(userId, publicKey, privateKey, ts)
-  const response = await axios.post<AccessTokenResponse>(`${settings.API_ENDPOINT}/token`, {
-    apiKey: publicKey,
-    userId,
-    ts,
-    signature,
-  })
-
-  if (!response.data.success) {
-    logger.error('Unable to get access token')
-    throw new Error(response.data.error)
-  }
-
-  return response.data.token
-}
-
 export const transport = new WebSocketTransport<WsTransportTypes>({
   url: (context) => context.adapterSettings.WS_API_ENDPOINT,
   options: async (context) => ({
@@ -104,6 +58,9 @@ export const transport = new WebSocketTransport<WsTransportTypes>({
             result: message.data.price,
             data: {
               result: message.data.price,
+              mid: message.data.price,
+              bid: message.data.bidPrice,
+              ask: message.data.askPrice,
             },
             timestamps: {
               providerIndicatedTimeUnixMs: Math.round(message.data.ts / 1e6), // Value from provider is in nanoseconds

packages/sources/gsr/test-payload.json

@@ -1,6 +1,13 @@
 {
- "requests": [{
-  "from": "ETH",
-  "to": "USD"
- }]
+ "requests": [
+    {
+      "from": "ETH",
+      "to": "USD"
+    },
+    {
+      "from": "ETH",
+      "to": "USD",
+      "endpoint": "crypto-lwba"
+    }
+  ]
 }

packages/sources/gsr/test/integration/__snapshots__/adapter.test.ts.snap

@@ -1,8 +1,29 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
+exports[`websocket websocket endpoint lwba endpoint alias should return success 1`] = `
+{
+  "data": {
+    "ask": 1235,
+    "bid": 1233,
+    "mid": 1234,
+    "result": 1234,
+  },
+  "result": 1234,
+  "statusCode": 200,
+  "timestamps": {
+    "providerDataReceivedUnixMs": Any<Number>,
+    "providerDataStreamEstablishedUnixMs": Any<Number>,
+    "providerIndicatedTimeUnixMs": 1669345393482,
+  },
+}
+`;
+
 exports[`websocket websocket endpoint should return success 1`] = `
 {
   "data": {
+    "ask": 1235,
+    "bid": 1233,
+    "mid": 1234,
     "result": 1234,
   },
   "result": 1234,

packages/sources/gsr/test/integration/adapter.test.ts

@@ -63,6 +63,20 @@ describe('websocket', () => {
       })
     })
 
+    it('lwba endpoint alias should return success', async () => {
+      const response = await testAdapter.request({
+        base: 'ETH',
+        quote: 'USD',
+        endpoint: 'crypto-lwba',
+      })
+      expect(response.json()).toMatchSnapshot({
+        timestamps: {
+          providerDataReceivedUnixMs: expect.any(Number),
+          providerDataStreamEstablishedUnixMs: expect.any(Number),
+        },
+      })
+    })
+
     it('should return error (empty data)', async () => {
       const response = await testAdapter.request({})
       expect(response.statusCode).toEqual(400)

packages/sources/gsr/test/integration/fixtures.ts

@@ -35,6 +35,8 @@ export const mockTokenSuccess = (): nock.Scope =>
 const base = 'ETH'
 const quote = 'USD'
 const price = 1234
+const bidPrice = 1233
+const askPrice = 1235
 const time = 1669345393482
 
 export const mockWebSocketServer = (URL: string) => {
@@ -47,6 +49,8 @@ export const mockWebSocketServer = (URL: string) => {
           data: {
             symbol: `${base.toUpperCase()}.${quote.toUpperCase()}`,
             price,
+            bidPrice,
+            askPrice,
             ts: time * 1e6,
           },
         }),