Add SetAttendanceMode command

Author: schmidma

src/client.rs

@@ -184,6 +184,9 @@ async fn handle_message(
             Command::RemoveNerd { talk_id } => {
                 remove_nerd(state, talk_id, user_id).await?;
             }
+            Command::SetAttendanceMode { attendance_mode } => {
+                set_attendance_mode(state, user_id, attendance_mode).await?;
+            }
         }
     }
 
@@ -400,3 +403,22 @@ async fn remove_nerd(state: &AppState, talk_id: usize, user_id: usize) -> Result
         .send(Update::RemoveNerd { talk_id, user_id });
     Ok(())
 }
+
+async fn set_attendance_mode(
+    state: &AppState,
+    user_id: UserId,
+    attendance_mode: crate::storage::AttendanceMode,
+) -> Result<()> {
+    let mut storage = state.storage.write().await;
+    let Storage { users, .. } = storage.deref_mut();
+    let user = users
+        .get_mut(&user_id)
+        .wrap_err_with(|| format!("user {user_id} does not exist"))?;
+    user.attendance_mode = attendance_mode;
+    users.commit().await.wrap_err("failed to commit users")?;
+    let _ = state.updates_sender.send(Update::UpdateAttendanceMode {
+        user_id,
+        attendance_mode,
+    });
+    Ok(())
+}

src/messages.rs

@@ -82,6 +82,9 @@ pub enum Command {
     RemoveNerd {
         talk_id: usize,
     },
+    SetAttendanceMode {
+        attendance_mode: AttendanceMode,
+    },
 }
 
 #[allow(clippy::enum_variant_names)]
@@ -134,6 +137,10 @@ pub enum Update {
         talk_id: usize,
         user_id: usize,
     },
+    UpdateAttendanceMode {
+        user_id: usize,
+        attendance_mode: AttendanceMode,
+    },
 }
 
 #[derive(Clone, Debug, Deserialize, Serialize)]