From 3f5ddf917dcc28fa34ee53090a3d6adbb5ee381e Mon Sep 17 00:00:00 2001 From: Thilo Behnke Date: Sat, 28 May 2022 21:42:06 +0200 Subject: [PATCH] session reader / session writer --- server/src/http.rs | 2 +- server/src/session.rs | 10 ++++++++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/server/src/http.rs b/server/src/http.rs index 69f368f..6cf5426 100644 --- a/server/src/http.rs +++ b/server/src/http.rs @@ -58,7 +58,7 @@ async fn handle_request(session_manager: &Arc>, event_writ match (req.method(), req.uri().path()) { (&Method::POST, "/create_session") => handle_session_create(session_manager, req).await, (&Method::POST, "/write") => handle_event_write(event_writer, req).await, - (&Method::GET, "/show") => handle_event_read(event_reader, req).await, + (&Method::POST, "/read") => handle_event_read(event_reader, req).await, _ => Ok(Response::new("unknown".into())) } } diff --git a/server/src/session.rs b/server/src/session.rs index 274fdb8..7bc6426 100644 --- a/server/src/session.rs +++ b/server/src/session.rs @@ -45,8 +45,14 @@ impl SessionManager { Ok(session) } - pub fn get_session_consumer(&self, session: Session) -> EventReader { - EventReader::new(Box::new(KafkaSessionEventReaderImpl::new(&self.kafka_host, &session, &["move", "status", "input"]))) + pub fn get_session_reader(&self, session: Session) -> SessionReader { + let event_reader = EventReader::new(Box::new(KafkaSessionEventReaderImpl::new(&self.kafka_host, &session, &["move", "status", "input"]))); + SessionReader {reader: event_reader, session} + } + + pub fn get_session_writer(&self, session: Session) -> SessionWriter { + let event_writer = EventWriter::new(Box::new(KafkaSessionEventWriterImpl::new(&self.kafka_host))); + SessionWriter {writer: event_writer, session} } }