编辑移动止盈止损（WS）

{
  "id": 1761291309, // 调用id,响应结果返回相同ID
  "method": "updateTrailingStopOrder", // 调用编辑移动止盈止损任务方法
  "params": {
    "id": "mh47j196043lfy", // 移动止盈止损任务id
    "enabled": false, //  "true"表示启用移动止盈止损任务
    "amountOrPercent": 1, // 卖出比例 (0-1)，0.5表示卖出50%
    "customFeeAndTip": false, // "true"表示优先费 (priorityFee) 和贿赂费 (jitoTip) 两个字段均有效，系统将按填写的值执行交易 (null表示自动优先费/自动贿赂费)，"false"表示高速模式下只有优先费 (priorityFee) 有效，防夹模式下只有贿赂费 (jitoTip) 有效，系统将自动进行分配
    "priorityFee": "", // 优先费 (SOL)，对Solana有效，空字符串表示使用自动优先费
    "gasFeeDelta": 5, // 额外增加的gas (Gwei)，对EVM链有效
    "maxFeePerGas": 100, // 基础gas超过此值时将不进行交易 (Gwei)，对EVM链有效
    "jitoEnabled": true, // "true"表示启用防夹模式 (Solana & Ethereum & Bsc)
    "jitoTip": 0.0021, // 防夹模式使用的贿赂费 (Solana)，"jitoEnabled"或"customFeeAndTip"为true时必填 (null表示自动优先费/自动贿赂费)
    "expireDelta": 360000000, // 任务有效时长，最大值为432000000 (毫秒)
    "expireExecute": false, // "true"表示任务过期仍未触发时，会按过期时的实时价格买入或卖出代币
    "useMidPrice": false, // "true"表示启用防插针模式，将使用1秒内的中间价格作为触发价，会尽可能但无法100%保证避免插针
    "maxSlippage": 0.1, // 最大滑点（0.00-1.00），买入时表示实际成交价格和期望价格之间的差距，卖出时表示期望价格和实际成交价格之间的差距，相差倍数=1/(1-滑点)，0.5即最多接受2倍价差，1 即不限制价差
    "concurrentNodes": 2, // 并发节点数（1-3）
    "retries": 1 // 失败后的重试次数（0-10）
  }
}

{
    "method": "rpcResponse", // rpc响应
    "id": 1761291309, // 调用id
    "result": {
        "err": false // 是否发生错误
    }
}

const WebSocket = require('ws')

function main() {
  const ws = new WebSocket('wss://api-data-v1.dbotx.com/trade/ws/', {
    headers: {
      'x-api-key': 'YOUR_API_KEY',
    },
  })

  ws.on('open', () => {
    ws.send(
      JSON.stringify({
        "id": 1761291309,
        "method": "updateTrailingStopOrder",
        "params": {
          "id": "mh47j196043lfy",
          "enabled": false,
          "amountOrPercent": 1,
          "customFeeAndTip": false,
          "priorityFee": "",
          "gasFeeDelta": 5,
          "maxFeePerGas": 100,
          "jitoEnabled": true,
          "jitoTip": 0.0021,
          "expireDelta": 360000000,
          "expireExecute": false,
          "useMidPrice": false,
          "maxSlippage": 0.1,
          "concurrentNodes": 2,
          "retries": 1
        }
      })
    )

    setInterval(() => {
      ws.ping()
    }, 30000)
  })

  ws.on('message', res => {
    console.log('res:', res.toString('utf-8'));
  })
}

main()

import asyncio
import websockets
import json

async def main():
    uri = "wss://api-data-v1.dbotx.com/trade/ws/"
    headers = {"x-api-key": "YOUR_API_KEY"}
    msg = {
        "id": 1761291309,
        "method": "updateTrailingStopOrder",
        "params": {
            "id": "mh47j196043lfy",
            "enabled": false,
            "amountOrPercent": 1,
            "customFeeAndTip": false,
            "priorityFee": "",
            "gasFeeDelta": 5,
            "maxFeePerGas": 100,
            "jitoEnabled": true,
            "jitoTip": 0.0021,
            "expireDelta": 360000000,
            "expireExecute": false,
            "useMidPrice": false,
            "maxSlippage": 0.1,
            "concurrentNodes": 2,
            "retries": 1
        }
    }

    async with websockets.connect(uri, additional_headers=headers) as ws:
        await ws.send(json.dumps(msg))

        async def keep_alive():
            while True:
                await ws.ping()
                await asyncio.sleep(30)

        async def listen_for_messages():
            async for message in ws:
                print(message)

        await asyncio.gather(keep_alive(), listen_for_messages())

if __name__ == "__main__":
    asyncio.run(main())