From 6a10fcaf64938da52b326ea80013d9f30ed62a6c Mon Sep 17 00:00:00 2001
From: Owen Jacobson <owen@grimoire.ca>
Date: Sat, 5 Oct 2024 22:42:43 -0400
Subject: Separate `/api/boot` into its own module.

---
 src/message/app.rs | 27 ---------------------------
 1 file changed, 27 deletions(-)

(limited to 'src/message/app.rs')

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?;
-- 
cgit v1.2.3