summaryrefslogtreecommitdiff
path: root/src/events/app
diff options
context:
space:
mode:
Diffstat (limited to 'src/events/app')
-rw-r--r--src/events/app/events.rs11
-rw-r--r--src/events/app/mod.rs2
2 files changed, 8 insertions, 5 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)]
diff --git a/src/events/app/mod.rs b/src/events/app/mod.rs
index 03a7da2..f364e00 100644
--- a/src/events/app/mod.rs
+++ b/src/events/app/mod.rs
@@ -2,4 +2,4 @@ mod broadcaster;
mod events;
pub use self::broadcaster::Broadcaster;
-pub use self::events::{Events, EventsError};
+pub use self::events::{Error as EventsError, Events};