diff options
Diffstat (limited to 'src/events/app/events.rs')
| -rw-r--r-- | src/events/app/events.rs | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/events/app/events.rs b/src/events/app/events.rs index a8814c9..8b76994 100644 --- a/src/events/app/events.rs +++ b/src/events/app/events.rs @@ -9,7 +9,10 @@ use sqlx::sqlite::SqlitePool; use super::Broadcaster; use crate::{ clock::DateTime, - events::repo::broadcast::{self, Provider as _}, + events::{ + app::EventsError, + repo::broadcast::{self, Provider as _}, + }, repo::{ channel::{self, Provider as _}, error::NotFound as _, @@ -33,7 +36,7 @@ impl<'a> Events<'a> { channel: &channel::Id, body: &str, sent_at: &DateTime, - ) -> Result<broadcast::Message, EventsError> { + ) -> Result<broadcast::Message, Error> { let mut tx = self.db.begin().await?; let channel = tx .channels() @@ -55,7 +58,7 @@ impl<'a> Events<'a> { channel: &channel::Id, subscribed_at: &DateTime, resume_at: Option<broadcast::Sequence>, - ) -> Result<impl Stream<Item = broadcast::Message> + std::fmt::Debug, EventsError> { + ) -> Result<impl Stream<Item = broadcast::Message> + std::fmt::Debug, Error> { // Somewhat arbitrarily, expire after 90 days. let expire_at = subscribed_at.to_owned() - TimeDelta::days(90); @@ -130,7 +133,7 @@ impl<'a> Events<'a> { } #[derive(Debug, thiserror::Error)] -pub enum EventsError { +pub enum Error { #[error("channel {0} not found")] ChannelNotFound(channel::Id), #[error(transparent)] |
