Static link telemetry lib

Author: Charlie Friend

wrappers/rust/cpp-client-telemetry-sys/build.rs

@@ -54,13 +54,21 @@ fn write_bindings(header_path: &PathBuf) {
 }
 
 fn main() {
+    let mat_h_location = PathBuf::from(PROJECT_ROOT).join("lib/include/public/mat.h");
+    println!("cargo:rerun-if-changed={}", mat_h_location.to_string_lossy());
+
+    let out_dir = env::var("OUT_DIR").unwrap();
+    std::fs::copy("../lib/ClientTelemetry.lib", PathBuf::from(&out_dir).join("ClientTelemetry.lib"))
+        .expect("Failed to copy native ClientTelemetry lib");
+
     // Tell cargo to look for shared libraries in the specified directory
-    println!("cargo:rustc-link-search=../lib");
+    println!("cargo:rustc-link-search=native={}", out_dir);
+    println!("cargo:rustc-link-lib=ClientTelemetry");
 
     // TODO use clang crate instead of invoking CLI directly
     let header_out = Exec::cmd("clang")
         .arg("-E")
-        .arg(PathBuf::from(PROJECT_ROOT).join("lib/include/public/mat.h"))
+        .arg(mat_h_location)
         .arg("-D")
         .arg("HAVE_DYNAMIC_C_LIB")
         .capture()

wrappers/rust/cpp-client-telemetry-sys/src/lib.rs

@@ -1,14 +1,83 @@
-pub fn add(left: usize, right: usize) -> usize {
-    left + right
+#![allow(non_upper_case_globals)]
+#![allow(non_camel_case_types)]
+#![allow(non_snake_case)]
+include!(concat!(env!("OUT_DIR"), "/bindings.rs"));
+
+use std::{ffi::{c_void}, os::raw};
+
+fn evt_api_call_wrapper(context_ptr: *mut evt_context_t) -> Option<evt_handle_t> {
+    let mut result = -1;
+    unsafe {
+        if let Some(cb) = evt_api_call {
+            result = cb(context_ptr);
+        }
+    }
+
+    if result == -1 {
+        return Option::None;
+    }
+
+    // Box is now responsible for destroying the context
+    let context = unsafe { Box::from_raw(context_ptr) };
+
+    Some(context.handle.clone())
+}
+
+pub fn evt_open(config: *mut c_void) -> Option<evt_handle_t> {
+    let context: Box<evt_context_t> = Box::new(evt_context_t {
+        call: evt_call_t_EVT_OP_OPEN,
+        handle: 0,
+        data: config,
+        result: 0,
+        size: 0,
+    });
+
+    evt_api_call_wrapper(Box::into_raw(context))
+}
+
+pub fn evt_close(handle: &evt_handle_t) -> evt_status_t {
+    let context: Box<evt_context_t> = Box::new(evt_context_t {
+        call: evt_call_t_EVT_OP_CLOSE,
+        handle: *handle,
+        data: std::ptr::null_mut(),
+        result: 0,
+        size: 0,
+    });
+
+    let raw_pointer = Box::into_raw(context);
+
+    let mut result: evt_status_t = -1;
+    unsafe {
+        if let Some(cb) = evt_api_call {
+            result = cb(raw_pointer);
+            let _context = Box::from_raw(raw_pointer);
+        }
+    }
+
+    result
 }
 
 #[cfg(test)]
 mod tests {
     use super::*;
 
     #[test]
-    fn it_works() {
-        let result = add(2, 2);
-        assert_eq!(result, 4);
+    fn test_open_close() {
+        let config = r#"{
+            "eventCollectorUri": "http://localhost:64099/OneCollector/track",
+            "cacheFilePath":"hackathon_storage.db",
+            "config":{"host": "*"},
+            "name":"Rust-API-Client-0",
+            "version":"1.0.0",
+            "primaryToken":"99999999999999999999999999999999-99999999-9999-9999-9999-999999999999-9999",
+            "maxTeardownUploadTimeInSec":5,
+            "hostMode":false,
+            "traceLevelMask": 4294967295,
+            "minimumTraceLevel":0,
+            "sdkmode":0,
+            "compat": {"customTypePrefix": "compat_event"}
+        }"#;
+
+        let result = evt_open(config.as_ptr() as *mut c_void);
     }
 }