| use crate::binary::mapper; |
| use crate::binary::sender::Sender; |
| use crate::state::command::EntryCommand; |
| use crate::streaming::session::Session; |
| use crate::streaming::systems::system::SharedSystem; |
| use anyhow::Result; |
| use iggy::error::IggyError; |
| use iggy::streams::create_stream::CreateStream; |
| use tracing::debug; |
| |
| pub async fn handle( |
| command: CreateStream, |
| sender: &mut dyn Sender, |
| session: &Session, |
| system: &SharedSystem, |
| ) -> Result<(), IggyError> { |
| debug!("session: {session}, command: {command}"); |
| let response; |
| { |
| let mut system = system.write().await; |
| let stream = system |
| .create_stream(session, command.stream_id, &command.name) |
| .await?; |
| response = mapper::map_stream(stream); |
| } |
| |
| let system = system.read().await; |
| system |
| .state |
| .apply(session.get_user_id(), EntryCommand::CreateStream(command)) |
| .await?; |
| sender.send_ok_response(&response).await?; |
| Ok(()) |
| } |