github/wasm-pong
1
0
Fork 0
mirror of https://github.com/thilo-behnke/wasm-pong.git synced 2026-07-11 02:29:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

session reader / session writer

Browse Source
This commit is contained in:
Thilo Behnke
2022-05-28 21:42:06 +02:00
parent cf1d0fc520
commit 3f5ddf917d
2 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/http.rs
View File

@@ -58,7 +58,7 @@ async fn handle_request(session_manager: &Arc<Mutex<SessionManager>>, 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()))
}
}

10
server/src/session.rs
View File

@@ -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}
}
}