feat!: v0.5.0 — multi-symbol quote APIs, from_config constructors, public call_* methods

Breaking changes:
- QuoteClient/TradeClient now accept ClientConfig directly via from_config();
  lifetime parameter <'a> removed, HttpClient is now owned (not borrowed)
- call_into / call_optional / call_into_items / call_into_versioned /
  call_into_list_or_object / call_optional_versioned are now pub
- get_kline / get_option_expiration accept &[&str] instead of &str
- get_option_chain accepts &[(&str, &str)] (symbol+expiry pairs) instead of two &str
- get_option_kline accepts &[&str] identifiers instead of single &str
- BarsByPageRequest.symbol renamed to symbols: Option<Vec<String>>

Author: hotea

CHANGELOG.md

@@ -5,6 +5,19 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.5.0] - 2026-07-07
+
+### Breaking Changes
+
+- **`QuoteClient` / `TradeClient` 构造方式变更**：不再需要用户手动创建 `HttpClient`；新增 `from_config(config: ClientConfig)` 构造器，直接接受 `ClientConfig`，内部自动选择 trade/quote server。旧的 `new(http_client)` / `with_secret_key(http_client, ...)` 构造器继续可用，但参数从 `&HttpClient` 改为拥有所有权的 `HttpClient`（移除了 lifetime 参数 `<'a>`）。
+- **`call_*` 系列方法改为 `pub`**：`call_into`、`call_into_versioned`、`call_into_items`、`call_into_list_or_object`、`call_optional`、`call_optional_versioned` 现在均为 `pub`，可直接用于自定义请求。
+- **多 symbol 支持（行情接口签名变更）**：下列接口参数由单 symbol 改为 slice。调用方需更新：
+  - `get_kline(symbol: &str, ...)` → `get_kline(symbols: &[&str], ...)`
+  - `get_option_expiration(symbol: &str)` → `get_option_expiration(symbols: &[&str])`
+  - `get_option_chain(symbol: &str, expiry: &str)` → `get_option_chain(items: &[(&str, &str)])`（每项为 `(symbol, expiry)` 对）
+  - `get_option_kline(identifier: &str, period: &str)` → `get_option_kline(identifiers: &[&str], period: &str)`
+  - `BarsByPageRequest.symbol: Option<String>` → `symbols: Option<Vec<String>>`
+
 ## [0.4.4] - 2026-07-03
 
 ### Fixed

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tigeropen"
-version = "0.4.4"
+version = "0.5.0"
 edition = "2021"
 rust-version = "1.70"
 description = "老虎证券 OpenAPI Rust SDK"

examples/quote_example.rs

@@ -9,11 +9,10 @@
 //!
 //! Run: `TIGER_CONFIG_PATH=~/.tigeropen/tiger_openapi_config.properties cargo run --example quote_example`
 
-use tigeropen::client::http_client::HttpClient;
 use tigeropen::config::ClientConfig;
 use tigeropen::model::quote::{
-    CorporateActionRequest, FinancialDailyRequest, FinancialReportRequest, FutureKlineRequest,
-    MarketScannerRequest,
+    Brief, CorporateActionRequest, FinancialDailyRequest, FinancialReportRequest, FutureKlineRequest,
+    MarketScannerRequest, MarketState,
 };
 use tigeropen::model::quote_requests::{
     AllFutureContractsRequest, BarsRequest, BriefRequest, DepthQuoteRequest,
@@ -96,8 +95,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     };
     println!("tiger_id={} account={}\n", config.tiger_id, config.account);
 
-    let http = HttpClient::with_quote_server(config);
-    let qc = QuoteClient::new(&http);
+    let qc = QuoteClient::from_config(config);
 
     let mut results: Vec<RunResult> = Vec::new();
 
@@ -133,7 +131,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         Err(e) => fail(&mut results, "GetBrief", e),
     }
 
-    match qc.get_kline("AAPL", "day").await {
+    match qc.get_kline(&["AAPL"], "day").await {
         Ok(klines) if !klines.is_empty() => ok(
             &mut results,
             "GetKline(AAPL day)",
@@ -346,7 +344,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let mut expiry_date = String::new();
     let mut opt_identifier = String::new();
 
-    match qc.get_option_expiration("AAPL").await {
+    match qc.get_option_expiration(&["AAPL"]).await {
         Ok(exps) if !exps.is_empty() && !exps[0].dates.is_empty() => {
             ok(
                 &mut results,
@@ -365,7 +363,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         skip(&mut results, "GetOptionBrief", "no expiry available");
         skip(&mut results, "GetOptionKline", "no expiry available");
     } else {
-        match qc.get_option_chain("AAPL", &expiry_date).await {
+        match qc.get_option_chain(&[("AAPL", &expiry_date)]).await {
             Ok(chain) if !chain.is_empty() && !chain[0].items.is_empty() => {
                 ok(
                     &mut results,
@@ -401,7 +399,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 Err(e) => fail(&mut results, "GetOptionBrief", e),
             }
 
-            match qc.get_option_kline(&opt_identifier, "day").await {
+            match qc.get_option_kline(&[opt_identifier.as_str()], "day").await {
                 Ok(ks) if !ks.is_empty() => ok(
                     &mut results,
                     "GetOptionKline",
@@ -852,6 +850,74 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         Err(e) => fail(&mut results, "GetQuoteOvernight(AAPL)", e),
     }
 
+    // ── low-level call_* API ──────────────────────────────────────────────
+    println!("\n=== Low-level call_* API ===");
+
+    // call_into: raw method name + params, deserializes data directly into T
+    match qc
+        .call_into::<Vec<MarketState>, _>("market_state", serde_json::json!({"market": "US"}))
+        .await
+    {
+        Ok(states) if !states.is_empty() => ok(
+            &mut results,
+            "call_into(market_state)",
+            format!("market={} status={}", states[0].market, states[0].market_status),
+        ),
+        Ok(_) => ok(&mut results, "call_into(market_state)", "(empty)"),
+        Err(e) => fail(&mut results, "call_into(market_state)", e),
+    }
+
+    // call_into_versioned: same as call_into but with explicit API version
+    match qc
+        .call_into_versioned::<Vec<MarketState>, _>(
+            "market_state",
+            serde_json::json!({"market": "US"}),
+            Some("2.0"),
+        )
+        .await
+    {
+        Ok(states) => ok(
+            &mut results,
+            "call_into_versioned(market_state, v2.0)",
+            format!("count={}", states.len()),
+        ),
+        Err(e) => fail(&mut results, "call_into_versioned(market_state, v2.0)", e),
+    }
+
+    // call_into_items: unwraps {"items":[...]} envelope
+    match qc
+        .call_into_items::<Brief, _>(
+            "brief",
+            serde_json::json!({"symbols": ["AAPL"], "level": "basic"}),
+        )
+        .await
+    {
+        Ok(briefs) if !briefs.is_empty() => ok(
+            &mut results,
+            "call_into_items(brief)",
+            format!("symbol={} price={:?}", briefs[0].symbol, briefs[0].latest_price),
+        ),
+        Ok(_) => ok(&mut results, "call_into_items(brief)", "(empty)"),
+        Err(e) => fail(&mut results, "call_into_items(brief)", e),
+    }
+
+    // call_optional: returns None when data is absent
+    match qc
+        .call_optional::<Brief, _>(
+            "brief",
+            serde_json::json!({"symbols": ["AAPL"], "level": "basic"}),
+        )
+        .await
+    {
+        Ok(Some(b)) => ok(
+            &mut results,
+            "call_optional(brief)",
+            format!("symbol={}", b.symbol),
+        ),
+        Ok(None) => ok(&mut results, "call_optional(brief)", "(no data)"),
+        Err(e) => fail(&mut results, "call_optional(brief)", e),
+    }
+
     print_summary(&results);
     Ok(())
 }

examples/trade_example.rs

@@ -14,7 +14,6 @@
 
 use std::time::{SystemTime, UNIX_EPOCH};
 
-use tigeropen::client::http_client::HttpClient;
 use tigeropen::config::ClientConfig;
 use tigeropen::model::order::limit_order;
 use tigeropen::model::trade_requests::{
@@ -95,11 +94,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     println!("tiger_id={} account={}\n", config.tiger_id, config.account);
 
     let account = config.account.clone();
-    let http = HttpClient::new(config.clone());
-    let tc = match &config.secret_key {
-        Some(sk) => TradeClient::with_secret_key(&http, &account, sk),
-        None => TradeClient::new(&http, &account),
-    };
+    let tc = TradeClient::from_config(config);
 
     let mut results: Vec<RunResult> = Vec::new();
 
@@ -517,6 +512,43 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         skip(&mut results, "CheckOptionExercise", "no exercisable positions");
     }
 
+    // ── low-level call_* API ──────────────────────────────────────────────
+    println!("\n=== Low-level call_* API ===");
+
+    // call_into_items: raw method name + arbitrary JSON params, returns Vec<T>
+    match tc
+        .call_into_items::<tigeropen::model::contract::Contract, _>(
+            "contract",
+            serde_json::json!({"account": account, "symbol": "AAPL", "sec_type": "STK"}),
+        )
+        .await
+    {
+        Ok(cs) if !cs.is_empty() => ok(
+            &mut results,
+            "call_into_items(contract)",
+            format!("symbol={} secType={}", cs[0].symbol, cs[0].sec_type),
+        ),
+        Ok(_) => ok(&mut results, "call_into_items(contract)", "(empty)"),
+        Err(e) => fail(&mut results, "call_into_items(contract)", e),
+    }
+
+    // call_optional: returns None when data is absent, Some(T) otherwise
+    match tc
+        .call_optional::<tigeropen::model::trade::PreviewResult, _>(
+            "preview_order",
+            tigeropen::model::order::limit_order(&account, "AAPL", "STK", "BUY", 1, 1.00),
+        )
+        .await
+    {
+        Ok(Some(r)) => ok(
+            &mut results,
+            "call_optional(preview_order)",
+            format!("isPass={} commission={}", r.is_pass, r.commission),
+        ),
+        Ok(None) => ok(&mut results, "call_optional(preview_order)", "(no data)"),
+        Err(e) => fail(&mut results, "call_optional(preview_order)", e),
+    }
+
     print_summary(&results);
     Ok(())
 }

src/model/quote_requests.rs

@@ -115,7 +115,7 @@ pub struct BarsRequest {
 #[derive(Debug, Clone, Serialize, Default)]
 pub struct BarsByPageRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
-    pub symbol: Option<String>,
+    pub symbols: Option<Vec<String>>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub period: Option<String>,
     #[serde(skip_serializing_if = "Option::is_none")]