tardis-machine - npm Package Compare versions

Comparing version 3.31.2 to 3.32.0

dist/ws/subscriptionsmappers.js

@@ -537,2 +537,15 @@ "use strict";
 };
+const coinbaseInternationalMapper = {
+    canHandle: (message) => {
+        return message.type === 'SUBSCRIBE';
+    },
+    map: (message) => {
+        return message.channels.map((channel) => {
+            return {
+                channel,
+                symbols: message.product_ids
+            };
+        });
+    }
+};
 exports.subscriptionsMappers = {
@@ -595,4 +608,5 @@ bitmex: bitmexMapper,
     bitget: bitgetMapper,
-    'bitget-futures': bitgetMapper
+    'bitget-futures': bitgetMapper,
+    'coinbase-international': coinbaseInternationalMapper
 };
 //# sourceMappingURL=subscriptionsmappers.js.map

package.json

 {
   "name": "tardis-machine",
-  "version": "3.31.2",
+  "version": "3.32.0",
   "engines": {
@@ -62,3 +62,3 @@ "node": ">=16"
     "is-docker": "^2.2.1",
-    "tardis-dev": "^13.31.2",
+    "tardis-dev": "^13.32.0",
     "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.42.0",
@@ -65,0 +65,0 @@ "yargs": "^17.5.1"

src/ws/subscriptionsmappers.ts

@@ -623,3 +623,17 @@ import { Exchange, Filter } from 'tardis-dev'
 }
+const coinbaseInternationalMapper: SubscriptionMapper = {
+  canHandle: (message: any) => {
+    return message.type === 'SUBSCRIBE'
+  },
 
+  map: (message: any) => {
+    return message.channels.map((channel: string) => {
+      return {
+        channel,
+        symbols: message.product_ids
+      }
+    })
+  }
+}
+
 export const subscriptionsMappers: { [key in Exchange]: SubscriptionMapper } = {
@@ -682,3 +696,4 @@ bitmex: bitmexMapper,
   bitget: bitgetMapper,
-  'bitget-futures': bitgetMapper
+  'bitget-futures': bitgetMapper,
+  'coinbase-international': coinbaseInternationalMapper
 }
@@ -685,0 +700,0 @@

No alert changes

Improved metrics

Total package byte prevSize

191197

0.57%

Lines of code

3369

0.84%

Dependency changes

• Updated

  tardis-dev@^13.32.0