feat(us): US market APIs — Rust, Python, Node.js, Java, blocking

.gitignore

@@ -3,6 +3,7 @@
 .vscode
 *.log
 cmake.build
+.claude/
 build
 
 # Eclipse IDE

java/src/fundamental_context.rs

@@ -330,3 +330,134 @@ pub unsafe extern "system" fn Java_com_longbridge_SdkNative_fundamentalContextMa
         Ok(())
     })
 }
+
+// ── US-market JNI stubs
+// ─────────────────────────────────────────────────────── All US APIs return
+// JSON strings; Java callers parse with Gson/Jackson.
+
+macro_rules! us_counter_id_method {
+    ($jni_name:ident, $method:ident) => {
+        #[unsafe(no_mangle)]
+        pub unsafe extern "system" fn $jni_name(
+            mut env: JNIEnv,
+            _class: JClass,
+            context: i64,
+            counter_id: JObject,
+            callback: JObject,
+        ) {
+            jni_result(&mut env, (), |env| {
+                let context = &*(context as *const ContextObj);
+                let counter_id: String = FromJValue::from_jvalue(env, counter_id.into())?;
+                async_util::execute(env, callback, async move {
+                    let resp = context.ctx.$method(counter_id).await?;
+                    Ok(serde_json::to_string(&resp).unwrap_or_default())
+                })?;
+                Ok(())
+            })
+        }
+    };
+}
+
+macro_rules! us_counter_id_report_method {
+    ($jni_name:ident, $method:ident) => {
+        #[unsafe(no_mangle)]
+        pub unsafe extern "system" fn $jni_name(
+            mut env: JNIEnv,
+            _class: JClass,
+            context: i64,
+            counter_id: JObject,
+            report: JObject,
+            callback: JObject,
+        ) {
+            jni_result(&mut env, (), |env| {
+                let context = &*(context as *const ContextObj);
+                let counter_id: String = FromJValue::from_jvalue(env, counter_id.into())?;
+                let report: String = FromJValue::from_jvalue(env, report.into())?;
+                async_util::execute(env, callback, async move {
+                    let resp = context.ctx.$method(counter_id, report).await?;
+                    Ok(serde_json::to_string(&resp).unwrap_or_default())
+                })?;
+                Ok(())
+            })
+        }
+    };
+}
+
+us_counter_id_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsCompanyOverview,
+    us_company_overview
+);
+us_counter_id_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsValuationOverview,
+    us_valuation_overview
+);
+us_counter_id_report_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsFinancialOverview,
+    us_financial_overview
+);
+us_counter_id_report_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsKeyFinancialMetrics,
+    us_key_financial_metrics
+);
+us_counter_id_report_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsAnalystConsensus,
+    us_analyst_consensus
+);
+us_counter_id_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsEtfDividendInfo,
+    us_etf_dividend_info
+);
+us_counter_id_method!(
+    Java_com_longbridge_SdkNative_fundamentalContextUsCompanyDividends,
+    us_company_dividends
+);
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_fundamentalContextUsFinancialStatementV3(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    counter_id: JObject,
+    kind: JObject,
+    report: JObject,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let counter_id: String = FromJValue::from_jvalue(env, counter_id.into())?;
+        let kind: String = FromJValue::from_jvalue(env, kind.into())?;
+        let report: String = FromJValue::from_jvalue(env, report.into())?;
+        async_util::execute(env, callback, async move {
+            let resp = context
+                .ctx
+                .us_financial_statement_v3(counter_id, kind, report)
+                .await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_fundamentalContextUsEtfFiles(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    counter_id: JObject,
+    size: JObject,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let counter_id: String = FromJValue::from_jvalue(env, counter_id.into())?;
+        let size: Option<i32> = FromJValue::from_jvalue(env, size.into())?;
+        async_util::execute(env, callback, async move {
+            let resp = context
+                .ctx
+                .us_etf_files(counter_id, size.map(|s| s as u32))
+                .await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}

java/src/quote_context.rs

@@ -1282,3 +1282,22 @@ pub unsafe extern "system" fn Java_com_longbridge_SdkNative_quoteContextOptionVo
         Ok(())
     })
 }
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_quoteContextUsCryptoOverview(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    symbol: JObject,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let symbol: String = FromJValue::from_jvalue(env, symbol.into())?;
+        async_util::execute(env, callback, async move {
+            let resp = context.ctx.us_crypto_overview(symbol).await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}

java/src/trade_context.rs

@@ -4,16 +4,16 @@ use jni::{
     JNIEnv, JavaVM,
     errors::Result,
     objects::{GlobalRef, JClass, JObject, JString},
-    sys::jobjectArray,
+    sys::{jboolean, jobjectArray},
 };
 use longbridge::{
     Config, Decimal, Market, TradeContext,
     trade::{
         BalanceType, EstimateMaxPurchaseQuantityOptions, GetCashFlowOptions,
         GetFundPositionsOptions, GetHistoryExecutionsOptions, GetHistoryOrdersOptions,
         GetStockPositionsOptions, GetTodayExecutionsOptions, GetTodayOrdersOptions, OrderSide,
-        OrderStatus, OrderType, OutsideRTH, PushEvent, ReplaceOrderOptions, SubmitOrderOptions,
-        TimeInForceType, TopicType,
+        OrderStatus, OrderType, OutsideRTH, PushEvent, QueryUSOrdersOptions, ReplaceOrderOptions,
+        SubmitOrderOptions, TimeInForceType, TopicType,
     },
 };
 use parking_lot::Mutex;
@@ -625,3 +625,104 @@ pub unsafe extern "system" fn Java_com_longbridge_SdkNative_tradeContextEstimate
         Ok(())
     })
 }
+
+// ── US-market JNI stubs ──────────────────────────────────────────────────────
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_tradeContextUsQueryOrders(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    symbol: JObject,
+    action: i64,
+    start_at: i64,
+    end_at: i64,
+    query_type: i64,
+    page: i64,
+    limit: i64,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let symbol_str: String = FromJValue::from_jvalue(env, symbol.into())?;
+        let us_opts = longbridge::trade::GetUSHistoryOrders {
+            symbol: if symbol_str.is_empty() {
+                None
+            } else {
+                Some(symbol_str)
+            },
+            side: match action {
+                1 => longbridge::trade::OrderSide::Buy,
+                2 => longbridge::trade::OrderSide::Sell,
+                _ => longbridge::trade::OrderSide::Unknown,
+            },
+            start_at,
+            end_at,
+            query_type: query_type as i32,
+            page: page as i32,
+            limit: limit as i32,
+        };
+        async_util::execute(env, callback, async move {
+            let resp = context.ctx.us_query_orders(us_opts).await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_tradeContextUsOrderDetail(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    order_id: JObject,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let order_id: String = FromJValue::from_jvalue(env, order_id.into())?;
+        async_util::execute(env, callback, async move {
+            let resp = context.ctx.us_order_detail(order_id).await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_tradeContextUsAssetOverview(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        async_util::execute(env, callback, async move {
+            let resp = context.ctx.us_asset_overview().await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}
+
+#[unsafe(no_mangle)]
+pub unsafe extern "system" fn Java_com_longbridge_SdkNative_tradeContextUsRealizedPl(
+    mut env: JNIEnv,
+    _class: JClass,
+    context: i64,
+    currency: JObject,
+    category: JObject,
+    callback: JObject,
+) {
+    jni_result(&mut env, (), |env| {
+        let context = &*(context as *const ContextObj);
+        let currency: String = FromJValue::from_jvalue(env, currency.into())?;
+        let category: Option<String> = FromJValue::from_jvalue(env, category.into()).ok();
+        async_util::execute(env, callback, async move {
+            let resp = context.ctx.us_realized_pl(longbridge::trade::GetUSRealizedPLOptions { currency, category: category.unwrap_or_default() }).await?;
+            Ok(serde_json::to_string(&resp).unwrap_or_default())
+        })?;
+        Ok(())
+    })
+}