initial port of c bindings

Author: analogrelay

Cargo.lock

@@ -8,10 +8,13 @@ udfs
 backoff
 pluggable
 cloneable
+upsert
+upserts
 
 # Cosmos' docs all use "Autoscale" as a single word, rather than a compound "AutoScale" or "Auto Scale"
 autoscale
 
 # Words used within the Cosmos Native Client (azure_data_cosmos_native)
 azurecosmos
 cosmosclient
+cstring

sdk/cosmos/.dict.txt

@@ -98,7 +98,7 @@ pub struct SystemProperties {
 ///
 /// Returned by [`DatabaseClient::read()`](crate::clients::DatabaseClient::read()).
 #[non_exhaustive]
-#[derive(Clone, Default, Debug, Deserialize, PartialEq, Eq)]
+#[derive(Clone, Default, Debug, Deserialize, Serialize, PartialEq, Eq)]
 pub struct DatabaseProperties {
     /// The ID of the database.
     pub id: String,

sdk/cosmos/azure_data_cosmos/src/models/mod.rs

@@ -14,7 +14,15 @@ name = "azurecosmos"
 crate-type = ["cdylib", "staticlib"]
 
 [dependencies]
-azure_data_cosmos = { path = "../azure_data_cosmos" }
+futures.workspace = true
+tokio = { workspace = true, optional = true, features = ["rt-multi-thread", "macros"] }
+serde_json = { workspace = true, features = ["raw_value"] }
+azure_core.workspace = true
+azure_data_cosmos = { path = "../azure_data_cosmos", features = [ "key_auth", "preview_query_engine" ] }
+
+[features]
+default = ["tokio"]
+tokio = ["dep:tokio"]
 
 [build-dependencies]
 cbindgen = "0.29.0"

sdk/cosmos/azure_data_cosmos_native/Cargo.toml

@@ -36,9 +36,13 @@ fn main() {
             "\n// Specifies the version of cosmosclient this header file was generated from.\n// This should match the version of libcosmosclient you are referencing.\n#define COSMOSCLIENT_H_VERSION \"{}\"",
             env!("CARGO_PKG_VERSION")
         ))
+        .with_style(cbindgen::Style::Both)
+        .rename_item("CosmosClientHandle", "CosmosClient")
+        .rename_item("DatabaseClientHandle", "DatabaseClient")
+        .rename_item("ContainerClientHandle", "ContainerClient")
         .with_cpp_compat(true)
         .with_header(header)
         .generate()
         .expect("unable to generate bindings")
-        .write_to_file("include/cosmosclient.h");
+        .write_to_file("include/azurecosmos.h");
 }

sdk/cosmos/azure_data_cosmos_native/build.rs

@@ -0,0 +1,51 @@
+use std::{future::Future, sync::OnceLock};
+use tokio::runtime::Runtime;
+
+// Centralized runtime - single instance per process (following Azure SDK pattern)
+// https://github.com/Azure/azure-sdk-for-cpp/blob/main/sdk/core/azure-core-amqp/src/impl/rust_amqp/rust_amqp/rust_wrapper/src/amqp/connection.rs#L100-L107
+pub static RUNTIME: OnceLock<Runtime> = OnceLock::new();
+
+pub fn block_on<F>(future: F) -> F::Output
+where
+    F: Future,
+{
+    let runtime = RUNTIME.get_or_init(|| Runtime::new().expect("Failed to create Tokio runtime"));
+    runtime.block_on(future)
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_blocking_runtime_initialization() {
+        let result1 = block_on(async { 42 });
+        let result2 = block_on(async { 24 });
+
+        assert_eq!(result1, 42);
+        assert_eq!(result2, 24);
+    }
+
+    #[test]
+    fn test_blocking_async_operation() {
+        let result = block_on(async {
+            tokio::time::sleep(tokio::time::Duration::from_millis(1)).await;
+            "completed"
+        });
+
+        assert_eq!(result, "completed");
+    }
+
+    #[test]
+    fn test_runtime_singleton() {
+        block_on(async { 1 });
+        let runtime1 = RUNTIME.get();
+
+        block_on(async { 2 });
+        let runtime2 = RUNTIME.get();
+
+        assert!(runtime1.is_some());
+        assert!(runtime2.is_some());
+        assert!(std::ptr::eq(runtime1.unwrap(), runtime2.unwrap()));
+    }
+}