From 9fabef3b9df6b4500bf36e6e7cc708d4852feebd Mon Sep 17 00:00:00 2001
From: Thilo Behnke <thilo.behnke@gmx.net>
Date: Sun, 5 Jun 2022 15:45:33 +0200
Subject: [PATCH] send message to websocket

---
 server/src/http.rs | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/server/src/http.rs b/server/src/http.rs
index eee6cc1..eb6fe48 100644
--- a/server/src/http.rs
+++ b/server/src/http.rs
@@ -157,7 +157,15 @@ async fn serve_websocket(websocket_session: WebSocketSession, websocket: HyperWe
         println!("Ready to read messages from kafka: {:?}", websocket_session_write_copy);
         loop {
             let messages = event_reader.read_from_session();
+            if let Err(_) = messages {
+                eprintln!("Failed to read messages from kafka for session: {:?}", websocket_session_write_copy);
+                continue;
+            }
             println!("Read messages for websocket_session {:?} from consumer: {:?}", websocket_session_write_copy, messages);
+            let messages = messages.unwrap();
+            let json = serde_json::to_string(&messages).unwrap();
+            let message = Message::from(json);
+            websocket_writer.send(message);
         }
     });
     Ok(())