Tests for purged channels and messages.

This required a re-think of the `.immediately()` combinator, to generalize it to cases where a message is _not_ expected. That (more or less immediately) suggested some mixed combinators, particularly for stream futures (futures of `Option<T>`).

1 files changed, 6 insertions, 4 deletions

diff --git a/src/channel/app.rs b/src/channel/app.rs
index 7bfa0f7..8359277 100644
--- a/src/channel/app.rs
+++ b/src/channel/app.rs
@@ -4,7 +4,7 @@ use sqlx::sqlite::SqlitePool;
 
 use super::{
     repo::{LoadError, Provider as _},
-    Channel, History, Id,
+    Channel, Id,
 };
 use crate::{
     clock::DateTime,
@@ -42,12 +42,14 @@ impl<'a> Channels<'a> {
 
     // This function is careless with respect to time, and gets you the channel as
     // it exists in the specific moment when you call it.
-    pub async fn get(&self, channel: &Id) -> Result<Option<Channel>, Error> {
+    pub async fn get(&self, channel: &Id) -> Result<Channel, Error> {
+        let not_found = || Error::NotFound(channel.clone());
+
         let mut tx = self.db.begin().await?;
-        let channel = tx.channels().by_id(channel).await.optional()?;
+        let channel = tx.channels().by_id(channel).await.not_found(not_found)?;
         tx.commit().await?;
 
-        Ok(channel.as_ref().and_then(History::as_snapshot))
+        channel.as_snapshot().ok_or_else(not_found)
     }
 
     pub async fn delete(&self, channel: &Id, deleted_at: &DateTime) -> Result<(), Error> {