deribit-websocket 0.3.1

WebSocket client for Deribit trading platform real-time 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

//! WebSocket response message handling

use crate::model::ws_types::{JsonRpcError, JsonRpcResponse, JsonRpcResult};

/// Response handler for WebSocket messages
#[derive(Debug, Clone)]
pub struct ResponseHandler;

impl ResponseHandler {
    /// Create a new response handler
    pub fn new() -> Self {
        Self
    }

    /// Parse a JSON-RPC response
    pub fn parse_response(&self, data: &str) -> Result<JsonRpcResponse, serde_json::Error> {
        serde_json::from_str(data)
    }

    /// Check if response is successful
    pub fn is_success(&self, response: &JsonRpcResponse) -> bool {
        matches!(response.result, JsonRpcResult::Success { .. })
    }

    /// Extract result from successful response
    pub fn extract_result<'a>(
        &self,
        response: &'a JsonRpcResponse,
    ) -> Option<&'a serde_json::Value> {
        match &response.result {
            JsonRpcResult::Success { result } => Some(result),
            JsonRpcResult::Error { .. } => None,
        }
    }

    /// Extract error from response
    pub fn extract_error<'a>(&self, response: &'a JsonRpcResponse) -> Option<&'a JsonRpcError> {
        match &response.result {
            JsonRpcResult::Success { .. } => None,
            JsonRpcResult::Error { error } => Some(error),
        }
    }
}

impl Default for ResponseHandler {
    fn default() -> Self {
        Self::new()
    }
}