Update tardis-dev to 16.5.0

Author: thaaddeus

package-lock.json

@@ -78,7 +78,7 @@
     "debug": "^4.4.1",
     "find-my-way": "^9.3.0",
     "is-docker": "^2.2.1",
-    "tardis-dev": "^16.4.2",
+    "tardis-dev": "^16.5.0",
     "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.59.0",
     "yargs": "^17.5.1"
   },

package.json

@@ -704,7 +704,30 @@ const bullishMapper: SubscriptionMapper = {
   }
 }
 
-export const subscriptionsMappers: Partial<Record<Exchange | 'lighter', SubscriptionMapper>> = {
+const polymarketMapper: SubscriptionMapper = {
+  canHandle: (message: any) => {
+    return message.type === 'market'
+  },
+
+  map: (message: any) => {
+    const symbols = message.assets_ids
+
+    const filters = [
+      { channel: 'book', symbols },
+      { channel: 'price_change', symbols },
+      { channel: 'last_trade_price', symbols },
+      { channel: 'tick_size_change', symbols }
+    ]
+
+    if (message.custom_feature_enabled === true) {
+      filters.push({ channel: 'best_bid_ask', symbols }, { channel: 'new_market', symbols }, { channel: 'market_resolved', symbols })
+    }
+
+    return filters
+  }
+}
+
+export const subscriptionsMappers: Record<Exchange, SubscriptionMapper> = {
   bitmex: bitmexMapper,
   coinbase: coinbaseMaper,
   deribit: deribitMapper,
@@ -763,7 +786,8 @@ export const subscriptionsMappers: Partial<Record<Exchange | 'lighter', Subscrip
   'coinbase-international': coinbaseInternationalMapper,
   hyperliquid: hyperliquidMapper,
   lighter: lighterMapper,
-  bullish: bullishMapper
+  bullish: bullishMapper,
+  polymarket: polymarketMapper
 }
 
 export type SubscriptionMapper = {

src/ws/subscriptionsmappers.ts

@@ -50,4 +50,50 @@ describe('subscriptions mappers', () => {
       { channel: 'V1TAIndexPrice', symbols: ['BTC'] }
     ])
   })
+
+  test('maps Polymarket market subscriptions', () => {
+    const mapper = subscriptionsMappers.polymarket
+    const date = new Date()
+    const message = { type: 'market', assets_ids: ['2174101397', '713210352'] }
+
+    expect(mapper.canHandle(message, date)).toBe(true)
+    expect(mapper.map(message, date)).toEqual([
+      { channel: 'book', symbols: ['2174101397', '713210352'] },
+      { channel: 'price_change', symbols: ['2174101397', '713210352'] },
+      { channel: 'last_trade_price', symbols: ['2174101397', '713210352'] },
+      { channel: 'tick_size_change', symbols: ['2174101397', '713210352'] }
+    ])
+  })
+
+  test('maps Polymarket custom market subscriptions', () => {
+    const mapper = subscriptionsMappers.polymarket
+    const date = new Date()
+    const message = { type: 'market', assets_ids: ['2174101397'], custom_feature_enabled: true }
+
+    expect(mapper.map(message, date)).toEqual([
+      { channel: 'book', symbols: ['2174101397'] },
+      { channel: 'price_change', symbols: ['2174101397'] },
+      { channel: 'last_trade_price', symbols: ['2174101397'] },
+      { channel: 'tick_size_change', symbols: ['2174101397'] },
+      { channel: 'best_bid_ask', symbols: ['2174101397'] },
+      { channel: 'new_market', symbols: ['2174101397'] },
+      { channel: 'market_resolved', symbols: ['2174101397'] }
+    ])
+  })
+
+  test('maps Polymarket empty asset subscriptions', () => {
+    const mapper = subscriptionsMappers.polymarket
+    const date = new Date()
+    const message = { type: 'market', assets_ids: [], custom_feature_enabled: true }
+
+    expect(mapper.map(message, date)).toEqual([
+      { channel: 'book', symbols: [] },
+      { channel: 'price_change', symbols: [] },
+      { channel: 'last_trade_price', symbols: [] },
+      { channel: 'tick_size_change', symbols: [] },
+      { channel: 'best_bid_ask', symbols: [] },
+      { channel: 'new_market', symbols: [] },
+      { channel: 'market_resolved', symbols: [] }
+    ])
+  })
 })