implement CLIENT

1 files changed, 22 insertions, 4 deletions

diff --git a/luz/src/main.rs b/luz/src/main.rs
index 5e9cd13..9779351 100644
--- a/luz/src/main.rs
+++ b/luz/src/main.rs
@@ -1,8 +1,13 @@
-use std::time::Duration;
+use std::{str::FromStr, time::Duration};
 
+use jid::JID;
 use luz::{CommandMessage, LuzHandle};
 use sqlx::SqlitePool;
-use tokio::io::{AsyncReadExt, AsyncWriteExt};
+use tokio::{
+    io::{AsyncReadExt, AsyncWriteExt},
+    sync::oneshot,
+};
+use tracing::info;
 
 #[tokio::main]
 async fn main() {
@@ -13,10 +18,23 @@ async fn main() {
 
     tokio::spawn(async move {
         while let Some(msg) = recv.recv().await {
-            println!("{:#?}", msg)
+            info!("{:#?}", msg)
         }
     });
 
     luz.send(CommandMessage::Connect).await.unwrap();
-    tokio::time::sleep(Duration::from_secs(15)).await;
+    let (send, recv) = oneshot::channel();
+    tokio::time::sleep(Duration::from_secs(5)).await;
+    info!("sending message");
+    luz.send(CommandMessage::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");
 }