diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2024-10-05 22:42:43 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2024-10-05 22:47:12 -0400 |
| commit | 6a10fcaf64938da52b326ea80013d9f30ed62a6c (patch) | |
| tree | 08a3860b68391514390f42872ccc1cb4c6e6afd2 /src/message/app.rs | |
| parent | 1fb26ad31d385ddc628e1b73d6a8764981ca6885 (diff) | |
Separate `/api/boot` into its own module.
Diffstat (limited to 'src/message/app.rs')
| -rw-r--r-- | src/message/app.rs | 27 |
1 files changed, 0 insertions, 27 deletions
diff --git a/src/message/app.rs b/src/message/app.rs index 1e50a65..385c92e 100644 --- a/src/message/app.rs +++ b/src/message/app.rs @@ -44,33 +44,6 @@ impl<'a> Messages<'a> { Ok(message.as_sent()) } - pub async fn in_channel( - &self, - channel: &channel::Id, - resume_point: Option<Sequence>, - ) -> Result<Vec<Message>, DeleteError> { - let mut tx = self.db.begin().await?; - let channel = tx - .channels() - .by_id(channel) - .await - .not_found(|| DeleteError::ChannelNotFound(channel.clone()))?; - let messages = tx.messages().in_channel(&channel, resume_point).await?; - tx.commit().await?; - - let messages = messages - .into_iter() - .filter_map(|message| { - message - .events() - .filter(Sequence::up_to(resume_point)) - .collect() - }) - .collect(); - - Ok(messages) - } - pub async fn delete(&self, message: &Id, deleted_at: &DateTime) -> Result<(), DeleteError> { let mut tx = self.db.begin().await?; let deleted = tx.sequence().next(deleted_at).await?; |
