shockrah/freechat
shockrah/freechat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added delete method for messages

Browse Source
This commit is contained in:
shockrah 2020-09-17 21:54:54 -07:00
parent 2642fdb8b3
commit 65532def98
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
server-api/db/src/member.rs
View File

@ -66,7 +66,6 @@ impl FromDB<Member> for Member {
if let Ok(conn) = p.get_conn().await { if let Ok(conn) = p.get_conn().await {
match Member::get(p, row.id).await { match Member::get(p, row.id).await {
Response::Row(_) => { Response::Row(_) => {
// update now
let db_result: Result<Conn, SqlError> let db_result: Result<Conn, SqlError>
= conn.drop_exec(q, params!{ = conn.drop_exec(q, params!{
"id" => row.id, "id" => row.id,

11
server-api/db/src/messages.rs
View File

@ -62,6 +62,15 @@ impl FromDB<Message> for Message {
} }
async fn delete(p: &Pool, id: UBigInt) -> Response<Self> { 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"))
} }
} }