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 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.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 for Message { } async fn delete(p: &Pool, id: UBigInt) -> Response { - unimplemented!() + if let Ok(conn) = p.get_conn().await { + let q = "DELETE FROM messages WHERE id = :id"; + let result: Result = + 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")) } }