add drop context log

examples/rust/subscribe_candlesticks/src/main.rs

@@ -12,11 +12,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         .with_env_filter(EnvFilter::from_default_env())
         .init();
 
-    let config =
-        Arc::new(Config::from_env()?.push_candlestick_mode(PushCandlestickMode::Confirmed));
+    let config = Arc::new(Config::from_env()?);
     let (ctx, mut receiver) = QuoteContext::try_new(config).await?;
     println!("member id: {}", ctx.member_id());
-    ctx.subscribe_candlesticks("600000.SH", Period::FiveMinute)
+    ctx.subscribe_candlesticks("700.HK", Period::OneMinute)
         .await?;
 
     while let Some(event) = receiver.recv().await {

rust/crates/httpclient/src/client.rs

@@ -9,7 +9,6 @@ use serde::Deserialize;
 use crate::{HttpClientConfig, HttpClientError, HttpClientResult, Json, RequestBuilder};
 
 /// LongPort HTTP client
-#[derive(Clone)]
 pub struct HttpClient {
     pub(crate) http_cli: Client,
     pub(crate) config: Arc<HttpClientConfig>,
@@ -54,8 +53,12 @@ impl HttpClient {
 
     /// Create a new request builder
     #[inline]
-    pub fn request(&self, method: Method, path: impl Into<String>) -> RequestBuilder<(), (), ()> {
-        RequestBuilder::new(self.clone(), method, path)
+    pub fn request(
+        &self,
+        method: Method,
+        path: impl Into<String>,
+    ) -> RequestBuilder<'_, (), (), ()> {
+        RequestBuilder::new(self, method, path)
     }
 
     /// Get the socket OTP(One Time Password)

rust/crates/httpclient/src/request.rs

@@ -118,8 +118,8 @@ struct OpenApiResponse {
 }
 
 /// A request builder
-pub struct RequestBuilder<T, Q, R> {
-    client: HttpClient,
+pub struct RequestBuilder<'a, T, Q, R> {
+    client: &'a HttpClient,
     method: Method,
     path: String,
     headers: HeaderMap,
@@ -128,8 +128,8 @@ pub struct RequestBuilder<T, Q, R> {
     mark_resp: PhantomData<R>,
 }
 
-impl RequestBuilder<(), (), ()> {
-    pub(crate) fn new(client: HttpClient, method: Method, path: impl Into<String>) -> Self {
+impl<'a> RequestBuilder<'a, (), (), ()> {
+    pub(crate) fn new(client: &'a HttpClient, method: Method, path: impl Into<String>) -> Self {
         Self {
             client,
             method,
@@ -142,10 +142,10 @@ impl RequestBuilder<(), (), ()> {
     }
 }
 
-impl<T, Q, R> RequestBuilder<T, Q, R> {
+impl<'a, T, Q, R> RequestBuilder<'a, T, Q, R> {
     /// Set the request body
     #[must_use]
-    pub fn body<T2>(self, body: T2) -> RequestBuilder<T2, Q, R>
+    pub fn body<T2>(self, body: T2) -> RequestBuilder<'a, T2, Q, R>
     where
         T2: ToPayload,
     {
@@ -177,7 +177,7 @@ impl<T, Q, R> RequestBuilder<T, Q, R> {
 
     /// Set the query string
     #[must_use]
-    pub fn query_params<Q2>(self, params: Q2) -> RequestBuilder<T, Q2, R>
+    pub fn query_params<Q2>(self, params: Q2) -> RequestBuilder<'a, T, Q2, R>
     where
         Q2: Serialize + Send + Sync,
     {
@@ -194,7 +194,7 @@ impl<T, Q, R> RequestBuilder<T, Q, R> {
 
     /// Set the response body type
     #[must_use]
-    pub fn response<R2>(self) -> RequestBuilder<T, Q, R2>
+    pub fn response<R2>(self) -> RequestBuilder<'a, T, Q, R2>
     where
         R2: FromPayload,
     {
@@ -210,7 +210,7 @@ impl<T, Q, R> RequestBuilder<T, Q, R> {
     }
 }
 
-impl<T, Q, R> RequestBuilder<T, Q, R>
+impl<T, Q, R> RequestBuilder<'_, T, Q, R>
 where
     T: ToPayload,
     Q: Serialize + Send,

rust/crates/wsclient/src/client.rs

@@ -257,7 +257,6 @@ impl WsSession {
 }
 
 /// LongPort Websocket client
-#[derive(Clone)]
 pub struct WsClient {
     command_tx: mpsc::UnboundedSender<Command>,
     rate_limit: Arc<HashMap<u8, RateLimiter>>,

rust/src/error.rs

@@ -61,6 +61,17 @@ impl Error {
         }
     }
 
+    /// Returns the OpenAPI error code
+    pub fn openapi_error_code(&self) -> Option<i64> {
+        match self {
+            Error::HttpClient(HttpClientError::OpenApi { code, .. }) => Some(*code as i64),
+            Error::WsClient(WsClientError::ResponseError { detail, .. }) => {
+                detail.as_ref().map(|detail| detail.code as i64)
+            }
+            _ => None,
+        }
+    }
+
     /// Consumes this error and returns a simple error
     pub fn into_simple_error(self) -> SimpleError {
         match self {

rust/src/quote/cache.rs

@@ -1,7 +1,6 @@
 use std::{
     collections::HashMap,
     hash::Hash,
-    sync::Arc,
     time::{Duration, Instant},
 };
 
@@ -18,9 +17,8 @@ struct Inner<K, V> {
     values: HashMap<K, Item<V>>,
 }
 
-#[derive(Clone)]
 pub(crate) struct CacheWithKey<K, V> {
-    inner: Arc<Mutex<Inner<K, V>>>,
+    inner: Mutex<Inner<K, V>>,
 }
 
 impl<K, V> CacheWithKey<K, V>
@@ -30,10 +28,10 @@ where
 {
     pub(crate) fn new(timeout: Duration) -> Self {
         CacheWithKey {
-            inner: Arc::new(Mutex::new(Inner {
+            inner: Mutex::new(Inner {
                 timeout,
                 values: HashMap::new(),
-            })),
+            }),
         }
     }
 
@@ -61,7 +59,6 @@ where
     }
 }
 
-#[derive(Clone)]
 pub(crate) struct Cache<V> {
     inner: CacheWithKey<(), V>,
 }