# Account streams Real-time WebSocket stream for account-related updates including balances, orders, and points. ## Connection ``` wss://api.deltadefi.io/accounts/stream?api_key= ``` **Query Parameters** | Name | Type | Required | Description | | -------- | ------ | -------- | ------------ | | api\_key | string | Yes | Your API key | *** ## Event Types This WebSocket stream provides the following event types: | Event Type | Sub Type | Description | | ---------- | ------------- | ------------------------------------------------------------------- | | Account | `balance` | Account balance updates when deposits, withdrawals, or trades occur | | Account | `order_info` | Real-time order status updates (new orders, fills, cancellations) | | Account | `dlta_points` | Points/rewards updates when you earn DLTA points | *** ## Event Formats {% tabs %} {% tab title="order\_info" %} Real-time order updates. Sent whenever an order status changes (created, partially filled, fully filled, cancelled). ```json { "type": "Account", "sub_type": "order_info", "order": { "id": "550e8400-e29b-41d4-a716-446655440000", "account_id": "550e8400-e29b-41d4-a716-446655440001", "status": "open", "symbol": "ADAUSDM", "base_qty": "100.00", "quote_qty": "93.00", "side": "buy", "price": "0.93", "type": "limit", "locked_base_qty": "100.00", "locked_quote_qty": "93.00", "executed_base_qty": "0", "executed_quote_qty": "0", "ob_open_order_base_qty": "100.00", "commission_unit": "lovelace", "commission": "0", "commission_rate_bp": 10, "executed_price": "0", "created_at": "2024-01-01T00:00:00Z", "updated_at": "2024-01-01T00:00:00Z", "order_execution_records": [] } } ``` **Order Status Values:** * `building` - Order is being built * `processing` - Order is being processed * `open` - Order is active on the order book * `closed` - Order is fully filled * `failed` - Order failed * `cancelled` - Order was cancelled {% endtab %} {% tab title="dlta\_points" %} Points updates when you earn DLTA rewards from trading activity. ```json { "type": "Account", "sub_type": "dlta_points", "dlta_points": { "delta": "150", "new_total": "15150", "season_points": "5150", "source_type": "trade", "source_ref": "550e8400-e29b-41d4-a716-446655440000", "league": "gold" } } ``` **Fields:** | Field | Type | Description | | -------------- | ------ | ---------------------------------------------------------------------- | | delta | string | Points earned in this update | | new\_total | string | New total points balance | | season\_points | string | Points earned this season | | source\_type | string | Source of points: `trade`, `referral`, `bonus` | | source\_ref | string | Reference ID (e.g., order ID for trades) | | league | string | Current league tier: `bronze`, `silver`, `gold`, `platinum`, `diamond` | | {% endtab %} | | | {% tab title="balance" %} Account balance updates when deposits, withdrawals, or trades occur. ```json { "type": "Account", "sub_type": "balance", "balance": [ { "asset": "usdm", "asset_unit": "5066154a102ee037390c5236f78db23239b49c5748d3d349f3ccf04b55534458", "free": 1153.006812, "locked": 0 }, { "asset": "ada", "asset_unit": "", "free": 1383.52097, "locked": 0 } ] } ``` **Fields:** | Field | Type | Description | | ------------- | ------ | ----------------------------------- | | asset | string | Asset symbol (e.g., `ada`, `usdm`) | | asset\_unit | string | On-chain asset unit (empty for ADA) | | free | number | Available balance for trading | | locked | number | Balance locked in open orders | | {% endtab %} | | | | {% endtabs %} | | | *** ## Connection Example {% tabs %} {% tab title="JavaScript" %} ```javascript const WebSocket = require('ws'); const ws = new WebSocket('wss://api.deltadefi.io/accounts/stream?api_key='); ws.on('open', function open() { console.log('Connected to account stream'); }); ws.on('message', function message(data) { const event = JSON.parse(data); switch (event.sub_type) { case 'order_info': console.log('Order update:', event.order); break; case 'dlta_points': console.log('Points earned:', event.dlta_points.delta); break; case 'balance': console.log('Balance update:', event.balance); break; default: console.log('Event:', event); } }); ws.on('close', function close() { console.log('Disconnected from account stream'); }); ws.on('error', function error(err) { console.error('WebSocket error:', err); }); ``` {% endtab %} {% tab title="Python" %} ```python import websocket import json def on_message(ws, message): event = json.loads(message) if event.get('sub_type') == 'order_info': print(f"Order update: {event['order']}") elif event.get('sub_type') == 'dlta_points': print(f"Points earned: {event['dlta_points']['delta']}") elif event.get('sub_type') == 'balance': print(f"Balance update: {event['balance']}") else: print(f"Event: {event}") def on_error(ws, error): print(f"Error: {error}") def on_close(ws, close_status_code, close_msg): print("Connection closed") def on_open(ws): print("Connected to account stream") ws = websocket.WebSocketApp( "wss://api.deltadefi.io/accounts/stream?api_key=", on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close ) ws.run_forever() ``` {% endtab %} {% tab title="Go" %} ```go package main import ( "encoding/json" "fmt" "log" "github.com/gorilla/websocket" ) type Event struct { Type string `json:"type"` SubType string `json:"sub_type"` Order json.RawMessage `json:"order,omitempty"` DltaPoints json.RawMessage `json:"dlta_points,omitempty"` Balance json.RawMessage `json:"balance,omitempty"` } func main() { url := "wss://api.deltadefi.io/accounts/stream?api_key=" c, _, err := websocket.DefaultDialer.Dial(url, nil) if err != nil { log.Fatal("dial:", err) } defer c.Close() fmt.Println("Connected to account stream") for { _, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) return } var event Event json.Unmarshal(message, &event) switch event.SubType { case "order_info": fmt.Printf("Order update: %s\n", event.Order) case "dlta_points": fmt.Printf("Points update: %s\n", event.DltaPoints) case "balance": fmt.Printf("Balance update: %s\n", event.Balance) default: fmt.Printf("Event: %s\n", message) } } } ``` {% endtab %} {% endtabs %} *** ## Related * [Market Price Streams](/start-trading/developers/websocket-endpoints/market-price-streams.md) * [Market Depth Streams](/start-trading/developers/websocket-endpoints/market-depth-streams.md) * [Recent Trades](/start-trading/developers/websocket-endpoints/recent-trades.md) --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://docs.deltadefi.io/start-trading/developers/websocket-endpoints/account-streams.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.