From c6162b77fb113634359acc9dd6b7d6b4191fc5d4 Mon Sep 17 00:00:00 2001 From: seth Date: Sat, 20 Jan 2024 21:19:09 -0500 Subject: refactor: adjust to poise 0.6.1 --- src/main.rs | 25 +++++++++++++------------ 1 file changed, 13 insertions(+), 12 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index 1cbd2e7..1eef5bf 100644 --- a/src/main.rs +++ b/src/main.rs @@ -8,13 +8,12 @@ use std::time::Duration; use color_eyre::eyre::{eyre, Context as _, Report, Result}; use color_eyre::owo_colors::OwoColorize; use log::{info, warn}; -use poise::serenity_prelude::{self as serenity, ShardManager}; +use poise::serenity_prelude as serenity; use poise::{EditTracker, Framework, FrameworkOptions, PrefixFrameworkOptions}; use redis::ConnectionLike; use storage::Storage; use tokio::signal::ctrl_c; use tokio::signal::unix::{signal, SignalKind}; -use tokio::sync::Mutex; mod api; mod colors; @@ -71,9 +70,9 @@ async fn setup( Ok(data) } -async fn handle_shutdown(shard_manager: Arc>, reason: &str) { +async fn handle_shutdown(shard_manager: Arc, reason: &str) { warn!("{reason}! Shutting down bot..."); - shard_manager.lock().await.shutdown_all().await; + shard_manager.shutdown_all().await; println!("{}", "Everything is shutdown. Goodbye!".green()); } @@ -106,7 +105,9 @@ async fn main() -> Result<()> { prefix_options: PrefixFrameworkOptions { prefix: Some("!".into()), - edit_tracker: Some(EditTracker::for_timespan(Duration::from_secs(3600))), + edit_tracker: Some(Arc::new(EditTracker::for_timespan(Duration::from_secs( + 3600, + )))), ..Default::default() }, @@ -114,19 +115,19 @@ async fn main() -> Result<()> { }; let framework = Framework::builder() - .token(token) - .intents(intents) .options(options) .setup(|ctx, ready, framework| Box::pin(setup(ctx, ready, framework))) - .build() - .await - .wrap_err_with(|| "Failed to build framework!")?; + .build(); - let shard_manager = framework.shard_manager().clone(); + let mut client = serenity::ClientBuilder::new(token, intents) + .framework(framework) + .await?; + + let shard_manager = client.shard_manager.clone(); let mut sigterm = signal(SignalKind::terminate())?; tokio::select! { - result = framework.start() => result.map_err(Report::from), + result = client.start() => result.map_err(Report::from), _ = sigterm.recv() => { handle_shutdown(shard_manager, "Recieved SIGTERM").await; std::process::exit(0); -- cgit v1.2.3