1 files changed, 0 insertions, 136 deletions
diff --git a/src/channel/repo/messages.rs b/src/channel/repo/messages.rs
deleted file mode 100644
index a30e6da..0000000
--- a/src/channel/repo/messages.rs
+++ /dev/null
@@ -1,136 +0,0 @@
-use std::fmt;
-
-use sqlx::{sqlite::Sqlite, SqliteConnection, Transaction};
-
-use super::channels::Id as ChannelId;
-use crate::{
-    clock::DateTime,
-    id::Id as BaseId,
-    login::repo::logins::{Id as LoginId, Login, Logins},
-};
-
-pub trait Provider {
-    fn messages(&mut self) -> Messages;
-}
-
-impl<'c> Provider for Transaction<'c, Sqlite> {
-    fn messages(&mut self) -> Messages {
-        Messages(self)
-    }
-}
-
-pub struct Messages<'t>(&'t mut SqliteConnection);
-
-#[derive(Clone, Debug, serde::Serialize)]
-pub struct BroadcastMessage {
-    pub id: Id,
-    pub sender: Login,
-    pub body: String,
-    pub sent_at: DateTime,
-}
-
-impl<'c> Messages<'c> {
-    pub async fn create(
-        &mut self,
-        sender: &LoginId,
-        channel: &ChannelId,
-        body: &str,
-        sent_at: &DateTime,
-    ) -> Result<BroadcastMessage, sqlx::Error> {
-        let id = Id::generate();
-
-        let sender = Logins::from(&mut *self.0).by_id(sender).await?;
-
-        let message = sqlx::query!(
-            r#"
-                insert into message
-                    (id, sender, channel, body, sent_at)
-                values ($1, $2, $3, $4, $5)
-                returning
-                    id as "id: Id",
-                    sender as "sender: LoginId",
-                    body,
-                    sent_at as "sent_at: DateTime"
-            "#,
-            id,
-            sender.id,
-            channel,
-            body,
-            sent_at,
-        )
-        .map(|row| {
-            debug_assert!(row.sender == sender.id);
-            BroadcastMessage {
-                id: row.id,
-                sender: sender.clone(),
-                body: row.body,
-                sent_at: row.sent_at,
-            }
-        })
-        .fetch_one(&mut *self.0)
-        .await?;
-
-        Ok(message)
-    }
-
-    pub async fn for_replay(
-        &mut self,
-        channel: &ChannelId,
-        resume_at: Option<&DateTime>,
-    ) -> Result<Vec<BroadcastMessage>, sqlx::Error> {
-        let messages = sqlx::query!(
-            r#"
-                select
-                    message.id as "id: Id",
-                    login.id as "sender_id: LoginId",
-                    login.name as sender_name,
-                    message.body,
-                    message.sent_at as "sent_at: DateTime"
-                from message
-                    join login on message.sender = login.id
-                where channel = $1
-                    and coalesce(sent_at > $2, true)
-                order by sent_at asc
-            "#,
-            channel,
-            resume_at,
-        )
-        .map(|row| BroadcastMessage {
-            id: row.id,
-            sender: Login {
-                id: row.sender_id,
-                name: row.sender_name,
-            },
-            body: row.body,
-            sent_at: row.sent_at,
-        })
-        .fetch_all(&mut *self.0)
-        .await?;
-
-        Ok(messages)
-    }
-}
-
-/// Stable identifier for a [Message]. Prefixed with `M`.
-#[derive(Clone, Debug, Eq, Hash, PartialEq, sqlx::Type, serde::Deserialize, serde::Serialize)]
-#[sqlx(transparent)]
-#[serde(transparent)]
-pub struct Id(BaseId);
-
-impl From<BaseId> for Id {
-    fn from(id: BaseId) -> Self {
-        Self(id)
-    }
-}
-
-impl Id {
-    pub fn generate() -> Self {
-        BaseId::generate("M")
-    }
-}
-
-impl fmt::Display for Id {
-    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-        self.0.fmt(f)
-    }
-}