Add remaining commands

src/commands/allowed_dm/mod.rs

@@ -1,5 +1,5 @@
-pub mod set_allowed_dm;
-pub mod unset_allowed_dm;
+pub mod set;
+pub mod unset;
 
 use crate::{Context, Error};
 

src/commands/allowed_dm/set.rs

@@ -0,0 +1,38 @@
+use poise::{serenity_prelude::CreateEmbed, CreateReply};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    consts::THEME_COLOR,
+    models::CtxData,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let mut user_data = ctx.author_data().await?;
+        user_data.allowed_dm = true;
+        user_data.commit_changes(&ctx.data().database).await;
+
+        ctx.send(
+            CreateReply::default().ephemeral(true).embed(
+                CreateEmbed::new()
+                    .title("DMs permitted")
+                    .description("You will receive a message if a user sets a DM reminder for you.")
+                    .color(*THEME_COLOR),
+            ),
+        )
+        .await?;
+
+        Ok(())
+    }
+}
+
+/// Allow other users to set reminders in your direct messages
+#[poise::command(slash_command, rename = "allow", identifying_name = "set_allowed_dm")]
+pub async fn set(ctx: Context<'_>) -> Result<(), Error> {
+    (Options {}).run(ctx).await
+}

src/commands/allowed_dm/set_allowed_dm.rs

@@ -1,23 +0,0 @@
-use poise::{serenity_prelude::CreateEmbed, CreateReply};
-
-use crate::{consts::THEME_COLOR, models::CtxData, Context, Error};
-
-/// Allow other users to set reminders in your direct messages
-#[poise::command(slash_command, rename = "allow", identifying_name = "set_allowed_dm")]
-pub async fn set_allowed_dm(ctx: Context<'_>) -> Result<(), Error> {
-    let mut user_data = ctx.author_data().await?;
-    user_data.allowed_dm = true;
-    user_data.commit_changes(&ctx.data().database).await;
-
-    ctx.send(
-        CreateReply::default().ephemeral(true).embed(
-            CreateEmbed::new()
-                .title("DMs permitted")
-                .description("You will receive a message if a user sets a DM reminder for you.")
-                .color(*THEME_COLOR),
-        ),
-    )
-    .await?;
-
-    Ok(())
-}

src/commands/allowed_dm/unset.rs

@@ -0,0 +1,41 @@
+use poise::{serenity_prelude::CreateEmbed, CreateReply};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    consts::THEME_COLOR,
+    models::CtxData,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let mut user_data = ctx.author_data().await?;
+        user_data.allowed_dm = false;
+        user_data.commit_changes(&ctx.data().database).await;
+
+        ctx.send(
+            CreateReply::default().ephemeral(true).embed(
+                CreateEmbed::new()
+                    .title("DMs blocked")
+                    .description(concat!(
+                        "You can still set DM reminders for yourself or for users with",
+                        " DMs enabled."
+                    ))
+                    .color(*THEME_COLOR),
+            ),
+        )
+        .await?;
+
+        Ok(())
+    }
+}
+
+/// Block other users from setting reminders in your direct messages
+#[poise::command(slash_command, rename = "block", identifying_name = "unset_allowed_dm")]
+pub async fn unset(ctx: Context<'_>) -> Result<(), Error> {
+    (Options {}).run(ctx).await
+}

src/commands/allowed_dm/unset_allowed_dm.rs

@@ -1,25 +0,0 @@
-use poise::{serenity_prelude::CreateEmbed, CreateReply};
-
-use crate::{consts::THEME_COLOR, models::CtxData, Context, Error};
-
-/// Block other users from setting reminders in your direct messages
-#[poise::command(slash_command, rename = "block", identifying_name = "unset_allowed_dm")]
-pub async fn unset_allowed_dm(ctx: Context<'_>) -> Result<(), Error> {
-    let mut user_data = ctx.author_data().await?;
-    user_data.allowed_dm = false;
-    user_data.commit_changes(&ctx.data().database).await;
-
-    ctx.send(
-        CreateReply::default().ephemeral(true).embed(
-            CreateEmbed::new()
-                .title("DMs blocked")
-                .description(
-                    "You can still set DM reminders for yourself or for users with DMs enabled.",
-                )
-                .color(*THEME_COLOR),
-        ),
-    )
-    .await?;
-
-    Ok(())
-}

src/commands/settings/ephemeral_confirmations/mod.rs

@@ -1,7 +1,7 @@
 use crate::{Context, Error};
 
-pub mod set_ephemeral_confirmations;
-pub mod unset_ephemeral_confirmations;
+pub mod set;
+pub mod unset;
 
 /// Configure ephemeral setup
 #[poise::command(

src/commands/settings/ephemeral_confirmations/set.rs

@@ -0,0 +1,46 @@
+use poise::{serenity_prelude::CreateEmbed, CreateReply};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    consts::THEME_COLOR,
+    models::CtxData,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let mut guild_data = ctx.guild_data().await.unwrap()?;
+        guild_data.ephemeral_confirmations = true;
+        guild_data.commit_changes(&ctx.data().database).await;
+
+        ctx.send(
+            CreateReply::default().ephemeral(true).embed(
+                CreateEmbed::new()
+                    .title("Confirmations ephemeral")
+                    .description(concat!(
+                    "Reminder confirmations will be sent privately, and removed when your client",
+                    " restarts."
+                ))
+                    .color(*THEME_COLOR),
+            ),
+        )
+        .await?;
+
+        Ok(())
+    }
+}
+
+/// Set reminder confirmations to be sent "ephemerally" (private and cleared automatically)
+#[poise::command(
+    slash_command,
+    rename = "on",
+    identifying_name = "set_ephemeral_confirmations",
+    guild_only = true
+)]
+pub async fn set(ctx: Context<'_>) -> Result<(), Error> {
+    (Options {}).run(ctx).await
+}

src/commands/settings/ephemeral_confirmations/set_ephemeral_confirmations.rs

@@ -1,31 +0,0 @@
-use poise::{serenity_prelude::CreateEmbed, CreateReply};
-
-use crate::{consts::THEME_COLOR, models::CtxData, Context, Error};
-
-/// Set reminder confirmations to be sent "ephemerally" (private and cleared automatically)
-#[poise::command(
-    slash_command,
-    rename = "on",
-    identifying_name = "set_ephemeral_confirmations",
-    guild_only = true
-)]
-pub async fn set_ephemeral_confirmations(ctx: Context<'_>) -> Result<(), Error> {
-    let mut guild_data = ctx.guild_data().await.unwrap()?;
-    guild_data.ephemeral_confirmations = true;
-    guild_data.commit_changes(&ctx.data().database).await;
-
-    ctx.send(
-        CreateReply::default().ephemeral(true).embed(
-            CreateEmbed::new()
-                .title("Confirmations ephemeral")
-                .description(concat!(
-                    "Reminder confirmations will be sent privately, and removed when your client",
-                    " restarts."
-                ))
-                .color(*THEME_COLOR),
-        ),
-    )
-    .await?;
-
-    Ok(())
-}

src/commands/settings/ephemeral_confirmations/unset.rs

@@ -0,0 +1,46 @@
+use poise::{serenity_prelude::CreateEmbed, CreateReply};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    consts::THEME_COLOR,
+    models::CtxData,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let mut guild_data = ctx.guild_data().await.unwrap()?;
+        guild_data.ephemeral_confirmations = false;
+        guild_data.commit_changes(&ctx.data().database).await;
+
+        ctx.send(
+            CreateReply::default().ephemeral(true).embed(
+                CreateEmbed::new()
+                    .title("Confirmations public")
+                    .description(concat!(
+                        "Reminder confirmations will be sent as regular messages, and won't be ",
+                        "removed automatically."
+                    ))
+                    .color(*THEME_COLOR),
+            ),
+        )
+        .await?;
+
+        Ok(())
+    }
+}
+
+/// Set reminder confirmations to persist indefinitely
+#[poise::command(
+    slash_command,
+    rename = "off",
+    identifying_name = "unset_ephemeral_confirmations",
+    guild_only = true
+)]
+pub async fn unset(ctx: Context<'_>) -> Result<(), Error> {
+    (Options {}).run(ctx).await
+}

src/commands/settings/ephemeral_confirmations/unset_ephemeral_confirmations.rs

@@ -1,31 +0,0 @@
-use poise::{serenity_prelude::CreateEmbed, CreateReply};
-
-use crate::{consts::THEME_COLOR, models::CtxData, Context, Error};
-
-/// Set reminder confirmations to persist indefinitely
-#[poise::command(
-    slash_command,
-    rename = "off",
-    identifying_name = "unset_ephemeral_confirmations",
-    guild_only = true
-)]
-pub async fn unset_ephemeral_confirmations(ctx: Context<'_>) -> Result<(), Error> {
-    let mut guild_data = ctx.guild_data().await.unwrap()?;
-    guild_data.ephemeral_confirmations = false;
-    guild_data.commit_changes(&ctx.data().database).await;
-
-    ctx.send(
-        CreateReply::default().ephemeral(true).embed(
-            CreateEmbed::new()
-                .title("Confirmations public")
-                .description(concat!(
-                    "Reminder confirmations will be sent as regular messages, and won't be ",
-                    "removed automatically."
-                ))
-                .color(*THEME_COLOR),
-        ),
-    )
-    .await?;
-
-    Ok(())
-}

src/commands/timer/delete.rs

@@ -0,0 +1,65 @@
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options {
+    name: String,
+}
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
+
+        let exists = sqlx::query!(
+            "
+            SELECT 1 as _r
+            FROM timers
+            WHERE owner = ?
+                AND name = ?
+            ",
+            owner,
+            self.name
+        )
+        .fetch_one(&ctx.data().database)
+        .await;
+
+        if exists.is_ok() {
+            sqlx::query!(
+                "
+                DELETE FROM timers
+                WHERE owner = ?
+                    AND name = ?
+                ",
+                owner,
+                self.name
+            )
+            .execute(&ctx.data().database)
+            .await
+            .unwrap();
+
+            ctx.say("Deleted a timer").await?;
+        } else {
+            ctx.say("Could not find a timer by that name").await?;
+        }
+
+        Ok(())
+    }
+}
+
+/// Delete a timer
+#[poise::command(
+    slash_command,
+    rename = "delete",
+    identifying_name = "delete_timer",
+    default_member_permissions = "MANAGE_GUILD"
+)]
+pub async fn delete(
+    ctx: Context<'_>,
+    #[description = "Name of timer to delete"] name: String,
+) -> Result<(), Error> {
+    (Options { name }).run(ctx).await
+}

src/commands/timer/delete_timer.rs

@@ -1,33 +0,0 @@
-use crate::{Context, Error};
-
-/// Delete a timer
-#[poise::command(
-    slash_command,
-    rename = "delete",
-    identifying_name = "delete_timer",
-    default_member_permissions = "MANAGE_GUILD"
-)]
-pub async fn delete_timer(
-    ctx: Context<'_>,
-    #[description = "Name of timer to delete"] name: String,
-) -> Result<(), Error> {
-    let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
-
-    let exists =
-        sqlx::query!("SELECT 1 as _r FROM timers WHERE owner = ? AND name = ?", owner, name)
-            .fetch_one(&ctx.data().database)
-            .await;
-
-    if exists.is_ok() {
-        sqlx::query!("DELETE FROM timers WHERE owner = ? AND name = ?", owner, name)
-            .execute(&ctx.data().database)
-            .await
-            .unwrap();
-
-        ctx.say("Deleted a timer").await?;
-    } else {
-        ctx.say("Could not find a timer by that name").await?;
-    }
-
-    Ok(())
-}

src/commands/timer/list.rs

@@ -0,0 +1,64 @@
+use chrono::{DateTime, Utc};
+use num_integer::Integer;
+use poise::{serenity_prelude::CreateEmbed, CreateReply};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    consts::THEME_COLOR,
+    models::timer::Timer,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+fn time_difference(start_time: DateTime<Utc>) -> String {
+    let delta = (Utc::now() - start_time).num_seconds();
+
+    let (minutes, seconds) = delta.div_rem(&60);
+    let (hours, minutes) = minutes.div_rem(&60);
+    let (days, hours) = hours.div_rem(&24);
+
+    format!("{} days, {:02}:{:02}:{:02}", days, hours, minutes, seconds)
+}
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
+
+        let timers = Timer::from_owner(owner, &ctx.data().database).await;
+
+        if !timers.is_empty() {
+            ctx.send(
+                CreateReply::default().embed(
+                    CreateEmbed::new()
+                        .fields(timers.iter().map(|timer| {
+                            (
+                                &timer.name,
+                                format!("⌚ `{}`", time_difference(timer.start_time)),
+                                false,
+                            )
+                        }))
+                        .color(*THEME_COLOR),
+                ),
+            )
+            .await?;
+        } else {
+            ctx.say("No timers currently. Use `/timer start` to create a new timer").await?;
+        }
+
+        Ok(())
+    }
+}
+
+/// List the timers in this server or DM channel
+#[poise::command(
+    slash_command,
+    rename = "list",
+    identifying_name = "list_timer",
+    default_member_permissions = "MANAGE_GUILD"
+)]
+pub async fn list(ctx: Context<'_>) -> Result<(), Error> {
+    (Options {}).run(ctx).await
+}

src/commands/timer/list_timer.rs

@@ -1,45 +0,0 @@
-use chrono::{DateTime, Utc};
-use num_integer::Integer;
-use poise::{serenity_prelude::CreateEmbed, CreateReply};
-
-use crate::{consts::THEME_COLOR, models::timer::Timer, Context, Error};
-
-fn time_difference(start_time: DateTime<Utc>) -> String {
-    let delta = (Utc::now() - start_time).num_seconds();
-
-    let (minutes, seconds) = delta.div_rem(&60);
-    let (hours, minutes) = minutes.div_rem(&60);
-    let (days, hours) = hours.div_rem(&24);
-
-    format!("{} days, {:02}:{:02}:{:02}", days, hours, minutes, seconds)
-}
-
-/// List the timers in this server or DM channel
-#[poise::command(
-    slash_command,
-    rename = "list",
-    identifying_name = "list_timer",
-    default_member_permissions = "MANAGE_GUILD"
-)]
-pub async fn list_timer(ctx: Context<'_>) -> Result<(), Error> {
-    let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
-
-    let timers = Timer::from_owner(owner, &ctx.data().database).await;
-
-    if !timers.is_empty() {
-        ctx.send(
-            CreateReply::default().embed(
-                CreateEmbed::new()
-                    .fields(timers.iter().map(|timer| {
-                        (&timer.name, format!("⌚ `{}`", time_difference(timer.start_time)), false)
-                    }))
-                    .color(*THEME_COLOR),
-            ),
-        )
-        .await?;
-    } else {
-        ctx.say("No timers currently. Use `/timer start` to create a new timer").await?;
-    }
-
-    Ok(())
-}

src/commands/timer/mod.rs

@@ -1,6 +1,6 @@
-pub mod delete_timer;
-pub mod list_timer;
-pub mod start_timer;
+pub mod delete;
+pub mod list;
+pub mod start;
 
 use crate::{Context, Error};
 

src/commands/timer/start.rs

@@ -0,0 +1,53 @@
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    models::timer::Timer,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options {
+    name: String,
+}
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
+
+        let count = Timer::count_from_owner(owner, &ctx.data().database).await;
+
+        if count >= 25 {
+            ctx.say(
+                "You already have 25 timers. Please delete some timers before creating a new one",
+            )
+            .await?;
+        } else if self.name.len() <= 32 {
+            Timer::create(&self.name, owner, &ctx.data().database).await;
+
+            ctx.say("Created a new timer").await?;
+        } else {
+            ctx.say(format!(
+                "Please name your timer something shorted (max. 32 characters, you used {})",
+                self.name.len()
+            ))
+            .await?;
+        }
+
+        Ok(())
+    }
+}
+
+/// Start a new timer from now
+#[poise::command(
+    slash_command,
+    rename = "start",
+    identifying_name = "start_timer",
+    default_member_permissions = "MANAGE_GUILD"
+)]
+pub async fn start(
+    ctx: Context<'_>,
+    #[description = "Name for the new timer"] name: String,
+) -> Result<(), Error> {
+    (Options { name }).run(ctx).await
+}

src/commands/timer/start_timer.rs

@@ -1,34 +0,0 @@
-use crate::{models::timer::Timer, Context, Error};
-
-/// Start a new timer from now
-#[poise::command(
-    slash_command,
-    rename = "start",
-    identifying_name = "start_timer",
-    default_member_permissions = "MANAGE_GUILD"
-)]
-pub async fn start_timer(
-    ctx: Context<'_>,
-    #[description = "Name for the new timer"] name: String,
-) -> Result<(), Error> {
-    let owner = ctx.guild_id().map(|g| g.get()).unwrap_or_else(|| ctx.author().id.get());
-
-    let count = Timer::count_from_owner(owner, &ctx.data().database).await;
-
-    if count >= 25 {
-        ctx.say("You already have 25 timers. Please delete some timers before creating a new one")
-            .await?;
-    } else if name.len() <= 32 {
-        Timer::create(&name, owner, &ctx.data().database).await;
-
-        ctx.say("Created a new timer").await?;
-    } else {
-        ctx.say(format!(
-            "Please name your timer something shorted (max. 32 characters, you used {})",
-            name.len()
-        ))
-        .await?;
-    }
-
-    Ok(())
-}

src/commands/todo/channel/add.rs

@@ -1,4 +1,43 @@
-use crate::{models::CtxData, Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    models::CtxData,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options {
+    task: String,
+}
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        // ensure channel is cached
+        ctx.channel_data().await?;
+
+        sqlx::query!(
+            "
+            INSERT INTO todos (guild_id, channel_id, value)
+            VALUES (
+                (SELECT id FROM guilds WHERE guild = ?),
+                (SELECT id FROM channels WHERE channel = ?),
+                ?
+            )
+            ",
+            ctx.guild_id().unwrap().get(),
+            ctx.channel_id().get(),
+            self.task
+        )
+        .execute(&ctx.data().database)
+        .await
+        .unwrap();
+
+        ctx.say("Item added to todo list").await?;
+
+        Ok(())
+    }
+}
 
 /// Add an item to the channel todo list
 #[poise::command(
@@ -12,27 +51,5 @@ pub async fn add(
     ctx: Context<'_>,
     #[description = "The task to add to the todo list"] task: String,
 ) -> Result<(), Error> {
-    // ensure channel is cached
-    let _ = ctx.channel_data().await;
-
-    sqlx::query!(
-        "
-        INSERT INTO todos (guild_id, channel_id, value)
-        VALUES (
-            (SELECT id FROM guilds WHERE guild = ?),
-            (SELECT id FROM channels WHERE channel = ?),
-            ?
-        )
-        ",
-        ctx.guild_id().unwrap().get(),
-        ctx.channel_id().get(),
-        task
-    )
-    .execute(&ctx.data().database)
-    .await
-    .unwrap();
-
-    ctx.say("Item added to todo list").await?;
-
-    Ok(())
+    (Options { task }).run(ctx).await
 }

src/commands/todo/channel/view.rs

@@ -1,4 +1,44 @@
-use crate::{commands::todo::show_todo_page, Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    commands::todo::show_todo_page,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let values = sqlx::query!(
+            "
+            SELECT todos.id, value FROM todos
+            INNER JOIN channels ON todos.channel_id = channels.id
+            WHERE channels.channel = ?
+            ",
+            ctx.channel_id().get(),
+        )
+        .fetch_all(&ctx.data().database)
+        .await
+        .unwrap()
+        .iter()
+        .map(|row| (row.id as usize, row.value.clone()))
+        .collect::<Vec<(usize, String)>>();
+
+        let resp = show_todo_page(
+            &values,
+            0,
+            None,
+            Some(ctx.channel_id().get()),
+            ctx.guild_id().map(|g| g.get()),
+        );
+
+        ctx.send(resp).await?;
+
+        Ok(())
+    }
+}
 
 /// View and remove from the channel todo list
 #[poise::command(
@@ -9,30 +49,5 @@ use crate::{commands::todo::show_todo_page, Context, Error};
     default_member_permissions = "MANAGE_GUILD"
 )]
 pub async fn view(ctx: Context<'_>) -> Result<(), Error> {
-    let values = sqlx::query!(
-        "
-        SELECT todos.id, value FROM todos
-        INNER JOIN channels ON todos.channel_id = channels.id
-        WHERE channels.channel = ?
-        ",
-        ctx.channel_id().get(),
-    )
-    .fetch_all(&ctx.data().database)
-    .await
-    .unwrap()
-    .iter()
-    .map(|row| (row.id as usize, row.value.clone()))
-    .collect::<Vec<(usize, String)>>();
-
-    let resp = show_todo_page(
-        &values,
-        0,
-        None,
-        Some(ctx.channel_id().get()),
-        ctx.guild_id().map(|g| g.get()),
-    );
-
-    ctx.send(resp).await?;
-
-    Ok(())
+    (Options {}).run(ctx).await
 }

src/commands/todo/guild/add.rs

@@ -1,4 +1,36 @@
-use crate::{Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options {
+    task: String,
+}
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        sqlx::query!(
+            "
+            INSERT INTO todos (guild_id, value)
+            VALUES (
+                (SELECT id FROM guilds WHERE guild = ?), ?
+            )
+            ",
+            ctx.guild_id().unwrap().get(),
+            self.task
+        )
+        .execute(&ctx.data().database)
+        .await
+        .unwrap();
+
+        ctx.say("Item added to todo list").await?;
+
+        Ok(())
+    }
+}
 
 /// Add an item to the server todo list
 #[poise::command(
@@ -12,20 +44,5 @@ pub async fn add(
     ctx: Context<'_>,
     #[description = "The task to add to the todo list"] task: String,
 ) -> Result<(), Error> {
-    sqlx::query!(
-        "
-        INSERT INTO todos (guild_id, value)
-        VALUES (
-            (SELECT id FROM guilds WHERE guild = ?), ?
-        )",
-        ctx.guild_id().unwrap().get(),
-        task
-    )
-    .execute(&ctx.data().database)
-    .await
-    .unwrap();
-
-    ctx.say("Item added to todo list").await?;
-
-    Ok(())
+    (Options { task }).run(ctx).await
 }

src/commands/todo/guild/view.rs

@@ -1,4 +1,38 @@
-use crate::{commands::todo::show_todo_page, Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    commands::todo::show_todo_page,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let values = sqlx::query!(
+            "
+            SELECT todos.id, value FROM todos
+            INNER JOIN guilds ON todos.guild_id = guilds.id
+            WHERE guilds.guild = ?
+            ",
+            ctx.guild_id().unwrap().get(),
+        )
+        .fetch_all(&ctx.data().database)
+        .await
+        .unwrap()
+        .iter()
+        .map(|row| (row.id as usize, row.value.clone()))
+        .collect::<Vec<(usize, String)>>();
+
+        let resp = show_todo_page(&values, 0, None, None, ctx.guild_id().map(|g| g.get()));
+
+        ctx.send(resp).await?;
+
+        Ok(())
+    }
+}
 
 /// View and remove from the server todo list
 #[poise::command(
@@ -9,24 +43,5 @@ use crate::{commands::todo::show_todo_page, Context, Error};
     default_member_permissions = "MANAGE_GUILD"
 )]
 pub async fn view(ctx: Context<'_>) -> Result<(), Error> {
-    let values = sqlx::query!(
-        "
-        SELECT todos.id, value FROM todos
-        INNER JOIN guilds ON todos.guild_id = guilds.id
-        WHERE guilds.guild = ?
-        ",
-        ctx.guild_id().unwrap().get(),
-    )
-    .fetch_all(&ctx.data().database)
-    .await
-    .unwrap()
-    .iter()
-    .map(|row| (row.id as usize, row.value.clone()))
-    .collect::<Vec<(usize, String)>>();
-
-    let resp = show_todo_page(&values, 0, None, None, ctx.guild_id().map(|g| g.get()));
-
-    ctx.send(resp).await?;
-
-    Ok(())
+    (Options {}).run(ctx).await
 }

src/commands/todo/user/add.rs

@@ -1,4 +1,37 @@
-use crate::{Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options {
+    task: String,
+}
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        sqlx::query!(
+            "
+            INSERT INTO todos (user_id, value)
+            VALUES (
+                (SELECT id FROM users WHERE user = ?),
+                ?
+            )
+            ",
+            ctx.author().id.get(),
+            self.task
+        )
+        .execute(&ctx.data().database)
+        .await
+        .unwrap();
+
+        ctx.say("Item added to todo list").await?;
+
+        Ok(())
+    }
+}
 
 /// Add an item to your personal todo list
 #[poise::command(slash_command, rename = "add", identifying_name = "todo_user_add")]
@@ -6,22 +39,5 @@ pub async fn add(
     ctx: Context<'_>,
     #[description = "The task to add to the todo list"] task: String,
 ) -> Result<(), Error> {
-    sqlx::query!(
-        "
-        INSERT INTO todos (user_id, value)
-        VALUES (
-            (SELECT id FROM users WHERE user = ?),
-            ?
-        )
-        ",
-        ctx.author().id.get(),
-        task
-    )
-    .execute(&ctx.data().database)
-    .await
-    .unwrap();
-
-    ctx.say("Item added to todo list").await?;
-
-    Ok(())
+    (Options { task }).run(ctx).await
 }

src/commands/todo/user/view.rs

@@ -1,26 +1,41 @@
-use crate::{commands::todo::show_todo_page, Context, Error};
+use serde::{Deserialize, Serialize};
+
+use crate::{
+    commands::todo::show_todo_page,
+    utils::{Extract, Recordable},
+    Context, Error,
+};
+
+#[derive(Serialize, Deserialize, Extract)]
+pub struct Options;
+
+impl Recordable for Options {
+    async fn run(self, ctx: Context<'_>) -> Result<(), Error> {
+        let values = sqlx::query!(
+            "
+            SELECT todos.id, value FROM todos
+            INNER JOIN users ON todos.user_id = users.id
+            WHERE users.user = ?
+            ",
+            ctx.author().id.get(),
+        )
+        .fetch_all(&ctx.data().database)
+        .await
+        .unwrap()
+        .iter()
+        .map(|row| (row.id as usize, row.value.clone()))
+        .collect::<Vec<(usize, String)>>();
+
+        let resp = show_todo_page(&values, 0, Some(ctx.author().id.get()), None, None);
+
+        ctx.send(resp).await?;
+
+        Ok(())
+    }
+}
 
 /// View and remove from your personal todo list
 #[poise::command(slash_command, rename = "view", identifying_name = "todo_user_view")]
 pub async fn view(ctx: Context<'_>) -> Result<(), Error> {
-    let values = sqlx::query!(
-        "
-        SELECT todos.id, value FROM todos
-        INNER JOIN users ON todos.user_id = users.id
-        WHERE users.user = ?
-        ",
-        ctx.author().id.get(),
-    )
-    .fetch_all(&ctx.data().database)
-    .await
-    .unwrap()
-    .iter()
-    .map(|row| (row.id as usize, row.value.clone()))
-    .collect::<Vec<(usize, String)>>();
-
-    let resp = show_todo_page(&values, 0, Some(ctx.author().id.get()), None, None);
-
-    ctx.send(resp).await?;
-
-    Ok(())
+    (Options {}).run(ctx).await
 }