refactor: make ContentContext::new synchronous and infallible across all bindings

Author: sunli829

c/src/content_context/context.rs

@@ -33,7 +33,7 @@ pub unsafe extern "C" fn lb_content_context_new(
         std::ptr::null_mut::<c_void>(),
         userdata,
         async move {
-            let ctx = ContentContext::try_new(config)?;
+            let ctx = ContentContext::new(config);
             let arc_ctx = Arc::new(CContentContext { ctx });
             let ctx = Arc::into_raw(arc_ctx);
             Ok(CAsyncResult {

java/javasrc/src/main/java/com/longbridge/SdkNative.java

@@ -57,7 +57,7 @@ public static native void oauthBuild(String clientId, int callbackPort,
 
         public static native void freeOAuth(long oauth);
 
-        public static native void newContentContext(long config, AsyncCallback callback);
+        public static native long newContentContext(long config);
 
         public static native void freeContentContext(long context);
 

java/javasrc/src/main/java/com/longbridge/content/ContentContext.java

@@ -14,14 +14,12 @@ public class ContentContext implements AutoCloseable {
      * Create a ContentContext object
      *
      * @param config Config object
-     * @return A Future representing the result of the operation
-     * @throws OpenApiException If an error occurs
+     * @return A ContentContext object
      */
-    public static CompletableFuture<ContentContext> create(Config config)
-            throws OpenApiException {
-        return AsyncCallback.executeTask((callback) -> {
-            SdkNative.newContentContext(config.getRaw(), callback);
-        });
+    public static ContentContext create(Config config) {
+        ContentContext ctx = new ContentContext();
+        ctx.raw = SdkNative.newContentContext(config.getRaw());
+        return ctx;
     }
 
     @Override

java/src/content_context.rs

@@ -2,16 +2,14 @@ use std::sync::Arc;
 
 use jni::{
     JNIEnv,
-    errors::Result,
-    objects::{JClass, JObject, JValueOwned},
+    objects::{JClass, JObject},
 };
 use longbridge::{Config, content::ContentContext};
 
 use crate::{
     async_util,
     error::jni_result,
-    init::CONTENT_CONTEXT_CLASS,
-    types::{FromJValue, IntoJValue, ObjectArray, set_field},
+    types::{FromJValue, ObjectArray},
 };
 
 struct ContextObj {
@@ -23,29 +21,11 @@ pub unsafe extern "system" fn Java_com_longbridge_SdkNative_newContentContext(
     mut env: JNIEnv,
     _class: JClass,
     config: i64,
-    callback: JObject,
-) {
-    struct ContextObjRef(i64);
-
-    impl IntoJValue for ContextObjRef {
-        fn into_jvalue<'a>(self, env: &mut JNIEnv<'a>) -> Result<JValueOwned<'a>> {
-            let ctx_obj = env.new_object(CONTENT_CONTEXT_CLASS.get().unwrap(), "()V", &[])?;
-            set_field(env, &ctx_obj, "raw", self.0)?;
-            Ok(JValueOwned::from(ctx_obj))
-        }
-    }
-
-    jni_result(&mut env, (), |env| {
+) -> i64 {
+    jni_result(&mut env, 0i64, |_env| {
         let config = Arc::new((*(config as *const Config)).clone());
-
-        async_util::execute(env, callback, async move {
-            let ctx = ContentContext::try_new(config)?;
-            Ok(ContextObjRef(
-                Box::into_raw(Box::new(ContextObj { ctx })) as i64
-            ))
-        })?;
-
-        Ok(())
+        let ctx = ContentContext::new(config);
+        Ok(Box::into_raw(Box::new(ContextObj { ctx })) as i64)
     })
 }
 

java/src/init.rs

@@ -20,7 +20,7 @@ pub(crate) static TIME_LOCALDATETIME_CLASS: OnceLock<GlobalRef> = OnceLock::new(
 pub(crate) static TIME_ZONE_ID: OnceLock<GlobalRef> = OnceLock::new();
 pub(crate) static QUOTE_CONTEXT_CLASS: OnceLock<GlobalRef> = OnceLock::new();
 pub(crate) static TRADE_CONTEXT_CLASS: OnceLock<GlobalRef> = OnceLock::new();
-pub(crate) static CONTENT_CONTEXT_CLASS: OnceLock<GlobalRef> = OnceLock::new();
+
 pub(crate) static DERIVATIVE_TYPE_CLASS: OnceLock<GlobalRef> = OnceLock::new();
 pub(crate) static OPENAPI_EXCEPTION_CLASS: OnceLock<GlobalRef> = OnceLock::new();
 
@@ -73,11 +73,7 @@ pub extern "system" fn Java_com_longbridge_SdkNative_init<'a>(
         (DERIVATIVE_TYPE_CLASS, "com/longbridge/quote/DerivativeType"),
         (OPENAPI_EXCEPTION_CLASS, "com/longbridge/OpenApiException"),
         (QUOTE_CONTEXT_CLASS, "com/longbridge/quote/QuoteContext"),
-        (TRADE_CONTEXT_CLASS, "com/longbridge/trade/TradeContext"),
-        (
-            CONTENT_CONTEXT_CLASS,
-            "com/longbridge/content/ContentContext"
-        )
+        (TRADE_CONTEXT_CLASS, "com/longbridge/trade/TradeContext")
     );
 
     init_timezone_id(&mut env);

mcp/src/main.rs

@@ -49,7 +49,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     );
     let (quote_context, _) = QuoteContext::new(config.clone());
     let (trade_context, _) = TradeContext::new(config.clone());
-    let content_context = ContentContext::try_new(config.clone())?;
+    let content_context = ContentContext::new(config.clone());
     let readonly = cli.readonly;
 
     if !cli.http {

nodejs/src/content/context.rs

@@ -19,11 +19,10 @@ pub struct ContentContext {
 impl ContentContext {
     /// Create a new `ContentContext`
     #[napi]
-    pub async fn new(config: &Config) -> napi::Result<ContentContext> {
-        Ok(Self {
-            ctx: longbridge::content::ContentContext::try_new(Arc::new(config.0.clone()))
-                .map_err(ErrorNewType)?,
-        })
+    pub fn new(config: &Config) -> ContentContext {
+        Self {
+            ctx: longbridge::content::ContentContext::new(Arc::new(config.0.clone())),
+        }
     }
 
     /// Get discussion topics list

python/docs/index.md

@@ -30,7 +30,7 @@
 
 - [AsyncContentContext](reference_all.md#longbridge.openapi.AsyncContentContext)
 
-  Async content API for use with asyncio; create via `AsyncContentContext.create(config)` and await in asyncio.
+  Async content API for use with asyncio; create via `AsyncContentContext.create(config)` (synchronous, no await needed at construction).
 
 ## Quickstart
 

python/src/content/context.rs

@@ -19,7 +19,7 @@ impl ContentContext {
     #[new]
     fn new(config: &Config) -> PyResult<Self> {
         Ok(Self {
-            ctx: ContentContextSync::try_new(Arc::new(config.0.clone())).map_err(ErrorNewType)?,
+            ctx: ContentContextSync::new(Arc::new(config.0.clone())).map_err(ErrorNewType)?,
         })
     }
 

python/src/content/context_async.rs

@@ -19,15 +19,10 @@ pub(crate) struct AsyncContentContext {
 impl AsyncContentContext {
     /// Create an async content context.
     #[classmethod]
-    fn create(cls: &Bound<PyType>, config: &Config) -> PyResult<Py<PyAny>> {
-        let py = cls.py();
-        let config = Arc::new(config.0.clone());
-        pyo3_async_runtimes::tokio::future_into_py(py, async move {
-            Ok(AsyncContentContext {
-                ctx: Arc::new(ContentContext::try_new(config).map_err(ErrorNewType)?),
-            })
-        })
-        .map(|b| b.unbind())
+    fn create(_cls: &Bound<PyType>, config: &Config) -> Self {
+        AsyncContentContext {
+            ctx: Arc::new(ContentContext::new(Arc::new(config.0.clone()))),
+        }
     }
 
     /// Get discussion topics list. Returns awaitable.