webull-rs 0.1.0

A Rust client for the Webull trading API
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

use serde::{Deserialize, Serialize};

/// Common API response structure.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ApiResponse<T> {
    /// Success flag
    pub success: bool,
    
    /// Response data
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data: Option<T>,
    
    /// Error code
    #[serde(skip_serializing_if = "Option::is_none")]
    pub code: Option<String>,
    
    /// Error message
    #[serde(skip_serializing_if = "Option::is_none")]
    pub message: Option<String>,
}

impl<T> ApiResponse<T> {
    /// Create a new successful response.
    pub fn success(data: T) -> Self {
        Self {
            success: true,
            data: Some(data),
            code: None,
            message: None,
        }
    }
    
    /// Create a new error response.
    pub fn error(code: impl Into<String>, message: impl Into<String>) -> Self {
        Self {
            success: false,
            data: None,
            code: Some(code.into()),
            message: Some(message.into()),
        }
    }
    
    /// Check if the response is successful.
    pub fn is_success(&self) -> bool {
        self.success
    }
    
    /// Get the data from the response.
    pub fn get_data(&self) -> Option<&T> {
        self.data.as_ref()
    }
}

/// Pagination information.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Pagination {
    /// Current page
    pub page: u32,
    
    /// Page size
    pub page_size: u32,
    
    /// Total number of items
    pub total: u32,
    
    /// Total number of pages
    pub total_pages: u32,
}

/// Paginated API response.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PaginatedResponse<T> {
    /// Success flag
    pub success: bool,
    
    /// Response data
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data: Option<Vec<T>>,
    
    /// Pagination information
    #[serde(skip_serializing_if = "Option::is_none")]
    pub pagination: Option<Pagination>,
    
    /// Error code
    #[serde(skip_serializing_if = "Option::is_none")]
    pub code: Option<String>,
    
    /// Error message
    #[serde(skip_serializing_if = "Option::is_none")]
    pub message: Option<String>,
}

impl<T> PaginatedResponse<T> {
    /// Create a new successful paginated response.
    pub fn success(data: Vec<T>, pagination: Pagination) -> Self {
        Self {
            success: true,
            data: Some(data),
            pagination: Some(pagination),
            code: None,
            message: None,
        }
    }
    
    /// Create a new error response.
    pub fn error(code: impl Into<String>, message: impl Into<String>) -> Self {
        Self {
            success: false,
            data: None,
            pagination: None,
            code: Some(code.into()),
            message: Some(message.into()),
        }
    }
    
    /// Check if the response is successful.
    pub fn is_success(&self) -> bool {
        self.success
    }
    
    /// Get the data from the response.
    pub fn get_data(&self) -> Option<&Vec<T>> {
        self.data.as_ref()
    }
    
    /// Get the pagination information.
    pub fn get_pagination(&self) -> Option<&Pagination> {
        self.pagination.as_ref()
    }
}