futu_rest/routes/qot/

qot_3401_plus.rs

//! REST raw proto-json routes for public QOT 3401+ APIs.
//!
//! These endpoints intentionally expose generated public C2S JSON directly.
//! The daemon Gateway handlers do the C++-aligned public→backend projection.

use axum::extract::{Json, State};
use prost::Message;
use serde::Serialize;
use serde::de::DeserializeOwned;
use serde_json::Value;

use crate::adapter::{self, RestState};

use super::RawApiResult;

async fn raw_qot_request<Req, Rsp>(state: &RestState, proto_id: u32, body: Value) -> RawApiResult
where
    Req: Message + Default + DeserializeOwned,
    Rsp: Message + Default + Serialize,
{
    adapter::proto_request_raw::<Req, Rsp>(state, proto_id, Some(body)).await
}

macro_rules! qot_raw_rest_endpoint {
    ($fn_name:ident, $proto_const:ident, $module:ident) => {
        pub async fn $fn_name(
            State(state): State<RestState>,
            Json(body): Json<Value>,
        ) -> RawApiResult {
            raw_qot_request::<futu_proto::$module::Request, futu_proto::$module::Response>(
                &state,
                futu_core::proto_id::$proto_const,
                body,
            )
            .await
        }
    };
}

qot_raw_rest_endpoint!(
    get_earnings_calendar,
    QOT_GET_EARNINGS_CALENDAR,
    qot_get_earnings_calendar
);
qot_raw_rest_endpoint!(
    get_macro_indicator_list,
    QOT_GET_MACRO_INDICATOR_LIST,
    qot_get_macro_indicator_list
);
qot_raw_rest_endpoint!(
    security_trading_sessions,
    QOT_GET_SECURITY_TRADING_SESSIONS,
    qot_get_security_trading_sessions
);
qot_raw_rest_endpoint!(
    market_trading_sessions,
    QOT_GET_MARKET_TRADING_SESSIONS,
    qot_get_market_trading_sessions
);
qot_raw_rest_endpoint!(kline_pattern, QOT_GET_KLINE_PATTERN, qot_get_kline_pattern);
qot_raw_rest_endpoint!(
    kline_pattern_statistics,
    QOT_GET_KLINE_PATTERN_STATISTICS,
    qot_get_kline_pattern_statistics
);
qot_raw_rest_endpoint!(
    kline_pattern_stocks,
    QOT_GET_KLINE_PATTERN_STOCKS,
    qot_get_kline_pattern_stocks
);
qot_raw_rest_endpoint!(
    kline_pattern_performance,
    QOT_GET_KLINE_PATTERN_PERFORMANCE,
    qot_get_kline_pattern_performance
);
qot_raw_rest_endpoint!(
    kline_pattern_catalog,
    QOT_GET_KLINE_PATTERN_CATALOG,
    qot_get_kline_pattern_catalog
);
qot_raw_rest_endpoint!(
    stock_note_labels,
    QOT_GET_STOCK_NOTE_LABELS,
    qot_get_stock_note_labels
);
qot_raw_rest_endpoint!(stock_notes, QOT_GET_STOCK_NOTES, qot_get_stock_notes);
qot_raw_rest_endpoint!(set_stock_note, QOT_SET_STOCK_NOTE, qot_set_stock_note);
pub async fn hot_news(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<futu_proto::qot_get_hot_news::Request, futu_proto::qot_get_hot_news::Response>(
        &state,
        futu_core::proto_id::QOT_GET_HOT_NEWS,
        body,
    )
    .await
}

pub async fn latest_news(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_latest_news::Request,
        futu_proto::qot_get_latest_news::Response,
    >(&state, futu_core::proto_id::QOT_GET_LATEST_NEWS, body)
    .await
}

pub async fn watchlist_news(
    State(state): State<RestState>,
    Json(body): Json<Value>,
) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_watchlist_news::Request,
        futu_proto::qot_get_watchlist_news::Response,
    >(&state, futu_core::proto_id::QOT_GET_WATCHLIST_NEWS, body)
    .await
}

pub async fn watchlist_announcement(
    State(state): State<RestState>,
    Json(body): Json<Value>,
) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_watchlist_announcement::Request,
        futu_proto::qot_get_watchlist_announcement::Response,
    >(
        &state,
        futu_core::proto_id::QOT_GET_WATCHLIST_ANNOUNCEMENT,
        body,
    )
    .await
}

pub async fn watchlist_rating(
    State(state): State<RestState>,
    Json(body): Json<Value>,
) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_watchlist_rating::Request,
        futu_proto::qot_get_watchlist_rating::Response,
    >(&state, futu_core::proto_id::QOT_GET_WATCHLIST_RATING, body)
    .await
}

pub async fn stock_news(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_stock_news::Request,
        futu_proto::qot_get_stock_news::Response,
    >(&state, futu_core::proto_id::QOT_GET_STOCK_NEWS, body)
    .await
}

pub async fn etf_screen(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_etf_screen::Request,
        futu_proto::qot_get_etf_screen::Response,
    >(&state, futu_core::proto_id::QOT_ETF_SCREEN, body)
    .await
}

pub async fn fund_screen(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_fund_screen::Request,
        futu_proto::qot_get_fund_screen::Response,
    >(&state, futu_core::proto_id::QOT_FUND_SCREEN, body)
    .await
}

pub async fn future_screen(
    State(state): State<RestState>,
    Json(body): Json<Value>,
) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_future_screen::Request,
        futu_proto::qot_get_future_screen::Response,
    >(&state, futu_core::proto_id::QOT_FUTURE_SCREEN, body)
    .await
}

pub async fn bond_screen(State(state): State<RestState>, Json(body): Json<Value>) -> RawApiResult {
    raw_qot_request::<
        futu_proto::qot_get_bond_screen::Request,
        futu_proto::qot_get_bond_screen::Response,
    >(&state, futu_core::proto_id::QOT_BOND_SCREEN, body)
    .await
}
qot_raw_rest_endpoint!(
    get_macro_indicator_history,
    QOT_GET_MACRO_INDICATOR_HISTORY,
    qot_get_macro_indicator_history
);
qot_raw_rest_endpoint!(
    get_fed_watch_target_rate,
    QOT_GET_FED_WATCH_TARGET_RATE,
    qot_get_fed_watch_target_rate
);
qot_raw_rest_endpoint!(
    get_fed_watch_dot_plot,
    QOT_GET_FED_WATCH_DOT_PLOT,
    qot_get_fed_watch_dot_plot
);
qot_raw_rest_endpoint!(
    get_earnings_beat_rank,
    QOT_GET_EARNINGS_BEAT_RANK,
    qot_get_earnings_beat_rank
);
qot_raw_rest_endpoint!(
    get_dividend_rank,
    QOT_GET_DIVIDEND_RANK,
    qot_get_dividend_rank
);
qot_raw_rest_endpoint!(
    get_dividend_calendar,
    QOT_GET_DIVIDEND_CALENDAR,
    qot_get_dividend_calendar
);
qot_raw_rest_endpoint!(
    get_economic_calendar,
    QOT_GET_ECONOMIC_CALENDAR,
    qot_get_economic_calendar
);
qot_raw_rest_endpoint!(
    get_us_pre_market_rank,
    QOT_GET_US_PRE_MARKET_RANK,
    qot_get_us_pre_market_rank
);
qot_raw_rest_endpoint!(
    get_us_after_hours_rank,
    QOT_GET_US_AFTER_HOURS_RANK,
    qot_get_us_after_hours_rank
);
qot_raw_rest_endpoint!(
    get_us_overnight_rank,
    QOT_GET_US_OVERNIGHT_RANK,
    qot_get_us_overnight_rank
);
qot_raw_rest_endpoint!(
    get_top_movers_rank,
    QOT_GET_TOP_MOVERS_RANK,
    qot_get_top_movers_rank
);
qot_raw_rest_endpoint!(get_hot_list, QOT_GET_HOT_LIST, qot_get_hot_list);
qot_raw_rest_endpoint!(
    get_short_selling_rank,
    QOT_GET_SHORT_SELLING_RANK,
    qot_get_short_selling_rank
);
qot_raw_rest_endpoint!(
    get_period_change_rank,
    QOT_GET_PERIOD_CHANGE_RANK,
    qot_get_period_change_rank
);
qot_raw_rest_endpoint!(
    get_high_dividend_soe_rank,
    QOT_GET_HIGH_DIVIDEND_SOE_RANK,
    qot_get_high_dividend_soe_rank
);
qot_raw_rest_endpoint!(
    get_institution_list,
    QOT_GET_INSTITUTION_LIST,
    qot_get_institution_list
);
qot_raw_rest_endpoint!(
    get_institution_profile,
    QOT_GET_INSTITUTION_PROFILE,
    qot_get_institution_profile
);
qot_raw_rest_endpoint!(
    get_institution_distribution,
    QOT_GET_INSTITUTION_DISTRIBUTION,
    qot_get_institution_distribution
);
qot_raw_rest_endpoint!(
    get_institution_holding_change,
    QOT_GET_INSTITUTION_HOLDING_CHANGE,
    qot_get_institution_holding_change
);
qot_raw_rest_endpoint!(
    get_institution_holding_list,
    QOT_GET_INSTITUTION_HOLDING_LIST,
    qot_get_institution_holding_list
);
qot_raw_rest_endpoint!(
    get_ark_fund_holding,
    QOT_GET_ARK_FUND_HOLDING,
    qot_get_ark_fund_holding
);
qot_raw_rest_endpoint!(
    get_ark_stock_dynamic,
    QOT_GET_ARK_STOCK_DYNAMIC,
    qot_get_ark_stock_dynamic
);
qot_raw_rest_endpoint!(
    get_ark_active_transaction,
    QOT_GET_ARK_ACTIVE_TRANSACTION,
    qot_get_ark_active_transaction
);
qot_raw_rest_endpoint!(
    get_rating_change,
    QOT_GET_RATING_CHANGE,
    qot_get_rating_change
);
qot_raw_rest_endpoint!(
    get_industrial_chain_list,
    QOT_GET_INDUSTRIAL_CHAIN_LIST,
    qot_get_industrial_chain_list
);
qot_raw_rest_endpoint!(
    get_industrial_chain_detail,
    QOT_GET_INDUSTRIAL_CHAIN_DETAIL,
    qot_get_industrial_chain_detail
);
qot_raw_rest_endpoint!(
    get_industrial_chain_by_plate,
    QOT_GET_INDUSTRIAL_CHAIN_BY_PLATE,
    qot_get_industrial_chain_by_plate
);
qot_raw_rest_endpoint!(
    get_industrial_plate_info,
    QOT_GET_INDUSTRIAL_PLATE_INFO,
    qot_get_industrial_plate_info
);
qot_raw_rest_endpoint!(
    get_industrial_plate_stock,
    QOT_GET_INDUSTRIAL_PLATE_STOCK,
    qot_get_industrial_plate_stock
);
qot_raw_rest_endpoint!(
    get_heat_map_data,
    QOT_GET_HEAT_MAP_DATA,
    qot_get_heat_map_data
);
qot_raw_rest_endpoint!(
    get_rise_fall_distribution,
    QOT_GET_RISE_FALL_DISTRIBUTION,
    qot_get_rise_fall_distribution
);