1 files changed, 11 insertions, 5 deletions
diff --git a/src/message/app.rs b/src/message/app.rs
index 3c74628..9792c8f 100644
--- a/src/message/app.rs
+++ b/src/message/app.rs
@@ -29,13 +29,17 @@ impl<'a> Messages<'a> {
         sent_at: &DateTime,
         body: &Body,
     ) -> Result<Message, SendError> {
+        let to_not_found = || SendError::ChannelNotFound(channel.clone());
+        let to_deleted = || SendError::ChannelDeleted(channel.clone());
+
         let mut tx = self.db.begin().await?;
-        let channel = tx
-            .channels()
-            .by_id(channel)
-            .await
-            .not_found(|| SendError::ChannelNotFound(channel.clone()))?;
+        let channel = tx.channels().by_id(channel).await.not_found(to_not_found)?;
+
+        // Ordering: don't bother allocating a sequence number before we know the channel might
+        // exist.
         let sent = tx.sequence().next(sent_at).await?;
+        let channel = channel.as_of(sent).ok_or_else(to_deleted)?;
+
         let message = tx.messages().create(&channel, sender, &sent, body).await?;
         tx.commit().await?;
 
@@ -126,6 +130,8 @@ impl<'a> Messages<'a> {
 pub enum SendError {
     #[error("channel {0} not found")]
     ChannelNotFound(channel::Id),
+    #[error("channel {0} deleted")]
+    ChannelDeleted(channel::Id),
     #[error(transparent)]
     Database(#[from] sqlx::Error),
     #[error(transparent)]