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/test/fixtures/message.rs | 4 ++--
 src/test/fixtures/mod.rs     | 2 --
 2 files changed, 2 insertions(+), 4 deletions(-)

(limited to 'src/test')

diff --git a/src/test/fixtures/message.rs b/src/test/fixtures/message.rs
index 33feeae..bfca8cd 100644
--- a/src/test/fixtures/message.rs
+++ b/src/test/fixtures/message.rs
@@ -3,7 +3,7 @@ use faker_rand::lorem::Paragraphs;
 use crate::{
     app::App,
     clock::RequestedAt,
-    events::repo::broadcast,
+    events::types,
     repo::{channel::Channel, login::Login},
 };
 
@@ -12,7 +12,7 @@ pub async fn send(
     login: &Login,
     channel: &Channel,
     sent_at: &RequestedAt,
-) -> broadcast::Message {
+) -> types::ChannelEvent {
     let body = propose();
 
     app.events()
diff --git a/src/test/fixtures/mod.rs b/src/test/fixtures/mod.rs
index a42dba5..450fbec 100644
--- a/src/test/fixtures/mod.rs
+++ b/src/test/fixtures/mod.rs
@@ -13,8 +13,6 @@ pub async fn scratch_app() -> App {
         .await
         .expect("setting up in-memory sqlite database");
     App::from(pool)
-        .await
-        .expect("creating an app from a fresh, in-memory database")
 }
 
 pub fn now() -> RequestedAt {
-- 
cgit v1.2.3