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

use crate::auth::AuthManager;
use crate::endpoints::base::BaseEndpoint;
use crate::error::WebullResult;
use reqwest::Client;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

/// Watchlist information.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Watchlist {
    /// Watchlist ID
    pub id: String,
    
    /// Watchlist name
    pub name: String,
    
    /// Watchlist symbols
    pub symbols: Vec<String>,
}

/// Request to create a watchlist.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct CreateWatchlistRequest {
    /// Watchlist name
    pub name: String,
    
    /// Watchlist symbols
    pub symbols: Vec<String>,
}

/// Request to modify a watchlist.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ModifyWatchlistRequest {
    /// Watchlist ID
    pub id: String,
    
    /// Watchlist name
    pub name: Option<String>,
    
    /// Watchlist symbols to add
    pub add_symbols: Option<Vec<String>>,
    
    /// Watchlist symbols to remove
    pub remove_symbols: Option<Vec<String>>,
}

/// Endpoints for watchlist operations.
pub struct WatchlistEndpoints {
    /// Base endpoint
    base: BaseEndpoint,
}

impl WatchlistEndpoints {
    /// Create new watchlist endpoints.
    pub fn new(client: Client, base_url: String, auth_manager: Arc<AuthManager>) -> Self {
        Self {
            base: BaseEndpoint::new(client, base_url, auth_manager),
        }
    }
    
    /// Get all watchlists.
    pub async fn get_watchlists(&self) -> WebullResult<Vec<Watchlist>> {
        self.base.get("/api/wlas/watchlist").await
    }
    
    /// Get a watchlist by ID.
    pub async fn get_watchlist(&self, watchlist_id: &str) -> WebullResult<Watchlist> {
        let path = format!("/api/wlas/watchlist/{}", watchlist_id);
        self.base.get(&path).await
    }
    
    /// Create a watchlist.
    pub async fn create_watchlist(&self, request: &CreateWatchlistRequest) -> WebullResult<Watchlist> {
        self.base.post("/api/wlas/watchlist", request).await
    }
    
    /// Modify a watchlist.
    pub async fn modify_watchlist(&self, request: &ModifyWatchlistRequest) -> WebullResult<Watchlist> {
        self.base.post("/api/wlas/watchlist/modify", request).await
    }
    
    /// Delete a watchlist.
    pub async fn delete_watchlist(&self, watchlist_id: &str) -> WebullResult<()> {
        let path = format!("/api/wlas/watchlist/delete/{}", watchlist_id);
        self.base.delete(&path).await
    }
    
    /// Add symbols to a watchlist.
    pub async fn add_symbols(&self, watchlist_id: &str, symbols: &[String]) -> WebullResult<Watchlist> {
        let request = ModifyWatchlistRequest {
            id: watchlist_id.to_string(),
            name: None,
            add_symbols: Some(symbols.to_vec()),
            remove_symbols: None,
        };
        
        self.modify_watchlist(&request).await
    }
    
    /// Remove symbols from a watchlist.
    pub async fn remove_symbols(&self, watchlist_id: &str, symbols: &[String]) -> WebullResult<Watchlist> {
        let request = ModifyWatchlistRequest {
            id: watchlist_id.to_string(),
            name: None,
            add_symbols: None,
            remove_symbols: Some(symbols.to_vec()),
        };
        
        self.modify_watchlist(&request).await
    }
    
    /// Rename a watchlist.
    pub async fn rename_watchlist(&self, watchlist_id: &str, name: &str) -> WebullResult<Watchlist> {
        let request = ModifyWatchlistRequest {
            id: watchlist_id.to_string(),
            name: Some(name.to_string()),
            add_symbols: None,
            remove_symbols: None,
        };
        
        self.modify_watchlist(&request).await
    }
}