diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2024-09-25 01:27:05 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2024-09-25 02:16:04 -0400 |
| commit | 452c8d0d9edb9894c108b6d577806c7c9d0071dd (patch) | |
| tree | 1857a7409fe9e5e8c724ff7a04112c57ed3de92c /src/events/app/events.rs | |
| parent | 697e90f291cec1bbd89965c2731f9481ec4507c4 (diff) | |
Crank up the Clippy warnings.
This'll catch style issues, mostly.
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)] |
