From eff129bc1f29bcb1b2b9d10c6b49ab886edc83d6 Mon Sep 17 00:00:00 2001
From: Owen Jacobson <owen@grimoire.ca>
Date: Fri, 27 Sep 2024 18:17:02 -0400
Subject: Make `/api/events` a firehose endpoint.

It now includes events for all channels. Clients are responsible for filtering.

The schema for channel events has changed; it now includes a channel name and ID, in the same format as the sender's name and ID. They also now include a `"type"` field, whose only valid value (as of this writing) is `"message"`.

This is groundwork for delivering message deletion (expiry) events to clients, and notifying clients of channel lifecycle events.
---
 src/app.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'src/app.rs')

diff --git a/src/app.rs b/src/app.rs
index b2f861c..07b932a 100644
--- a/src/app.rs
+++ b/src/app.rs
@@ -13,9 +13,9 @@ pub struct App {
 }
 
 impl App {
-    pub async fn from(db: SqlitePool) -> Result<Self, sqlx::Error> {
-        let broadcaster = Broadcaster::from_database(&db).await?;
-        Ok(Self { db, broadcaster })
+    pub fn from(db: SqlitePool) -> Self {
+        let broadcaster = Broadcaster::default();
+        Self { db, broadcaster }
     }
 }
 
@@ -29,6 +29,6 @@ impl App {
     }
 
     pub const fn channels(&self) -> Channels {
-        Channels::new(&self.db, &self.broadcaster)
+        Channels::new(&self.db)
     }
 }
-- 
cgit v1.2.3