1 files changed, 51 insertions, 1 deletions
diff --git a/src/repo/channel.rs b/src/repo/channel.rs
index 6514426..3c7468f 100644
--- a/src/repo/channel.rs
+++ b/src/repo/channel.rs
@@ -2,7 +2,11 @@ use std::fmt;
 
 use sqlx::{sqlite::Sqlite, SqliteConnection, Transaction};
 
-use crate::{clock::DateTime, events::types::Sequence, id::Id as BaseId};
+use crate::{
+    clock::DateTime,
+    events::types::{self, Sequence},
+    id::Id as BaseId,
+};
 
 pub trait Provider {
     fn channels(&mut self) -> Channels;
@@ -91,6 +95,52 @@ impl<'c> Channels<'c> {
 
         Ok(channels)
     }
+
+    pub async fn delete_expired(
+        &mut self,
+        channel: &Channel,
+        sequence: Sequence,
+        deleted_at: &DateTime,
+    ) -> Result<types::ChannelEvent, sqlx::Error> {
+        let channel = channel.id.clone();
+        sqlx::query_scalar!(
+            r#"
+                delete from channel
+                where id = $1
+                returning 1 as "row: i64"
+            "#,
+            channel,
+        )
+        .fetch_one(&mut *self.0)
+        .await?;
+
+        Ok(types::ChannelEvent {
+            sequence,
+            at: *deleted_at,
+            data: types::DeletedEvent { channel }.into(),
+        })
+    }
+
+    pub async fn expired(&mut self, expired_at: &DateTime) -> Result<Vec<Channel>, sqlx::Error> {
+        let channels = sqlx::query_as!(
+            Channel,
+            r#"
+                select
+                    channel.id as "id: Id",
+                    channel.name,
+                    channel.created_at as "created_at: DateTime"
+                from channel
+                    left join message
+                where created_at < $1
+                    and message.id is null
+            "#,
+            expired_at,
+        )
+        .fetch_all(&mut *self.0)
+        .await?;
+
+        Ok(channels)
+    }
 }
 
 // Stable identifier for a [Channel]. Prefixed with `C`.