实时推送

use std::sync::Arc;
use tigeropen::config::ClientConfig;
use tigeropen::push::*;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = ClientConfig::builder().build()?;
    let account = config.account.clone();
    let pc = Arc::new(PushClient::new(config, None));

    // 一次性注册所有需要的回调
    pc.set_callbacks(Callbacks {
        on_connect: Some(Arc::new(|| println!("[推送] 连接成功"))),
        on_disconnect: Some(Arc::new(|| println!("[推送] 连接断开"))),
        on_error: Some(Arc::new(|msg| eprintln!("[推送] 错误: {}", msg))),
        on_kickout: Some(Arc::new(|msg| eprintln!("[推送] 被踢出: {}", msg))),

        on_quote: Some(Arc::new(|data| {
            println!("[行情] {} price={:?} volume={:?}",
                data.symbol, data.latest_price, data.volume);
        })),
        on_tick: Some(Arc::new(|data| {
            println!("[逐笔] {} sn={} prices={} volumes={}",
                data.symbol, data.sn, data.price.len(), data.volume.len());
        })),
        on_depth: Some(Arc::new(|data| {
            let ask_levels = data.ask.as_ref().map_or(0, |a| a.price.len());
            let bid_levels = data.bid.as_ref().map_or(0, |b| b.price.len());
            println!("[深度] {} ask_levels={} bid_levels={}",
                data.symbol, ask_levels, bid_levels);
        })),

        on_order: Some(Arc::new(|data| {
            println!("[订单] id={} {} 状态: {}", data.id, data.symbol, data.status);
        })),
        on_position: Some(Arc::new(|data| {
            println!("[持仓] {} qty={}", data.symbol, data.position);
        })),
        on_asset: Some(Arc::new(|data| {
            println!("[资产] {} netLiquidation={}", data.account, data.net_liquidation);
        })),
        on_transaction: Some(Arc::new(|data| {
            println!("[成交] id={} {} price={}", data.id, data.symbol, data.filled_price);
        })),
        ..Default::default()
    });

    // 建立 TCP+TLS 连接（独立的自由函数，需要 &Arc<PushClient>）
    connect(&pc).await.map_err(|e| format!("连接失败: {}", e))?;

    // 订阅行情（同步调用，参数均为 Option）
    pc.subscribe(&SubjectType::Quote, Some("AAPL,TSLA"), None, None);
    pc.subscribe(&SubjectType::Tick, Some("AAPL"), None, None);
    pc.subscribe(&SubjectType::Depth, Some("AAPL"), None, None);

    // 订阅账户推送（account 通过第三个参数传入）
    pc.subscribe(&SubjectType::Asset, None, Some(&account), None);
    pc.subscribe(&SubjectType::Position, None, Some(&account), None);
    pc.subscribe(&SubjectType::Order, None, Some(&account), None);
    pc.subscribe(&SubjectType::Transaction, None, Some(&account), None);

    println!("已启动推送，按 Ctrl+C 退出...");
    tokio::signal::ctrl_c().await?;
    pc.disconnect();
    Ok(())
}

use std::sync::Arc;
use tigeropen::config::ClientConfig;
use tigeropen::push::{PushClient, PushClientOptions};

let config = ClientConfig::builder().build()?;
let options = PushClientOptions {
    heartbeat_interval_secs: Some(15),
    reconnect_interval_secs: Some(3),
    auto_reconnect: Some(true),
    ..Default::default()
};
let pc = Arc::new(PushClient::new(config, Some(options)));

use std::sync::Arc;
use tigeropen::push::Callbacks;

pc.set_callbacks(Callbacks {
    on_quote: Some(Arc::new(|data| {
        println!("{} price={:?}", data.symbol, data.latest_price);
    })),
    on_order: Some(Arc::new(|data| {
        println!("订单 id={} 状态: {}", data.id, data.status);
    })),
    ..Default::default()
});

pub async fn connect(client: &Arc<PushClient>) -> Result<(), String>
pub fn disconnect(&self)

use std::sync::Arc;
use tigeropen::push::{PushClient, connect};

let pc = Arc::new(PushClient::new(config, None));
connect(&pc).await.map_err(|e| format!("连接失败: {}", e))?;

// 主动断开
pc.disconnect();

use tigeropen::push::ConnectionState;

if pc.state() == ConnectionState::Connected {
    pc.subscribe(&SubjectType::Quote, Some("AAPL"), None, None);
}

pub fn subscribe(
    &self,
    subject: &SubjectType,
    symbols: Option<&str>,
    account: Option<&str>,
    market: Option<&str>,
) -> bool

use tigeropen::push::SubjectType;

// 订阅行情（逗号分隔）
pc.subscribe(&SubjectType::Quote, Some("AAPL,TSLA,GOOG"), None, None);
pc.subscribe(&SubjectType::Tick, Some("AAPL"), None, None);
pc.subscribe(&SubjectType::Depth, Some("AAPL"), None, None);
pc.subscribe(&SubjectType::Kline, Some("AAPL"), None, None);

// 期权订阅使用 OCC identifier（注意双空格）
pc.subscribe(&SubjectType::Option, Some("AAPL  250117C00150000"), None, None);

// 期货订阅
pc.subscribe(&SubjectType::Future, Some("CL2506"), None, None);

// 榜单订阅使用 market
pc.subscribe(&SubjectType::StockTop, None, None, Some("US"));

// 账户推送：symbols=None，account 传入账户号
pc.subscribe(&SubjectType::Asset, None, Some(&account), None);
pc.subscribe(&SubjectType::Position, None, Some(&account), None);
pc.subscribe(&SubjectType::Order, None, Some(&account), None);
pc.subscribe(&SubjectType::Transaction, None, Some(&account), None);

pub fn unsubscribe(
    &self,
    subject: &SubjectType,
    symbols: Option<&str>,
    account: Option<&str>,
    market: Option<&str>,
) -> bool

// 退订 TSLA 的行情
pc.unsubscribe(&SubjectType::Quote, Some("TSLA"), None, None);

// 退订账户资产推送
pc.unsubscribe(&SubjectType::Asset, None, Some(&account), None);

pub fn get_subscriptions(&self) -> HashMap<SubjectType, Vec<String>>
pub fn get_account_subscriptions(&self) -> Vec<SubjectType>

let quote_subs = pc.get_subscriptions();
let acct_subs = pc.get_account_subscriptions();
println!("行情订阅: {:?}", quote_subs);
println!("账户订阅: {:?}", acct_subs);

pub fn subscribe_cc(&self, symbols: &str) -> bool
pub fn unsubscribe_cc(&self, symbols: &str) -> bool

// 订阅加密货币行情
pc.subscribe_cc("BTC,ETH");

// 退订
pc.unsubscribe_cc("BTC");

pub fn subscribe_market(&self, market: &str) -> bool
pub fn unsubscribe_market(&self, market: &str) -> bool

// 订阅美股市场状态
pc.subscribe_market("US");

// 退订
pc.unsubscribe_market("US");