summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/app.rs2
-rw-r--r--src/channel/app.rs2
-rw-r--r--src/events/app.rs (renamed from src/events/app/events.rs)15
-rw-r--r--src/events/app/mod.rs5
-rw-r--r--src/events/broadcaster.rs (renamed from src/events/app/broadcaster.rs)0
-rw-r--r--src/events/mod.rs1
6 files changed, 10 insertions, 15 deletions
diff --git a/src/app.rs b/src/app.rs
index 1cf56c9..b2f861c 100644
--- a/src/app.rs
+++ b/src/app.rs
@@ -2,7 +2,7 @@ use sqlx::sqlite::SqlitePool;
use crate::{
channel::app::Channels,
- events::app::{Broadcaster, Events},
+ events::{app::Events, broadcaster::Broadcaster},
login::app::Logins,
};
diff --git a/src/channel/app.rs b/src/channel/app.rs
index bb87734..793fa35 100644
--- a/src/channel/app.rs
+++ b/src/channel/app.rs
@@ -1,7 +1,7 @@
use sqlx::sqlite::SqlitePool;
use crate::{
- events::app::Broadcaster,
+ events::broadcaster::Broadcaster,
repo::channel::{Channel, Provider as _},
};
diff --git a/src/events/app/events.rs b/src/events/app.rs
index 8b76994..7229551 100644
--- a/src/events/app/events.rs
+++ b/src/events/app.rs
@@ -6,13 +6,12 @@ use futures::{
};
use sqlx::sqlite::SqlitePool;
-use super::Broadcaster;
+use super::{
+ broadcaster::Broadcaster,
+ repo::broadcast::{self, Provider as _},
+};
use crate::{
clock::DateTime,
- events::{
- app::EventsError,
- repo::broadcast::{self, Provider as _},
- },
repo::{
channel::{self, Provider as _},
error::NotFound as _,
@@ -36,7 +35,7 @@ impl<'a> Events<'a> {
channel: &channel::Id,
body: &str,
sent_at: &DateTime,
- ) -> Result<broadcast::Message, Error> {
+ ) -> Result<broadcast::Message, EventsError> {
let mut tx = self.db.begin().await?;
let channel = tx
.channels()
@@ -58,7 +57,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, Error> {
+ ) -> Result<impl Stream<Item = broadcast::Message> + std::fmt::Debug, EventsError> {
// Somewhat arbitrarily, expire after 90 days.
let expire_at = subscribed_at.to_owned() - TimeDelta::days(90);
@@ -133,7 +132,7 @@ impl<'a> Events<'a> {
}
#[derive(Debug, thiserror::Error)]
-pub enum Error {
+pub enum EventsError {
#[error("channel {0} not found")]
ChannelNotFound(channel::Id),
#[error(transparent)]
diff --git a/src/events/app/mod.rs b/src/events/app/mod.rs
deleted file mode 100644
index f364e00..0000000
--- a/src/events/app/mod.rs
+++ /dev/null
@@ -1,5 +0,0 @@
-mod broadcaster;
-mod events;
-
-pub use self::broadcaster::Broadcaster;
-pub use self::events::{Error as EventsError, Events};
diff --git a/src/events/app/broadcaster.rs b/src/events/broadcaster.rs
index 6a1219a..6a1219a 100644
--- a/src/events/app/broadcaster.rs
+++ b/src/events/broadcaster.rs
diff --git a/src/events/mod.rs b/src/events/mod.rs
index e76d67c..b9f3f5b 100644
--- a/src/events/mod.rs
+++ b/src/events/mod.rs
@@ -1,4 +1,5 @@
pub mod app;
+pub mod broadcaster;
mod extract;
pub mod repo;
mod routes;