[EXCH-4240] operatorId support in WS

Author: ramazan-bitvavo

example/testApi.js

@@ -631,12 +631,13 @@ let testWebSockets = async () => {
   // bitvavo.websocket.tickerPrice({ market: 'BTC-EUR' })
   // bitvavo.websocket.tickerBook({ market: 'BTC-EUR' })
 
-  // bitvavo.websocket.placeOrder('BTC-EUR', 'sell', 'limit', { amount: '1', price: '6000' })
+  let operatorId = 1
+  // bitvavo.websocket.placeOrder('BTC-EUR', 'sell', 'limit', operatorId, { amount: '0.01', price: '97000' })
   // bitvavo.websocket.getOrder('BTC-EUR', '89c1a7f6-5fa1-4fa6-8a8d-aa2388798d4a')
-  // bitvavo.websocket.updateOrder('BTC-EUR', 'bc86d303-c199-404d-b742-f9b3a030916f', { amount: '0.5' })
-  // bitvavo.websocket.cancelOrder('BTC-EUR', 'bc86d303-c199-404d-b742-f9b3a030916f')
+  // bitvavo.websocket.updateOrder('BTC-EUR', 'bc86d303-c199-404d-b742-f9b3a030916f', operatorId,{ amount: '0.012' })
+  // bitvavo.websocket.cancelOrder('BTC-EUR', 'bc86d303-c199-404d-b742-f9b3a030916f', operatorId)
   // bitvavo.websocket.getOrders('BTC-EUR', { limit: 10 })
-  // bitvavo.websocket.cancelOrders({ market: 'BTC-EUR' })
+  // bitvavo.websocket.cancelOrders({ market: 'BTC-EUR' }, operatorId)
   // bitvavo.websocket.ordersOpen({ market: 'BTC-EUR' })
   // bitvavo.websocket.trades('BTC-EUR', {})
 

lib/index.js

@@ -774,12 +774,17 @@ let api = function Bitvavo() {
       //                           stopLoss/takeProfit:(amount, amountQuote, disableMarketProtection, triggerType, triggerReference, triggerAmount)
       //                           stopLossLimit/takeProfitLimit:(amount, price, postOnly, triggerType, triggerReference, triggerAmount)
       //                           all orderTypes: timeInForce, selfTradePrevention, responseRequired
-      placeOrder: async function (market = '', side = '', orderType = '', body = {}) {
+      placeOrder: async function (market = '',
+                                  side = '',
+                                  orderType = '',
+                                  operatorId = 0,
+                                  body = {}) {
         await this.checkSocket()
         body.action = 'privateCreateOrder'
         body.market = market
         body.side = side
         body.orderType = orderType
+        body.operatorId = operatorId
         doSendPrivate.call(this, JSON.stringify(body))
       },
 
@@ -802,19 +807,21 @@ let api = function Bitvavo() {
       // Optional body parameters: limit:(amount, amountRemaining, price, timeInForce, selfTradePrevention, postOnly)
       //               untriggered stopLoss/takeProfit:(amount, amountQuote, disableMarketProtection, triggerType, triggerReference, triggerAmount)
       //                           stopLossLimit/takeProfitLimit: (amount, price, postOnly, triggerType, triggerReference, triggerAmount)
-      updateOrder: async function (market = '', orderId = '', body = {}) {
+      updateOrder: async function (market = '', orderId = '', operatorId = 0, body = {}) {
         await this.checkSocket()
         body.action = 'privateUpdateOrder'
         body.market = market
         body.orderId = orderId
+        body.operatorId = operatorId
         doSendPrivate.call(this, JSON.stringify(body))
       },
 
-      cancelOrder: async function (market = '', orderId = '') {
+      cancelOrder: async function (market = '', orderId = '', operatorId = 0) {
         await this.checkSocket()
         let options = { 'action': 'privateCancelOrder' }
         options.market = market
         options.orderId = orderId
+        options.operatorId = operatorId
         doSendPrivate.call(this, JSON.stringify(options))
       },
 
@@ -827,9 +834,10 @@ let api = function Bitvavo() {
       },
 
       // options: market
-      cancelOrders: async function (options = {}) {
+      cancelOrders: async function (options = {}, operatorId = 0) {
         await this.checkSocket()
         options.action = 'privateCancelOrders'
+        options.operatorId = operatorId
         doSendPrivate.call(this, JSON.stringify(options))
       },