Comment

Author: mxiao-cll

packages/sources/dxfeed/src/transport/stock-quotes.ts

@@ -8,6 +8,7 @@ const bidSizeIndex = 7
 const askTimeIndex = 8
 const askPriceIndex = 10
 const askSizeIndex = 11
+const dataLength = 12
 
 export const transport = buildWsTransport<BaseEndpointTypes>(
   (params) => ({ Quote: [params.base.toUpperCase()] }),
@@ -18,6 +19,10 @@ export const transport = buildWsTransport<BaseEndpointTypes>(
 
     const data = message[0].data[1]
 
+    if (data.length != dataLength) {
+      return []
+    }
+
     const bidPrice = Number(data[bidPriceIndex])
     const askPrice = Number(data[askPriceIndex])
 

packages/sources/dxfeed/test/integration/__snapshots__/adapter-ws.test.ts.snap

@@ -1,5 +1,16 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
+exports[`websocket quote endpoint error when data length is not valid 1`] = `
+{
+  "error": {
+    "message": "The EA has not received any values from the Data Provider for the requested data yet. Retry after a short delay, and if the problem persists raise this issue in the relevant channels.",
+    "name": "AdapterError",
+  },
+  "status": "errored",
+  "statusCode": 504,
+}
+`;
+
 exports[`websocket quote endpoint should return ask when bid is 0 1`] = `
 {
   "data": {

packages/sources/dxfeed/test/integration/adapter-ws.test.ts

@@ -83,5 +83,13 @@ describe('websocket', () => {
       })
       expect(response.json()).toMatchSnapshot()
     })
+
+    it('error when data length is not valid', async () => {
+      const response = await testAdapter.request({
+        base: 'INVALID_DATA',
+        endpoint: 'stock_quotes',
+      })
+      expect(response.json()).toMatchSnapshot()
+    })
   })
 })

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

@@ -81,6 +81,15 @@ export const mockWebSocketServer = (URL: string): MockWebsocketServer => {
       channel: '/service/data',
     },
   ]
+  const quoteReponse4 = [
+    {
+      data: [
+        'Quote',
+        ['INVALID_DATA', 0, 0, 0, 1670868378000, 'V', 170.0, 148.0, 1670868370000, 'V', 0],
+      ],
+      channel: '/service/data',
+    },
+  ]
   const tradeResponse = [
     {
       data: [
@@ -118,6 +127,7 @@ export const mockWebSocketServer = (URL: string): MockWebsocketServer => {
       socket.send(JSON.stringify(quoteReponse))
       socket.send(JSON.stringify(quoteReponse2))
       socket.send(JSON.stringify(quoteReponse3))
+      socket.send(JSON.stringify(quoteReponse4))
       socket.send(JSON.stringify(tradeResponse))
     })
   })