1 files changed, 67 insertions, 0 deletions
diff --git a/src/handler/mod.rs b/src/handler/mod.rs
new file mode 100644
index 0000000..47e2774
--- /dev/null
+++ b/src/handler/mod.rs
@@ -0,0 +1,67 @@
+use crate::command;
+
+use std::error::Error;
+
+use serenity::async_trait;
+use serenity::builder::{CreateEmbed, CreateInteractionResponse, CreateInteractionResponseMessage};
+use serenity::model::{
+	application::{Command, Interaction},
+	colour::Colour,
+	gateway::Ready,
+};
+use serenity::prelude::{Context, EventHandler};
+use tracing::{debug, error, info, instrument};
+
+#[derive(Clone, Copy, Debug)]
+pub struct Handler;
+
+impl Handler {
+	async fn register_commands(&self, ctx: &Context) -> Result<(), Box<dyn Error>> {
+		let commands = command::to_vec();
+		let commands_len = commands.len();
+		for command in commands {
+			Command::create_global_command(&ctx.http, command).await?;
+		}
+
+		debug!("Registered {} commands", commands_len);
+		Ok(())
+	}
+}
+
+#[async_trait]
+impl EventHandler for Handler {
+	#[instrument(skip_all)]
+	async fn interaction_create(&self, ctx: Context, interaction: Interaction) {
+		if let Interaction::Command(command) = interaction {
+			let command_name = &command.data.name;
+			debug!("Received command: {}", command_name);
+
+			if let Err(why) = command::dispatch(&ctx, &command).await {
+				error!(
+					"Ran into an error while dispatching command {}:\n{why:?}",
+					command_name
+				);
+
+				let embed = CreateEmbed::new()
+					.title("An error occurred")
+					.description("Sorry about that!")
+					.color(Colour::RED);
+				let message = CreateInteractionResponseMessage::new().embed(embed);
+				let response = CreateInteractionResponse::Message(message);
+
+				if let Err(why) = command.create_response(&ctx.http, response).await {
+					error!("Ran into an error while trying to recover from an error!\n{why:?}");
+				}
+			}
+		}
+	}
+
+	#[instrument(skip_all)]
+	async fn ready(&self, ctx: Context, ready: Ready) {
+		info!("Connected as {}!", ready.user.name);
+
+		if let Err(why) = self.register_commands(&ctx).await {
+			error!("Couldn't register commands!\n{why:?}");
+		};
+	}
+}