From 65532def985a0dfe83ad772d34ddb71a87ddcef8 Mon Sep 17 00:00:00 2001
From: shockrah <alejandros714@protonmail.com>
Date: Thu, 17 Sep 2020 21:54:54 -0700
Subject: [PATCH] added delete method for messages

---
 server-api/db/src/member.rs   |  1 -
 server-api/db/src/messages.rs | 11 ++++++++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/server-api/db/src/member.rs b/server-api/db/src/member.rs
index 23caaf1..bb443a9 100644
--- a/server-api/db/src/member.rs
+++ b/server-api/db/src/member.rs
@@ -66,7 +66,6 @@ impl FromDB<Member> for Member {
         if let Ok(conn) = p.get_conn().await {
             match Member::get(p, row.id).await {
                 Response::Row(_) => {
-                    // update now
                     let db_result: Result<Conn, SqlError>
                         = conn.drop_exec(q, params!{
                             "id" => row.id,
diff --git a/server-api/db/src/messages.rs b/server-api/db/src/messages.rs
index 4f23bd5..1a81109 100644
--- a/server-api/db/src/messages.rs
+++ b/server-api/db/src/messages.rs
@@ -62,6 +62,15 @@ impl FromDB<Message> for Message {
     }
 
     async fn delete(p: &Pool, id: UBigInt) -> Response<Self> {
-        unimplemented!()
+        if let Ok(conn) = p.get_conn().await {
+            let q = "DELETE FROM messages WHERE id = :id";
+            let result: Result<Conn, SqlError> =
+                conn.drop_exec(q, params!{"id" => id}).await;
+            return match result {
+                Ok(_) => Response::Success,
+                Err(_) => Response::Other(sql_err!("Message::FromDB::delete"))
+            }
+        }
+        return Response::Other(no_conn!("Message::FromDB::update"))
     }
 }