chore: bump deps; implement chombo ranking limit

Cargo.toml

@@ -11,19 +11,19 @@ codegen-units = 1
 lto = true
 
 [workspace.dependencies]
-anyhow = "1.0.75"
-async-trait = "0.1.74"
-chrono = { version = "0.4.28", features = ["serde"] }
-image = { version = "0.24.7", default-features = false, features = ["png"] }
-reqwest = "0.11.22"
-riichi_hand = "0.6.0"
-scraper = "0.17.1"
-serde = "1.0.190"
-tokio = { version = "1.33.0", features = ["macros", "rt-multi-thread"] }
-slug = "0.1.4"
-clap = { version = "4.4.7", features = ["derive", "env"] }
-env_logger = "0.10.0"
+anyhow = "1.0.79"
+async-trait = "0.1.77"
+chrono = { version = "0.4.31", features = ["serde"] }
+image = { version = "0.24.8", default-features = false, features = ["png"] }
+reqwest = { version = "0.11.23", features = ["json"] }
+riichi_hand = "0.6.1"
+scraper = "0.18.1"
+serde = "1.0.195"
+tokio = { version = "1.35.1", features = ["macros", "rt-multi-thread"] }
+slug = "0.1.5"
+clap = { version = "4.4.16", features = ["derive", "env"] }
+env_logger = "0.10.1"
 log = "0.4.20"
 num-bigint = "0.4.4"
-itertools = "0.11.0"
-poise = "0.5.7"
+itertools = "0.12.0"
+poise = "0.6.1"

chombot-common/src/data.rs

@@ -1 +1,2 @@
 pub const DISCORD_MESSAGE_SIZE_LIMIT: usize = 2000;
+pub const DISCORD_EMBED_FIELD_LIMIT: usize = 25;

chombot-common/src/discord_utils.rs

@@ -1,4 +1,4 @@
-use poise::serenity_prelude::{ChannelId, Context, Error as SerenityError};
+use poise::serenity_prelude::{ChannelId, Context, CreateMessage, Error as SerenityError};
 
 use crate::data::DISCORD_MESSAGE_SIZE_LIMIT;
 
@@ -11,7 +11,7 @@
     for line in text.lines() {
         if message.len() + line.len() + "\n".len() > DISCORD_MESSAGE_SIZE_LIMIT {
             channel_id
-                .send_message(ctx, |m| m.content(&message))
+                .send_message(ctx, CreateMessage::new().content(&message))
                 .await?;
             message.clear();
         }
@@ -20,7 +20,9 @@
         message.push('\n');
     }
     if !message.is_empty() {
-        channel_id.send_message(ctx, |m| m.content(message)).await?;
+        channel_id
+            .send_message(ctx, CreateMessage::new().content(&message))
+            .await?;
     }
 
     Ok(())

chombot-common/src/slash_commands/hand.rs

@@ -2,7 +2,7 @@
 
 use anyhow::Result;
 use image::DynamicImage;
-use poise::serenity_prelude::AttachmentType;
+use poise::serenity_prelude::{CreateAttachment, CreateMessage};
 use poise::ChoiceParameter;
 
 use crate::chombot::{ChombotBase, TileStyle};
@@ -50,9 +50,9 @@
     DynamicImage::ImageRgba8(image)
         .write_to(&mut Cursor::new(&mut buf), image::ImageOutputFormat::Png)?;
 
-    let files: Vec<AttachmentType> = vec![(buf.as_slice(), "hand.png").into()];
+    let files: Vec<CreateAttachment> = vec![CreateAttachment::bytes(buf.as_slice(), "hand.png")];
     ctx.channel_id()
-        .send_files(&ctx.http(), files, |m| m)
+        .send_files(&ctx.http(), files, CreateMessage::new())
         .await?;
 
     ctx.say("<:Ichiwink:591396074141515776>").await?;

chombot-common/src/slash_commands/score.rs

@@ -2,7 +2,7 @@
 use log::info;
 use num_bigint::BigInt;
 use poise::serenity_prelude::{Color, CreateEmbed};
-use poise::ChoiceParameter;
+use poise::{ChoiceParameter, CreateReply};
 use riichi_hand::points::{Fu, Han, Honbas, PointsCalculationMode, PointsCustom};
 
 use crate::{ChombotPoiseContext, ChombotPoiseUserData};
@@ -58,20 +58,19 @@
     let points = Points::from_calculated(points_calculation_mode, han, fu, honbas)?;
     let fields = create_points_embed_fields(&points);
 
-    ctx.send(|reply| reply.embed(move |embed| create_points_embed(embed, han, fu, honbas, fields)))
+    ctx.send(CreateReply::default().embed(create_points_embed(han, fu, honbas, fields)))
         .await?;
 
     Ok(())
 }
 
 fn create_points_embed(
-    embed: &mut CreateEmbed,
     han: Han,
     fu: Fu,
     honbas: Honbas,
     fields: impl Iterator<Item = (&'static str, String, bool)>,
-) -> &mut CreateEmbed {
-    embed
+) -> CreateEmbed {
+    CreateEmbed::new()
         .title(format!("**{han} {fu} {honbas}**"))
         .color(Color::DARK_GREEN)
         .fields(fields)

chombot-kcc/src/main.rs

@@ -13,8 +13,10 @@
 use chombot_common::{start_tournaments_watcher, ChombotPoiseUserData};
 use clap::Parser;
 use log::{error, info, LevelFilter};
-use poise::serenity_prelude::{ChannelId, Context as SerenityContext, GatewayIntents};
-use poise::{BoxFuture, Command, Context, Event, Framework, FrameworkContext, FrameworkOptions};
+use poise::serenity_prelude::{
+    ChannelId, ClientBuilder, Context as SerenityContext, FullEvent, GatewayIntents,
+};
+use poise::{BoxFuture, Command, Context, Framework, FrameworkContext, FrameworkOptions};
 
 use crate::args::Arguments;
 use crate::chombot::Chombot;
@@ -49,7 +51,7 @@
     let ranking_watcher_channel_id = ranking_watcher_channel_id
         .expect("Ranking watcher feature enabled but no channel ID provided");
     let notifier = ChannelMessageNotifier::new(
-        ChannelId(ranking_watcher_channel_id),
+        ChannelId::new(ranking_watcher_channel_id),
         String::from("https://ranking.cvgo.re/ ranking update"),
     );
     tokio::spawn(async move {
@@ -74,11 +76,11 @@
 
 fn event_handler<'a>(
     ctx: &'a SerenityContext,
-    event: &'a Event<'a>,
+    event: &'a FullEvent,
     _framework_ctx: FrameworkContext<'a, PoiseUserData, Error>,
     _user_data: &'a PoiseUserData,
 ) -> BoxFuture<'a, anyhow::Result<()>> {
-    if let Event::Message { new_message } = event {
+    if let FullEvent::Message { new_message } = event {
         return Box::pin(async move {
             if !new_message.mention_everyone {
                 return Ok(());
@@ -133,8 +135,6 @@
             event_handler,
             ..Default::default()
         })
-        .token(&args.discord_token)
-        .intents(GatewayIntents::non_privileged())
         .setup(move |ctx, ready, framework| {
             Box::pin(async move {
                 if args.feature_ranking_watcher {
@@ -154,9 +154,15 @@
                     kcc_chombot,
                 })
             })
-        });
+        })
+        .build();
+
+    let mut client = ClientBuilder::new(&args.discord_token, GatewayIntents::non_privileged())
+        .framework(framework)
+        .await
+        .expect("Could not create client");
 
-    if let Err(why) = framework.run().await {
+    if let Err(why) = client.start().await {
         error!("Client error: {why:?}");
     }
 }

chombot-kcc/src/ranking_watcher/notifier.rs

@@ -79,7 +79,7 @@ mod tests {
 
     #[test]
     fn test_channel_message_notifier_build_message() {
-        let notifier = ChannelMessageNotifier::new(ChannelId(123), "TEST_MESSAGE".into());
+        let notifier = ChannelMessageNotifier::new(ChannelId::new(123), "TEST_MESSAGE".into());
         let ranking = Ranking(vec![
             RankingEntry {
                 pos: 1,

chombot-kcc/src/slash_commands/chombo.rs

@@ -1,6 +1,7 @@
 use anyhow::Result;
-use chombot_common::data::DISCORD_MESSAGE_SIZE_LIMIT;
-use poise::serenity_prelude::{Color, CreateEmbed, User};
+use chombot_common::data::{DISCORD_EMBED_FIELD_LIMIT, DISCORD_MESSAGE_SIZE_LIMIT};
+use poise::serenity_prelude::{Color, CreateAllowedMentions, CreateEmbed, User};
+use poise::CreateReply;
 use slug::slugify;
 
 use crate::chombot::Chombot;
@@ -18,7 +19,7 @@
 async fn ranking(ctx: PoiseContext<'_>) -> Result<()> {
     let entries = get_chombos_embed_entries(&ctx.data().kcc_chombot).await?;
 
-    ctx.send(|response| response.embed(|embed| create_chombos_embed(embed, entries)))
+    ctx.send(CreateReply::default().embed(create_chombos_embed(entries)))
         .await?;
 
     Ok(())
@@ -29,11 +30,11 @@
 async fn list(ctx: PoiseContext<'_>) -> Result<()> {
     let chombos = create_chombos_list(&ctx.data().kcc_chombot).await?;
 
-    ctx.send(|response| {
-        response
+    ctx.send(
+        CreateReply::default()
             .content(chombos)
-            .allowed_mentions(|mentions| mentions.empty_parse())
-    })
+            .allowed_mentions(CreateAllowedMentions::new().empty_users().empty_roles()),
+    )
     .await?;
 
     Ok(())
@@ -64,30 +65,28 @@
     let message_content = format_add_message(&user, &description);
     let entries = get_chombos_embed_entries(chombot).await?;
 
-    ctx.send(|response| {
-        response
+    ctx.send(
+        CreateReply::default()
             .content(message_content)
-            .embed(|embed| create_chombos_embed(embed, entries))
-    })
+            .embed(create_chombos_embed(entries)),
+    )
     .await?;
 
     Ok(())
 }
 
 async fn get_chombos_embed_entries(
     chombot: &Chombot,
-) -> Result<impl Iterator<Item = (String, usize, bool)>> {
+) -> Result<impl Iterator<Item = (String, String, bool)>> {
     let chombo_ranking = chombot.create_chombo_ranking().await?;
     Ok(chombo_ranking
         .into_iter()
-        .map(|(player, num)| (player.short_name(), num, true)))
+        .take(DISCORD_EMBED_FIELD_LIMIT)
+        .map(|(player, num)| (player.short_name(), num.to_string(), true)))
 }
 
-fn create_chombos_embed(
-    embed: &mut CreateEmbed,
-    entries: impl Iterator<Item = (String, usize, bool)>,
-) -> &mut CreateEmbed {
-    embed
+fn create_chombos_embed(entries: impl Iterator<Item = (String, String, bool)>) -> CreateEmbed {
+    CreateEmbed::new()
             .title("**CHOMBO COUNTER**")
             .color(Color::RED)
             .thumbnail("https://cdn.discordapp.com/attachments/591385176685281293/597292309792686090/1562356453777.png")

chombot-kcc/src/slash_commands/pasta/command.rs

@@ -1,6 +1,6 @@
 use anyhow::Result;
 use chombot_common::data::DISCORD_MESSAGE_SIZE_LIMIT;
-use poise::serenity_prelude::CacheHttp;
+use poise::serenity_prelude::{CacheHttp, CreateMessage};
 use poise::ChoiceParameter;
 
 use crate::PoiseContext;
@@ -64,7 +64,7 @@
         ctx.say(message).await?;
     } else {
         ctx.channel_id()
-            .send_message(&ctx.http(), |m| m.content(message))
+            .send_message(&ctx.http(), CreateMessage::new().content(message))
             .await?;
     }
 

chombot/Cargo.toml

@@ -25,8 +25,8 @@ env_logger.workspace = true
 num-bigint.workspace = true
 itertools.workspace = true
 poise.workspace = true
-toml = "0.8.6"
+toml = "0.8.8"
 chombot-common = { path = "../chombot-common" }
 
 [dev-dependencies]
-tempfile = "3.8.1"
+tempfile = "3.9.0"

chombot/src/config.rs

@@ -133,15 +133,15 @@ mod tests {
         let config = Config {
             guilds: HashMap::from([
                 (
-                    GuildId(69),
+                    GuildId::new(69),
                     GuildConfig {
-                        tournaments_watcher_channel_id: Some(ChannelId(2137)),
+                        tournaments_watcher_channel_id: Some(ChannelId::new(2137)),
                     },
                 ),
                 (
-                    GuildId(420),
+                    GuildId::new(420),
                     GuildConfig {
-                        tournaments_watcher_channel_id: Some(ChannelId(69)),
+                        tournaments_watcher_channel_id: Some(ChannelId::new(69)),
                     },
                 ),
             ]),
@@ -168,24 +168,24 @@ mod tests {
         let config = Config {
             guilds: HashMap::from([
                 (
-                    GuildId(69),
+                    GuildId::new(69),
                     GuildConfig {
-                        tournaments_watcher_channel_id: Some(ChannelId(2137)),
+                        tournaments_watcher_channel_id: Some(ChannelId::new(2137)),
                     },
                 ),
                 (
-                    GuildId(420),
+                    GuildId::new(420),
                     GuildConfig {
-                        tournaments_watcher_channel_id: Some(ChannelId(69)),
+                        tournaments_watcher_channel_id: Some(ChannelId::new(69)),
                     },
                 ),
             ]),
         };
 
-        let channel_ids: Vec<ChannelId> = vec![ChannelId(69), ChannelId(2137)];
+        let channel_ids: Vec<ChannelId> = vec![ChannelId::new(69), ChannelId::new(2137)];
 
         {
-            let chombot_config = ChombotConfig::new(path.to_path_buf(), config.clone());
+            let chombot_config = ChombotConfig::new(path.to_path_buf(), config);
             let mut ids = tokio::runtime::Builder::new_current_thread()
                 .build()?
                 .block_on(async { chombot_config.tournament_watcher_channels().await });

chombot/src/main.rs

@@ -14,7 +14,7 @@
 use chombot_common::{start_tournaments_watcher, ChombotPoiseUserData};
 use clap::Parser;
 use log::{error, info, LevelFilter};
-use poise::serenity_prelude::GatewayIntents;
+use poise::serenity_prelude::{ClientBuilder, GatewayIntents};
 use poise::{Command, Context, Framework, FrameworkOptions};
 use tokio::sync::RwLock;
 
@@ -61,8 +61,6 @@
             commands: get_command_list(),
             ..Default::default()
         })
-        .token(&args.discord_token)
-        .intents(GatewayIntents::non_privileged())
         .setup(move |ctx, ready, framework| {
             Box::pin(async move {
                 start_tournaments_watcher(config_ref.clone(), ctx.clone());
@@ -73,9 +71,15 @@
                     config: config_ref,
                 })
             })
-        });
+        })
+        .build();
+
+    let mut client = ClientBuilder::new(&args.discord_token, GatewayIntents::non_privileged())
+        .framework(framework)
+        .await
+        .expect("Could not create client");
 
-    if let Err(why) = framework.run().await {
+    if let Err(why) = client.start().await {
         error!("Client error: {why:?}");
     }
 }