summaryrefslogtreecommitdiff
path: root/src/message/repo.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/message/repo.rs')
-rw-r--r--src/message/repo.rs10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/message/repo.rs b/src/message/repo.rs
index 2e9700a..83bf0d5 100644
--- a/src/message/repo.rs
+++ b/src/message/repo.rs
@@ -180,17 +180,15 @@ impl Messages<'_> {
pub async fn delete(
&mut self,
- message: &History,
+ message: &Message,
deleted: &Instant,
) -> Result<History, sqlx::Error> {
- let id = message.id();
-
sqlx::query!(
r#"
insert into message_deleted (id, deleted_at, deleted_sequence)
values ($1, $2, $3)
"#,
- id,
+ message.id,
deleted.at,
deleted.sequence,
)
@@ -209,12 +207,12 @@ impl Messages<'_> {
returning id as "id: Id"
"#,
deleted.sequence,
- id,
+ message.id,
)
.fetch_one(&mut *self.0)
.await?;
- let message = self.by_id(id).await?;
+ let message = self.by_id(&message.id).await?;
Ok(message)
}