Merge branch 'master' of github.com:ccxt/binance-api-node

Author: carlosmiei

README.md

@@ -28,6 +28,7 @@ Import the module and create a new client. Passing api keys is optional only if
 you don't plan on doing authenticated calls. You can create an api key
 [here](https://www.binance.com/userCenter/createApi.html). If you want to create demo/testnet keys click [here](https://demo.binance.com/)
 
+
 ```js
 import Binance from 'binance-api-node'
 
@@ -91,6 +92,7 @@ client.ws.ticker('BTCUSDT', ticker => console.log(ticker))
 ```
 
 **Notes:**
+- `binance-api-node` fully supports the new algo service introduced on the Decemeber 9th of 2025
 - Proxy support is only available in Node.js environment
 - Browsers use system/OS proxy settings automatically
 - Supports HTTP and HTTPS proxies (use `http://` or `https://` protocol)
@@ -153,6 +155,7 @@ Following examples will use the `await` form, which requires some configuration
       - [delivery markPrice](#delivery-markprice)
     - [Authenticated REST Endpoints](#authenticated-rest-endpoints)
       - [order](#order)
+      - [updateOrder](#updateorder)
       - [orderTest](#ordertest)
       - [orderOco](#orderoco)
       - [getOrder](#getorder)
@@ -205,6 +208,8 @@ Following examples will use the `await` form, which requires some configuration
     - [Portfolio Margin Endpoints](#portfolio-margin-endpoints)
       - [getPortfolioMarginAccountInfo](#getportfoliomarginaccountinfo)
     - [Futures Authenticated REST endpoints](#futures-authenticated-rest-endpoints)
+      - [futuresOrder](#futuresorder)
+      - [futuresUpdateOrder](#futuresupdateorder)
       - [futuresGetOrder](#futuresgetorder)
       - [futuresAllOrders](#futuresallorders)
       - [futuresBatchOrders](#futuresbatchorders)
@@ -1375,7 +1380,8 @@ the request.
 
 #### order
 
-Creates a new order.
+- Creates a new order.
+- see https://developers.binance.com/docs/binance-spot-api-docs/rest-api/trading-endpoints#new-order-trade
 
 ```js
 console.log(
@@ -1451,6 +1457,26 @@ Test new order creation and signature/recvWindow. Creates and validates a new or
 
 Same API as above, but does not return any output on success.
 
+
+#### updateOrder
+
+- updates an order
+- see https://developers.binance.com/docs/binance-spot-api-docs/rest-api/trading-endpoints#cancel-an-existing-order-and-send-a-new-order-trade
+
+```Js
+
+  const order = await client.updateOrder({
+        symbol: 'LTCUSDT',
+        cancelOrderId: 12345678,
+        side: 'BUY',
+        type: 'LIMIT',
+        quantity: 1,
+        price: 80,
+        timeInForce: 'GTC',
+    })
+
+```
+
 #### orderOco
 
 Creates a new OCO order.
@@ -3615,6 +3641,42 @@ console.log(await client.getPortfolioMarginAccountInfo())
 
 ### Futures Authenticated REST endpoints
 
+#### futuresOrder
+
+- Creates a futures order
+- see https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/rest-api
+
+```js
+console.log(
+  await client.futuresOrder({
+      symbol: 'LTCUSDT',
+      side: 'BUY',
+      type: 'LIMIT',
+      quantity: 1,
+      price: 80,
+      timeInForce: 'GTC',
+  })
+)
+```
+
+#### futuresUpdateOrder
+- Updates a futures order
+- see https://developers.binance.com/docs/derivatives/usds-margined-futures/trade/rest-api/Modify-Order
+
+```js
+console.log(
+  await client.futuresUpdateOrder({
+      orderId: 23423423423,
+      symbol: 'LTCUSDT',
+      side: 'BUY',
+      type: 'LIMIT',
+      quantity: 1,
+      price: 80,
+      timeInForce: 'GTC',
+  })
+)
+```
+
 #### futuresGetOrder
 
 Check an order's status.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "binance-api-node",
-  "version": "0.13.4",
+  "version": "0.13.5",
   "description": "A node API wrapper for Binance",
   "main": "dist",
   "browser": {
@@ -22,7 +22,7 @@
     "build": "rm -rf dist && babel src -d dist",
     "prepare": "npm run build",
     "test": "npm run test:ava && npm run test:browser",
-    "test:ava": "ava --timeout=10s -v",
+    "test:ava": "ava --timeout=90s -v",
     "test:browser": "node test/browser/browser-test-runner.mjs && ava test/browser/crypto-browser-playwright.js test/browser/websocket-browser.test.js --timeout=15s -v",
     "test:browser:signature": "node test/browser/browser-test-runner.mjs",
     "test:browser:websocket": "ava test/browser/websocket-browser.test.js --timeout=15s -v",

src/http-client.js

@@ -404,6 +404,27 @@ const orderOco = (privCall, payload = {}, url) => {
     )
 }
 
+const updateOrder = (privCall, payload = {}, url) => {
+    const newPayload = { ...payload }
+
+    if (!newPayload.cancelReplaceMode) {
+        newPayload.cancelReplaceMode = 'STOP_ON_FAILURE'
+    }
+
+    if (!newPayload.timeInForce) {
+        newPayload.timeInForce = 'GTC'
+    }
+
+    if (!newPayload.newClientOrderId) {
+        newPayload.newClientOrderId = spotP()
+    }
+
+    return (
+        checkParams('updateOrder', newPayload, ['symbol', 'side', 'type']) &&
+        privCall(url, newPayload, 'POST')
+    )
+}
+
 /**
  * Zip asks and bids reponse from order book
  */
@@ -486,6 +507,7 @@ export default opts => {
 
         // Order endpoints
         order: payload => order(privCall, payload, '/api/v3/order'),
+        updateOrder: payload => updateOrder(privCall, payload, '/api/v3/order/cancelReplace'),
         orderOco: payload => orderOco(privCall, payload, '/api/v3/order/oco'),
         orderTest: payload => order(privCall, payload, '/api/v3/order/test'),
         getOrder: payload => privCall('/api/v3/order', payload),
@@ -570,15 +592,114 @@ export default opts => {
         futuresFundingRate: payload =>
             checkParams('fundingRate', payload, ['symbol']) &&
             pubCall('/fapi/v1/fundingRate', payload),
-        futuresOrder: payload => order(privCall, payload, '/fapi/v1/order'),
+        futuresOrder: payload => {
+            // Check if this is a conditional order type that should be routed to algo endpoint
+            const orderType = payload?.type?.toUpperCase()
+            const conditionalTypes = [
+                'STOP',
+                'STOP_MARKET',
+                'TAKE_PROFIT',
+                'TAKE_PROFIT_MARKET',
+                'TRAILING_STOP_MARKET',
+            ]
+
+            if (orderType && conditionalTypes.includes(orderType)) {
+                // Route to algo order endpoint
+                const algoPayload = { ...payload }
+                if (!algoPayload.clientAlgoId) {
+                    algoPayload.clientAlgoId = futuresP()
+                }
+                delete algoPayload.newClientOrderId
+                algoPayload.algoType = 'CONDITIONAL'
+                if (algoPayload.stopPrice && !algoPayload.triggerPrice) {
+                    algoPayload.triggerPrice = algoPayload.stopPrice
+                    delete algoPayload.stopPrice
+                }
+                return privCall('/fapi/v1/algoOrder', algoPayload, 'POST')
+            }
+            // Use regular order endpoint
+            return order(privCall, payload, '/fapi/v1/order')
+        },
+        futuresUpdateOrder: payload => {
+            if (payload && 'conditional' in payload) {
+                // for now it is not supported
+                // const payloadCopy = { ...payload }
+                // delete payloadCopy.conditional
+                // return privCall('/fapi/v1/algoOrder', payloadCopy, 'PUT')
+            }
+            return privCall('/fapi/v1/order', payload, 'PUT')
+        },
         futuresBatchOrders: payload => privCall('/fapi/v1/batchOrders', payload, 'POST'),
-        futuresGetOrder: payload => privCall('/fapi/v1/order', payload),
-        futuresCancelOrder: payload => privCall('/fapi/v1/order', payload, 'DELETE'),
-        futuresCancelAllOpenOrders: payload =>
-            privCall('/fapi/v1/allOpenOrders', payload, 'DELETE'),
+        futuresGetOrder: payload => {
+            // Check if this is a request for a conditional/algo order
+            const isConditional = payload?.conditional
+            const hasAlgoId = payload?.algoId || payload?.clientAlgoId
+            let payloadCopy = payload
+            if (payload && 'conditional' in payload) {
+                payloadCopy = { ...payload }
+                delete payloadCopy.conditional
+            }
+
+            if (isConditional || hasAlgoId) {
+                return privCall('/fapi/v1/algoOrder', payloadCopy)
+            }
+            return privCall('/fapi/v1/order', payloadCopy)
+        },
+        futuresCancelOrder: payload => {
+            // Check if this is a request for a conditional/algo order
+            const isConditional = payload?.conditional
+            const hasAlgoId = payload?.algoId || payload?.clientAlgoId
+            let payloadCopy = payload
+            if (payload && 'conditional' in payload) {
+                payloadCopy = { ...payload }
+                delete payloadCopy.conditional
+            }
+
+            if (isConditional || hasAlgoId) {
+                return privCall('/fapi/v1/algoOrder', payloadCopy, 'DELETE')
+            }
+            return privCall('/fapi/v1/order', payloadCopy, 'DELETE')
+        },
+        futuresCancelAllOpenOrders: payload => {
+            const isConditional = payload?.conditional
+            let payloadCopy = payload
+            if (payload && 'conditional' in payload) {
+                payloadCopy = { ...payload }
+                delete payloadCopy.conditional
+            }
+
+            if (isConditional) {
+                return privCall('/fapi/v1/algoOpenOrders', payloadCopy, 'DELETE')
+            }
+            return privCall('/fapi/v1/allOpenOrders', payloadCopy, 'DELETE')
+        },
         futuresCancelBatchOrders: payload => privCall('/fapi/v1/batchOrders', payload, 'DELETE'),
-        futuresOpenOrders: payload => privCall('/fapi/v1/openOrders', payload),
-        futuresAllOrders: payload => privCall('/fapi/v1/allOrders', payload),
+        futuresOpenOrders: payload => {
+            const isConditional = payload?.conditional
+            let payloadCopy = payload
+            if (payload && 'conditional' in payload) {
+                payloadCopy = { ...payload }
+                delete payloadCopy.conditional
+            }
+
+            if (isConditional) {
+                return privCall('/fapi/v1/openAlgoOrders', payloadCopy)
+            }
+            return privCall('/fapi/v1/openOrders', payloadCopy)
+        },
+        futuresAllOrders: payload => {
+            const isConditional = payload?.conditional
+            let payloadCopy = payload
+            if (payload && 'conditional' in payload) {
+                payloadCopy = { ...payload }
+                delete payloadCopy.conditional
+            }
+
+            if (isConditional) {
+                return privCall('/fapi/v1/allAlgoOrders', payloadCopy)
+            }
+            return privCall('/fapi/v1/allOrders', payloadCopy)
+        },
         futuresPositionRisk: payload => privCall('/fapi/v2/positionRisk', payload),
         futuresLeverageBracket: payload => privCall('/fapi/v1/leverageBracket', payload),
         futuresAccountBalance: payload => privCall('/fapi/v2/balance', payload),
@@ -594,6 +715,26 @@ export default opts => {
         futuresIncome: payload => privCall('/fapi/v1/income', payload),
         getMultiAssetsMargin: payload => privCall('/fapi/v1/multiAssetsMargin', payload),
         setMultiAssetsMargin: payload => privCall('/fapi/v1/multiAssetsMargin', payload, 'POST'),
+        futuresRpiDepth: payload => book(pubCall, payload, '/fapi/v1/rpiDepth'),
+        futuresSymbolAdlRisk: payload => pubCall('/fapi/v1/symbolAdlRisk', payload),
+        futuresCommissionRate: payload => privCall('/fapi/v1/commissionRate', payload),
+
+        // Algo Orders (Conditional Orders)
+        futuresCreateAlgoOrder: payload => {
+            if (!payload.clientAlgoId) {
+                payload.clientAlgoId = futuresP()
+            }
+            if (!payload.algoType) {
+                payload.algoType = 'CONDITIONAL'
+            }
+            return privCall('/fapi/v1/algoOrder', payload, 'POST')
+        },
+        futuresCancelAlgoOrder: payload => privCall('/fapi/v1/algoOrder', payload, 'DELETE'),
+        futuresCancelAllAlgoOpenOrders: payload =>
+            privCall('/fapi/v1/algoOpenOrders', payload, 'DELETE'),
+        futuresGetAlgoOrder: payload => privCall('/fapi/v1/algoOrder', payload),
+        futuresGetOpenAlgoOrders: payload => privCall('/fapi/v1/openAlgoOrders', payload),
+        futuresGetAllAlgoOrders: payload => privCall('/fapi/v1/allAlgoOrders', payload),
 
         // Delivery endpoints
         deliveryPing: () => pubCall('/dapi/v1/ping').then(() => true),

src/websocket.js

@@ -82,6 +82,24 @@ const depth = (payload, cb, transform = true, variator) => {
         )
 }
 
+const futuresRpiDepth = (payload, cb, transform = true) => {
+    const cache = (Array.isArray(payload) ? payload : [payload]).map(symbol => {
+        const symbolName = symbol.toLowerCase()
+        const w = openWebSocket(`${endpoints.futures}/${symbolName}@rpiDepth@500ms`)
+        w.onmessage = msg => {
+            const obj = JSONbig.parse(msg.data)
+            cb(transform ? futuresDepthTransform(obj) : obj)
+        }
+
+        return w
+    })
+
+    return options =>
+        cache.forEach(w =>
+            w.close(1000, 'Close handle was called', { keepClosed: true, ...options }),
+        )
+}
+
 const partialDepthTransform = (symbol, level, m) => ({
     symbol,
     level,
@@ -1017,6 +1035,7 @@ export default opts => {
 
         futuresDepth: (payload, cb, transform) => depth(payload, cb, transform, 'futures'),
         deliveryDepth: (payload, cb, transform) => depth(payload, cb, transform, 'delivery'),
+        futuresRpiDepth,
         futuresPartialDepth: (payload, cb, transform) =>
             partialDepth(payload, cb, transform, 'futures'),
         deliveryPartialDepth: (payload, cb, transform) =>