Merge branch 'main' into wip/mobile

1 files changed, 8 insertions, 8 deletions

diff --git a/src/invite/app.rs b/src/invite/app.rs
index 64ba753..176075f 100644
--- a/src/invite/app.rs
+++ b/src/invite/app.rs
@@ -5,7 +5,7 @@ use super::{repo::Provider as _, Id, Invite, Summary};
 use crate::{
     clock::DateTime,
     db::{Duplicate as _, NotFound as _},
-    event::repo::Provider as _,
+    event::{repo::Provider as _, Broadcaster, Event},
     login::{repo::Provider as _, Login, Password},
     name::Name,
     token::{repo::Provider as _, Secret},
@@ -13,18 +13,15 @@ use crate::{
 
 pub struct Invites<'a> {
     db: &'a SqlitePool,
+    events: &'a Broadcaster,
 }
 
 impl<'a> Invites<'a> {
-    pub const fn new(db: &'a SqlitePool) -> Self {
-        Self { db }
+    pub const fn new(db: &'a SqlitePool, events: &'a Broadcaster) -> Self {
+        Self { db, events }
     }
 
-    pub async fn create(
-        &self,
-        issuer: &Login,
-        issued_at: &DateTime,
-    ) -> Result<Invite, sqlx::Error> {
+    pub async fn issue(&self, issuer: &Login, issued_at: &DateTime) -> Result<Invite, sqlx::Error> {
         let mut tx = self.db.begin().await?;
         let invite = tx.invites().create(issuer, issued_at).await?;
         tx.commit().await?;
@@ -73,6 +70,9 @@ impl<'a> Invites<'a> {
         let secret = tx.tokens().issue(&login, accepted_at).await?;
         tx.commit().await?;
 
+        self.events
+            .broadcast(login.events().map(Event::from).collect::<Vec<_>>());
+
         Ok((login.as_created(), secret))
     }