From 521a8915f273dc2cda59080a2393e40e4f25db50 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Wed, 26 Mar 2025 15:57:24 +0000 Subject: feat(filamento): create example --- lampada/src/main.rs | 42 ------------------------------------------ 1 file changed, 42 deletions(-) delete mode 100644 lampada/src/main.rs (limited to 'lampada/src') diff --git a/lampada/src/main.rs b/lampada/src/main.rs deleted file mode 100644 index 7b7469d..0000000 --- a/lampada/src/main.rs +++ /dev/null @@ -1,42 +0,0 @@ -use std::{path::Path, str::FromStr, time::Duration}; - -use jid::JID; -use lampada::{db::Db, CoreClientCommand, LuzHandle}; -use sqlx::SqlitePool; -use tokio::{ - io::{AsyncReadExt, AsyncWriteExt}, - sync::oneshot, -}; -use tracing::info; - -#[tokio::main] -async fn main() { - tracing_subscriber::fmt::init(); - let db = Db::create_connect_and_migrate(Path::new("./luz.db")) - .await - .unwrap(); - let (luz, mut recv) = - LuzHandle::new("test@blos.sm".try_into().unwrap(), "slayed".to_string(), db); - - tokio::spawn(async move { - while let Some(msg) = recv.recv().await { - info!("{:#?}", msg) - } - }); - - luz.send(CoreClientCommand::Connect).await.unwrap(); - let (send, recv) = oneshot::channel(); - tokio::time::sleep(Duration::from_secs(5)).await; - info!("sending message"); - luz.send(CoreClientCommand::SendMessage( - JID::from_str("cel@blos.sm").unwrap(), - luz::chat::Body { - body: "hallo!!!".to_string(), - }, - send, - )) - .await - .unwrap(); - recv.await.unwrap().unwrap(); - println!("sent message"); -} -- cgit