wait for complete state before sending commands

1 files changed, 19 insertions, 0 deletions

diff --git a/mumd/src/command.rs b/mumd/src/command.rs
index 322bde8..1f7a781 100644
--- a/mumd/src/command.rs
+++ b/mumd/src/command.rs
@@ -1,3 +1,9 @@
+use crate::state::State;
+
+use std::sync::{Arc, Mutex};
+use tokio::sync::mpsc;
+
+#[derive(Debug)]
 pub enum Command {
     ChannelJoin {
         channel_id: u32,
@@ -12,3 +18,16 @@ pub enum Command {
     ServerDisconnect,
     Status,
 }
+
+pub async fn handle(
+    state: Arc<Mutex<State>>,
+    mut command_receiver: mpsc::UnboundedReceiver<Command>,
+) {
+    // wait until we can send packages
+    let mut initialized_receiver = state.lock().unwrap().initialized_receiver();
+    while matches!(initialized_receiver.recv().await, Some(false)) {}
+
+    while let Some(command) = command_receiver.recv().await {
+        state.lock().unwrap().handle_command(command).await;
+    }
+}