Add tool to remove embeds for clocktower.live links

At this point, IDFK. I changed nothing and the permissions are correct now.

.envrc

@@ -1,4 +1,4 @@
 use flake
 
-export DISCORD_TOKEN_FILE=./token
-export DB_FILE=db.sqlite
+export DISCORD_TOKEN_FILE=./token-prod
+export DB_FILE=db-prod.sqlite

src/main.rs

@@ -1,6 +1,6 @@
-use std::{future::Future, io, path::Path};
+use std::{io, path::Path};
 
-use ::serenity::all::{ChannelId, GuildId, Mentionable, UserId};
+use ::serenity::all::{ChannelId, EditMessage, GuildId, Mentionable, UserId};
 use eyre::{Context as _, Error, OptionExt, Result};
 use futures::{FutureExt, StreamExt, TryStreamExt};
 use poise::serenity_prelude as serenity;
@@ -107,19 +107,21 @@ async fn channel_children(
 }
 
 #[tracing::instrument]
-fn move_users<'a>(
+async fn move_users<'a>(
     ctx: Context<'a>,
     guild: GuildId,
     users: Vec<(ChannelId, UserId)>,
-) -> impl Future<Output = Result<()>> + Send + 'a {
-    futures::stream::iter(users.into_iter().map(move |(channel, user)| async move {
+) -> Result<()> {
+    futures::stream::iter(users.into_iter())
+        .map(Ok::<_, eyre::Error>)
+        .try_for_each_concurrent(10, move |(channel, user)| async move {
             tracing::info!(?channel, ?user, "Moving user");
             guild.move_member(ctx, user, channel).await?;
             tracing::info!(?channel, ?user, "Moved user");
             Ok(())
-    }))
-    .buffer_unordered(10)
-    .try_collect::<()>()
+        })
+        .await?;
+    Ok(())
 }
 
 #[tracing::instrument]
@@ -321,7 +323,9 @@ async fn currently_playing(ctx: Context<'_>, player: Option<serenity::UserId>) -
     let guild = ctx
         .guild_id()
         .ok_or_eyre("This bot only works in servers")?;
-    let GuildData { currently_playing, .. } = ctx.data().get(guild).await?;
+    let GuildData {
+        currently_playing, ..
+    } = ctx.data().get(guild).await?;
 
     let member = guild
         .member(&ctx, player.unwrap_or(ctx.author().id))
@@ -336,7 +340,12 @@ async fn currently_playing(ctx: Context<'_>, player: Option<serenity::UserId>) -
     };
 
     ctx.reply(if player.is_some() {
-        format!("{} is {} {}", member.mention(), msg, currently_playing.mention())
+        format!(
+            "{} is {} {}",
+            member.mention(),
+            msg,
+            currently_playing.mention()
+        )
     } else {
         format!("You are {} {}", msg, currently_playing.mention())
     })
@@ -382,15 +391,28 @@ async fn register_commands(
     Ok(())
 }
 
+#[tracing::instrument(skip(ctx))]
+async fn handle_message(ctx: impl AsRef<serenity::Http>, message: &serenity::Message) -> Result<()> {
+    for embed in &message.embeds {
+        if embed.url.as_ref().is_some_and(|url| url.contains("https://clocktower.live")) {
+            let mut message = message.clone();
+            message.edit(&ctx.as_ref(), EditMessage::new().suppress_embeds(true)).await?;
+        }
+    }
+    Ok(())
+}
+
 async fn on_event(
     ctx: &serenity::Context,
     event: &serenity::FullEvent,
     framework: poise::FrameworkContext<'_, Data, Error>,
     _: &Data,
 ) -> Result<()> {
-    if let serenity::FullEvent::GuildCreate { guild, is_new: _ } = event {
-        register_commands(ctx, framework.options, guild.id).await?;
-    };
+    match event {
+        serenity::FullEvent::GuildCreate { guild, is_new: _ } => register_commands(ctx, framework.options, guild.id).await?,
+        serenity::FullEvent::Message { new_message: msg } | serenity::FullEvent::MessageUpdate { new: Some(msg), .. } => handle_message(ctx, msg).await?,
+        _ => {}
+    }
     Ok(())
 }
 
@@ -415,7 +437,7 @@ async fn main() -> Result<()> {
     .wrap_err("A Discord token is required")?;
     let dbfile = std::env::var_os("DB_FILE").ok_or_eyre("A database file is required")?;
     let intents =
-        serenity::GatewayIntents::non_privileged() | serenity::GatewayIntents::GUILD_MEMBERS;
+        serenity::GatewayIntents::non_privileged() | serenity::GatewayIntents::GUILD_MEMBERS | serenity::GatewayIntents::GUILD_MESSAGES;
 
     let framework = poise::Framework::builder()
         .options(poise::FrameworkOptions {