userTwapStatusUpdates

Stream twap status updates for specific user addresses.

Every live data message includes both routing identifiers with the same value:

{"type": "userTwapStatusUpdates", "channel": "userTwapStatusUpdates"}

Other payload fields are omitted above. Existing clients may continue routing on either field.

💧New endpoint - this endpoint is not a part of original Hyperliquid API and is added by us for builder convenience.

Delivers the same events as allTwapStatusUpdates, filtered to the subscribed addresses. Subscribing again merges new addresses into the existing subscription; unsubscribing requires the full current address set.

Subscribe

{ 
    "type": "subscribe",
    "subscription": {
        "type": "userTwapStatusUpdates",
        "addresses": ["0x742d35Cc6634C0532925a3b844Bc9e7595f7F2e2"]
    }
} 

Unsubscribe

{ 
    "type": "unsubscribe",
    "subscription": {
        "type": "userTwapStatusUpdates",
        "addresses": ["0x742d35Cc6634C0532925a3b844Bc9e7595f7F2e2"]
    }
}

Reconnection Note: When reconnecting with a session, replay and live events may overlap. Deduplicate using (time, txIndex) - skip updates where this tuple is at or before your last processed update. See Session Management for details.

userTwapStatusUpdates data format

{
  "type": "userTwapStatusUpdates",
  "channel": "userTwapStatusUpdates",
  "seq": 1,
  "cursor": "500:1704067200000:3",
  "updates": [
    {
      "time": "2025-09-03T10:48:14.285201806", // time of update
      "createdAt": 1756896494285, // time of creation
      "twapId": 12345,
      "user": "0x742d35cc6634c0532925a3b844bc9e7595f7f2e2",
      "coin": "ETH",
      "side": "B",

      "status": "activated", // can be activated, finished, terminated, stopped, waitingForTrigger or error
      "statusMessage": null, // only non null when status is error

      "sz": "100.5",
      "minutes": 60,
      "reduceOnly": false,
      "randomize": true,

      "executedSz": "25.125",
      "executedNtl": "50250.0",
      "txIndex": 3,

      // only present on trigger TWAPs: the TWAP activates when the mark
      // price crosses triggerPx in the direction given by triggerAbove
      "triggerPx": "3500.0",
      "triggerAbove": true,
      "stopPx": "3200.0" // only present when a stop price is attached
    }
  ]
}

Examples

Javascript

const WebSocket = require('ws');

const ws = new WebSocket('wss://api.hydromancer.xyz/ws', {
    headers: { 'Authorization': `Bearer ${process.env.HYDROMANCER_API_KEY}` }
});

ws.on('open', () => {
    ws.send(JSON.stringify({
        method: 'subscribe',
        subscription: {
            type: 'userTwapStatusUpdates',
            addresses: ['0x010461c14e146ac35fe42271bdc1134ee31c703a']
        }
    }));
});

ws.on('message', (data) => {
    const msg = JSON.parse(data);
    if (msg.type === 'userTwapStatusUpdates') {
        for (const update of msg.updates) {
            console.log(`${update.user} ${update.coin} ${update.status}`);
        }
    }
});

Python

import json
import os
import websocket

def on_open(ws):
    ws.send(json.dumps({
        "method": "subscribe",
        "subscription": {
            "type": "userTwapStatusUpdates",
            "addresses": ["0x010461c14e146ac35fe42271bdc1134ee31c703a"]
        }
    }))

def on_message(ws, message):
    msg = json.loads(message)
    if msg.get("type") == "userTwapStatusUpdates":
        for update in msg["updates"]:
            print(f"{update['user']} {update['coin']} {update['status']}")

ws = websocket.WebSocketApp(
    "wss://api.hydromancer.xyz/ws",
    header={"Authorization": f"Bearer {os.environ['HYDROMANCER_API_KEY']}"},
    on_open=on_open,
    on_message=on_message,
)
ws.run_forever()