Send created events when channels are added.

1 files changed, 13 insertions, 5 deletions

diff --git a/src/channel/app.rs b/src/channel/app.rs
index 6bad158..1eeca79 100644
--- a/src/channel/app.rs
+++ b/src/channel/app.rs
@@ -1,25 +1,33 @@
 use sqlx::sqlite::SqlitePool;
 
-use crate::repo::channel::{Channel, Provider as _};
+use crate::{
+    clock::DateTime,
+    events::{broadcaster::Broadcaster, types::ChannelEvent},
+    repo::channel::{Channel, Provider as _},
+};
 
 pub struct Channels<'a> {
     db: &'a SqlitePool,
+    broadcaster: &'a Broadcaster,
 }
 
 impl<'a> Channels<'a> {
-    pub const fn new(db: &'a SqlitePool) -> Self {
-        Self { db }
+    pub const fn new(db: &'a SqlitePool, broadcaster: &'a Broadcaster) -> Self {
+        Self { db, broadcaster }
     }
 
-    pub async fn create(&self, name: &str) -> Result<Channel, CreateError> {
+    pub async fn create(&self, name: &str, created_at: &DateTime) -> Result<Channel, CreateError> {
         let mut tx = self.db.begin().await?;
         let channel = tx
             .channels()
-            .create(name)
+            .create(name, created_at)
             .await
             .map_err(|err| CreateError::from_duplicate_name(err, name))?;
         tx.commit().await?;
 
+        self.broadcaster
+            .broadcast(&ChannelEvent::created(channel.clone()));
+
         Ok(channel)
     }