Merge pull request #255 from Rustmail/212-snippets

feat(snippets): add commands for snippet feature

Author: Akinator31

.gitignore

@@ -3,7 +3,7 @@ config.toml
 config.toml.backup
 node_modules
 .env
-db/
+/db/
 .idea
 .vscode/
 package-lock.json

.sqlx/query-0d8e91df51026f5a3400697b0797c60424475d42fec68d891852cecc41e15c0a.json

@@ -0,0 +1,11 @@
+-- Add migration script here
+CREATE TABLE IF NOT EXISTS "snippets" (
+    "id" INTEGER PRIMARY KEY AUTOINCREMENT,
+    "key" TEXT NOT NULL UNIQUE,
+    "content" TEXT NOT NULL,
+    "created_by" TEXT NOT NULL,
+    "created_at" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updated_at" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+
+CREATE INDEX IF NOT EXISTS "idx_snippets_key" ON "snippets"("key");

.sqlx/query-2b110957c98cd482afcc93eba2762c7229a0d4b04387acf03179c7449054a58a.json

@@ -144,6 +144,7 @@ pub async fn run_bot(
     registry.register_command(TakeCommand);
     registry.register_command(ReleaseCommand);
     registry.register_command(PingCommand);
+    registry.register_command(SnippetCommand);
 
     let registry = Arc::new(registry);
 

.sqlx/query-68cdb069424b9fdd6468b28d8cdf9b5c2aa49cc2bb3ac886496adb0e220bf431.json

@@ -21,24 +21,29 @@ pub async fn anonreply(
         .as_ref()
         .ok_or_else(database_connection_failed)?;
 
-    let content = extract_reply_content(&msg.content, &config.command.prefix, &["anonreply", "ar"]);
+    let mut content =
+        extract_reply_content(&msg.content, &config.command.prefix, &["anonreply", "ar"]);
+
+    if let Some(text) = &content {
+        if let Some(stripped) = text.strip_prefix("{{").and_then(|s| s.strip_suffix("}}")) {
+            let snippet_key = stripped.trim();
+            match get_snippet_by_key(snippet_key, db_pool).await? {
+                Some(snippet) => {
+                    content = Some(snippet.content);
+                }
+                None => {
+                    return Err(ModmailError::Command(CommandError::SnippetNotFound(
+                        snippet_key.to_string(),
+                    )));
+                }
+            }
+        }
+    }
+
     let intent = extract_intent(content, &msg.attachments).await;
 
     let Some(intent) = intent else {
-        MessageBuilder::system_message(&ctx, config)
-            .translated_content(
-                "reply.missing_content",
-                None,
-                Some(msg.author.id),
-                msg.guild_id.map(|g| g.get()),
-            )
-            .await
-            .color(0xFF0000)
-            .reply_to(msg.clone())
-            .send_and_forget()
-            .await;
-
-        return Err(validation_failed("Missing content"));
+        return Err(ModmailError::Message(MessageError::MessageEmpty));
     };
 
     let thread = fetch_thread(db_pool, &msg.channel_id.to_string()).await?;

.sqlx/query-6cf54c26731b1dd92650445bac0850548928cbfa6501788cd1c3b6d8b3fd6b19.json

@@ -28,6 +28,7 @@ pub mod release;
 pub mod remove_reminder;
 pub mod remove_staff;
 pub mod reply;
+pub mod snippet;
 pub mod take;
 
 pub use add_reminder::*;
@@ -49,6 +50,7 @@ pub use release::*;
 pub use remove_reminder::*;
 pub use remove_staff::*;
 pub use reply::*;
+pub use snippet::*;
 pub use take::*;
 
 pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;