polynode 0.12.0

Rust SDK for the PolyNode API — real-time Polymarket data
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144

use serde::{Deserialize, Serialize};

/// A single price level in the orderbook.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct OrderbookLevel {
    pub price: String,
    pub size: String,
}

/// Full orderbook snapshot for an asset.
#[derive(Debug, Clone, Deserialize)]
pub struct BookSnapshot {
    pub asset_id: String,
    pub market: String,
    #[serde(default)]
    pub event_title: Option<String>,
    #[serde(default)]
    pub question: Option<String>,
    #[serde(default)]
    pub outcome: Option<String>,
    #[serde(default)]
    pub slug: Option<String>,
    pub bids: Vec<OrderbookLevel>,
    pub asks: Vec<OrderbookLevel>,
}

/// Incremental orderbook delta. A level with size "0" means removal.
#[derive(Debug, Clone, Deserialize)]
pub struct BookUpdate {
    pub asset_id: String,
    pub market: String,
    #[serde(default)]
    pub event_title: Option<String>,
    #[serde(default)]
    pub question: Option<String>,
    #[serde(default)]
    pub outcome: Option<String>,
    #[serde(default)]
    pub slug: Option<String>,
    pub bids: Vec<OrderbookLevel>,
    pub asks: Vec<OrderbookLevel>,
}

/// A single asset's price in a price change event.
/// Extended in v0.11.0 to carry PM's full wire payload so clients can maintain
/// tick-accurate local books. `size`, `side`, `best_bid`, `best_ask` are
/// optional for backward compatibility with older server versions.
#[derive(Debug, Clone, Deserialize)]
pub struct PriceChangeAsset {
    pub asset_id: String,
    pub price: String,
    #[serde(default)]
    pub outcome: String,
    /// Absolute size at this level after the change. "0" means the level was removed.
    #[serde(default)]
    pub size: Option<String>,
    /// Side this level belongs to: "BUY" (bids) or "SELL" (asks).
    #[serde(default)]
    pub side: Option<String>,
    /// Best bid on the asset after this change.
    #[serde(default)]
    pub best_bid: Option<String>,
    /// Best ask on the asset after this change.
    #[serde(default)]
    pub best_ask: Option<String>,
}

/// Summary of price movement across assets in a market.
#[derive(Debug, Clone, Deserialize)]
pub struct PriceChange {
    pub market: String,
    #[serde(default)]
    pub event_title: Option<String>,
    #[serde(default)]
    pub question: Option<String>,
    #[serde(default)]
    pub slug: Option<String>,
    pub assets: Vec<PriceChangeAsset>,
}

/// A single executed trade ("last trade price" event).
#[derive(Debug, Clone, Deserialize)]
pub struct BookTrade {
    pub asset_id: String,
    pub market: String,
    pub price: String,
    pub size: String,
    pub side: String,
    pub fee_rate_bps: String,
    pub timestamp: String,
    #[serde(default)]
    pub outcome: Option<String>,
    #[serde(default)]
    pub slug: Option<String>,
}

/// Individual orderbook update, discriminated by `type` field.
#[derive(Debug, Clone, Deserialize)]
#[serde(tag = "type")]
pub enum OrderbookUpdate {
    #[serde(rename = "book_snapshot")]
    Snapshot(BookSnapshot),
    #[serde(rename = "book_update")]
    Update(BookUpdate),
    #[serde(rename = "price_change")]
    PriceChange(PriceChange),
    #[serde(rename = "last_trade_price")]
    LastTradePrice(BookTrade),
}

/// Messages yielded to the user from the orderbook stream.
#[derive(Debug)]
pub enum ObMessage {
    /// An individual orderbook update (snapshot, delta, or price change).
    Update(OrderbookUpdate),
    /// All initial snapshots have been delivered.
    SnapshotsDone { total: u64 },
    /// Subscription acknowledged.
    Subscribed { markets: u64 },
    /// Unsubscribed.
    Unsubscribed,
    /// Error from the server.
    Error { error: String, message: String },
}

// ── Wire message types for deserialization ──

#[derive(Debug, Deserialize)]
pub(crate) struct RawObMessage {
    #[serde(rename = "type", default)]
    pub msg_type: Option<String>,
    #[serde(default)]
    pub error: Option<String>,
    #[serde(default)]
    pub message: Option<String>,
    #[serde(default)]
    pub markets: Option<u64>,
    #[serde(default)]
    pub total: Option<u64>,
    #[serde(default)]
    pub snapshots: Option<Vec<serde_json::Value>>,
    #[serde(default)]
    pub updates: Option<Vec<serde_json::Value>>,
}