Async client for the Kite Connect WebSocket API
feat: update Order option in TickerMessage
+5
-3
+5
-3
src/models/ticker_message.rs
+5
-3
src/models/ticker_message.rs
···
1
-
use crate::{TextMessage, TickMessage};
1
+
use crate::{Order, TextMessage, TickMessage};
2
2
3
3
use super::text_message::TextMessageType;
4
4
···
12
12
/// Error response
13
13
Error(String),
14
14
/// Order postback
15
-
Order(serde_json::Value),
15
+
OrderPostback(Result<Order, String>),
16
16
/// Messages and alerts from broker
17
17
Message(serde_json::Value),
18
18
/// Websocket closing frame
···
23
23
fn from(value: TextMessage) -> Self {
24
24
let message_type: TextMessageType = value.message_type.into();
25
25
match message_type {
26
-
TextMessageType::Order => Self::Order(value.data),
26
+
TextMessageType::Order => Self::OrderPostback(
27
+
serde_json::from_value(value.data).map_err(|e| e.to_string()),
28
+
),
27
29
TextMessageType::Error => Self::Error(value.data.to_string()),
28
30
TextMessageType::Message => Self::Message(value.data),
29
31
}