Fills

wss://api.rivermarkets.com/v1/ws/fills?subaccount_id=<uuid>

{ "type": "connected" }
{ "type": "fill",    "river_id": 12345, "exchange_trade_id": "0xdef…", /* + full fill fields */ }
{ "type": "error",   "code": "...", "message": "..." }
{ "type": "reconnect" }

{
  "river_id": 12345,
  "river_order_id": "8b1f1a2e-…",
  "client_order_id": null,
  "exchange_order_id": "0xabc…",
  "exchange_trade_id": "0xdef…",
  "exchange_timestamp": "2026-04-29T13:14:18.456Z",
  "price": 0.42,
  "qty": 4,
  "fee": 0.02,
  "buy_flag": true,
  "is_maker": false,
  "counterparty_address": null,
  "counterparty_exchange_order_id": null
}

import asyncio
from rivermarkets import AsyncRiverMarkets

async def run(subaccount_id: str):
    client = AsyncRiverMarkets(key_id="<uuid>", private_key="<base64-priv>")
    async with client.ws.fills(subaccount_id=subaccount_id) as stream:
        async for msg in stream:
            if msg.type == "fill":
                print(msg.exchange_trade_id, msg.qty, "@", msg.price, "fee", msg.fee)

asyncio.run(run("<subaccount-uuid>"))

import asyncio, base64, json, time
from urllib.parse import urlencode, quote
import websockets
from nacl.signing import SigningKey

KEY_ID = "<uuid>"
signing_key = SigningKey(base64.b64decode("<base64-priv>"))


def sign_ws(path: str, extra_params: dict) -> str:
    sorted_q = urlencode(sorted(extra_params.items()), quote_via=quote)
    ts = str(int(time.time()))
    canonical = "\n".join(["WS", path, sorted_q, ts]).encode()
    sig = base64.b64encode(signing_key.sign(canonical).signature).decode()
    return f"wss://api.rivermarkets.com{path}?{urlencode({**extra_params, 'key_id': KEY_ID, 'ts': ts, 'sig': sig})}"


async def run(subaccount_id: str):
    async with websockets.connect(sign_ws("/v1/ws/fills", {"subaccount_id": subaccount_id})) as ws:
        async for raw in ws:
            msg = json.loads(raw)
            if msg["type"] == "fill":
                print(msg["exchange_trade_id"], msg["qty"], "@", msg["price"], "fee", msg["fee"])

asyncio.run(run("<subaccount-uuid>"))