mirror of
https://github.com/logos-messaging/libchat.git
synced 2026-05-12 13:09:29 +00:00
de9216a152
Implement a `client` crate that wraps the `libchat` context behind a simple `ChatClient<D>` API. The delivery strategy is pluggable via a `DeliveryService` trait, with two implementations provided: - `InProcessDelivery` — shared `MessageBus` for single-process tests - `CDelivery` — C function-pointer callback for the FFI layer Add a `client-ffi` crate that exposes the client as a C API via `safer-ffi`. A `generate-headers` binary produces the companion C header. Include two runnable examples: - `examples/in-process` — Alice/Bob exchange using in-process delivery - `examples/c-ffi` — same exchange written entirely in C; smoketested under valgrind (to catch memory leaks) in CI iterates: #71
34 lines
1.1 KiB
Rust
34 lines
1.1 KiB
Rust
use client::{ChatClient, ConversationIdOwned, InProcessDelivery};
|
|
use std::sync::Arc;
|
|
|
|
fn main() {
|
|
let delivery = InProcessDelivery::new(Default::default());
|
|
let mut cursor = delivery.cursor_at_tail("delivery_address");
|
|
|
|
let mut saro = ChatClient::new("saro", delivery.clone());
|
|
let mut raya = ChatClient::new("raya", delivery);
|
|
|
|
let raya_bundle = raya.create_intro_bundle().unwrap();
|
|
saro.create_conversation(&raya_bundle, b"hello raya")
|
|
.unwrap();
|
|
|
|
let raw = cursor.next().unwrap();
|
|
let content = raya.receive(&raw).unwrap().unwrap();
|
|
println!(
|
|
"Raya received: {:?}",
|
|
std::str::from_utf8(&content.data).unwrap()
|
|
);
|
|
|
|
let raya_convo_id: ConversationIdOwned = Arc::from(content.conversation_id.as_str());
|
|
raya.send_message(&raya_convo_id, b"hi saro").unwrap();
|
|
|
|
let raw = cursor.next().unwrap();
|
|
let content = saro.receive(&raw).unwrap().unwrap();
|
|
println!(
|
|
"Saro received: {:?}",
|
|
std::str::from_utf8(&content.data).unwrap()
|
|
);
|
|
|
|
println!("Message exchange complete.");
|
|
}
|