coinw 添加数据实例

client/coinw.test.js

@@ -97,9 +97,9 @@ describe('coinw站点测试', () => {
             console.error(e)
         }
 
-        await sleep(9999999)
+        await sleep(timeout)
 
-    })
+    }, timeout)
 
     test('监听wss', async (done) => {
 
@@ -214,9 +214,52 @@ describe('coinw站点测试', () => {
 
         Network.webSocketFrameReceived(params => {
             // console.log('WebSocket frame received:', params.response)
-            console.info('webSocketFrameReceived 回复', params.response)
+            // console.info('webSocketFrameReceived 回复', params.response)
             let data = formatResponse(params)
             console.info('webSocketFrameReceived解析结果:', data)
+            let target = [{
+                //实时跟踪数据
+                base: 'ai', //币种
+                type: 'ticker_swap',
+                biz: 'indexes',
+            }, {
+                //标记价格
+                base: 'ai',
+                type: 'mark_price',
+                biz: 'mark_price',
+            }, {
+                //K线数据
+                base: 'ai',
+                type: 'level5',
+                biz: 'depth',
+            }, {
+                // 不知道是什么
+                base: 'ai',
+                type: 'candles_swap',
+                biz: 'indexes',
+            }, {
+                //合约费率
+                base: 'ai',
+                type: 'funding_rate',
+                biz: 'funding_rate',
+            }, {
+                //合约费率
+                base: 'ai',
+                type: 'funding_rate',
+                biz: 'funding_rate',
+            }]
+
+            let res = target.filter(val => {
+                let keys = Object.keys(val), is = false
+
+                for (let key of keys) {
+                    is &&= data[key] === val[key]
+                }
+                return is
+            }).length ? data : ''
+
+            console.info('>>>', res)
+
         })
         Network.webSocketFrameError(params => {
             console.log('WebSocket frame error:', params.response)