Add ban and unban event publishing to user management functions (#32)

* Add ban and unban event publishing to user management functions

- Implemented `publish_ban_event` and `publish_unban_event` functions in the users repository.
- Updated `ban_user`, `unban_user`, `restrict_user`, and `unrestrict_user` functions to publish events for leaderboard updates upon user ban and unban actions.

* Move ban/unban event publishing to usecase layer (#33)

* Initial plan

* Move event publishing from commands to usecases

Co-authored-by: cmyui <17343631+cmyui@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: cmyui <17343631+cmyui@users.noreply.github.com>

* ddeath to dead code

* Simplify error handling in user management usecases (#34)

* Initial plan

* Use ? syntax for both calls in ban/unban/restrict/unrestrict usecases

Co-authored-by: cmyui <17343631+cmyui@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: cmyui <17343631+cmyui@users.noreply.github.com>

---------

Co-authored-by: Copilot <198982749+Copilot@users.noreply.github.com>
Co-authored-by: cmyui <17343631+cmyui@users.noreply.github.com>

Author: cmyui

src/repositories/users.rs

@@ -248,3 +248,15 @@ pub async fn update_previous_overwrite<C: Context>(
         .await?;
     Ok(())
 }
+
+pub async fn publish_ban_event<C: Context>(ctx: &C, user_id: i64) -> anyhow::Result<()> {
+    let mut redis = ctx.redis().await?;
+    let _: () = redis.publish("peppy:ban", user_id.to_string()).await?;
+    Ok(())
+}
+
+pub async fn publish_unban_event<C: Context>(ctx: &C, user_id: i64) -> anyhow::Result<()> {
+    let mut redis = ctx.redis().await?;
+    let _: () = redis.publish("peppy:unban", user_id.to_string()).await?;
+    Ok(())
+}

src/usecases/users.rs

@@ -92,31 +92,27 @@ pub async fn change_username<C: Context>(
 }
 
 pub async fn ban_user<C: Context>(ctx: &C, user_id: i64) -> ServiceResult<()> {
-    match users::ban(ctx, user_id).await {
-        Ok(_) => Ok(()),
-        Err(e) => unexpected(e),
-    }
+    users::ban(ctx, user_id).await?;
+    users::publish_ban_event(ctx, user_id).await?;
+    Ok(())
 }
 
 pub async fn unban_user<C: Context>(ctx: &C, user_id: i64) -> ServiceResult<()> {
-    match users::unban(ctx, user_id).await {
-        Ok(_) => Ok(()),
-        Err(e) => unexpected(e),
-    }
+    users::unban(ctx, user_id).await?;
+    users::publish_unban_event(ctx, user_id).await?;
+    Ok(())
 }
 
 pub async fn restrict_user<C: Context>(ctx: &C, user_id: i64) -> ServiceResult<()> {
-    match users::restrict(ctx, user_id).await {
-        Ok(_) => Ok(()),
-        Err(e) => unexpected(e),
-    }
+    users::restrict(ctx, user_id).await?;
+    users::publish_ban_event(ctx, user_id).await?;
+    Ok(())
 }
 
 pub async fn unrestrict_user<C: Context>(ctx: &C, user_id: i64) -> ServiceResult<()> {
-    match users::unrestrict(ctx, user_id).await {
-        Ok(_) => Ok(()),
-        Err(e) => unexpected(e),
-    }
+    users::unrestrict(ctx, user_id).await?;
+    users::publish_unban_event(ctx, user_id).await?;
+    Ok(())
 }
 
 pub async fn freeze_user<C: Context>(ctx: &C, user_id: i64, reason: &str) -> ServiceResult<()> {