logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-07 00:13:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

extend rust example with waku_start (#3224)

Browse Source
This commit is contained in:
Ivan FB 2024-12-26 19:37:43 +01:00 committed by GitHub
parent e4a07a99ce
commit 5aeee9dded
1 changed files with 21 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
examples/rust/src/main.rs
View File

@ -1,16 +1,9 @@
use std::os::raw::{c_char, c_int, c_void};
use std::{slice, thread, time};
use std::cell::OnceCell; use std::cell::OnceCell;
use std::ffi::CString; use std::ffi::CString;
use std::os::raw::{c_char, c_int, c_void};
use std::{slice, thread, time};
pub type WakuCallback = pub type WakuCallback = unsafe extern "C" fn(c_int, *const c_char, usize, *const c_void);
unsafe extern "C" fn(
c_int,
*const c_char,
usize,
*const c_void,
);
extern "C" { extern "C" {
pub fn waku_new( pub fn waku_new(
@ -19,11 +12,9 @@ extern "C" {
user_data: *const c_void, user_data: *const c_void,
) -> *mut c_void; ) -> *mut c_void;
pub fn waku_version( pub fn waku_version(ctx: *const c_void, cb: WakuCallback, user_data: *const c_void) -> c_int;
ctx: *const c_void,
cb: WakuCallback, pub fn waku_start(ctx: *const c_void, cb: WakuCallback, user_data: *const c_void) -> c_int;
user_data: *const c_void,
) -> c_int;
pub fn waku_default_pubsub_topic( pub fn waku_default_pubsub_topic(
ctx: *mut c_void, ctx: *mut c_void,
@ -43,9 +34,8 @@ pub unsafe extern "C" fn trampoline<C>(
let closure = &mut *(data as *mut C); let closure = &mut *(data as *mut C);
let buffer_utf8 = let buffer_utf8 =
String::from_utf8(slice::from_raw_parts(buffer as *mut u8, buffer_len) String::from_utf8(slice::from_raw_parts(buffer as *mut u8, buffer_len).to_vec())
.to_vec()) .expect("valid utf8");
.expect("valid utf8");
closure(return_val, &buffer_utf8); closure(return_val, &buffer_utf8);
} }
@ -70,7 +60,7 @@ fn main() {
unsafe { unsafe {
// Create the waku node // Create the waku node
let closure = |ret: i32, data: &str| { let closure = |ret: i32, data: &str| {
println!("Ret {ret}. Error creating waku node {data}"); println!("Ret {ret}. waku_new closure called {data}");
}; };
let cb = get_trampoline(&closure); let cb = get_trampoline(&closure);
let config_json_str = CString::new(config_json).unwrap(); let config_json_str = CString::new(config_json).unwrap();
@ -99,14 +89,20 @@ fn main() {
let _ = default_pubsub_topic.set(data.to_string()); let _ = default_pubsub_topic.set(data.to_string());
}; };
let cb = get_trampoline(&closure); let cb = get_trampoline(&closure);
let _ret = waku_default_pubsub_topic( let _ret = waku_default_pubsub_topic(ctx, cb, &closure as *const _ as *const c_void);
ctx,
cb,
&closure as *const _ as *const c_void,
);
println!("Version: {}", version.get_or_init(|| unreachable!())); println!("Version: {}", version.get_or_init(|| unreachable!()));
println!("Default pubsubTopic: {}", default_pubsub_topic.get_or_init(|| unreachable!())); println!(
"Default pubsubTopic: {}",
default_pubsub_topic.get_or_init(|| unreachable!())
);
// Start the Waku node
let closure = |ret: i32, data: &str| {
println!("Ret {ret}. waku_start closure called {data}");
};
let cb = get_trampoline(&closure);
let _ret = waku_start(ctx, cb, &closure as *const _ as *const c_void);
} }
loop { loop {