feat: dispatch notification from client code

czabaj · Oct 31, 2024 · 4ede348 · 4ede348
1 parent 2f9112e
commit 4ede348
Show file tree

Hide file tree

Showing 4 changed files with 51 additions and 8 deletions.
diff --git a/functions/src/index.ts b/functions/src/index.ts
@@ -262,6 +262,11 @@ export const dispatchNotification = onCall<FreeTableMessage | FreshKegMessage>(
             body: `${currentUserFamiliarName} právě zapsal/a první pivo.`,
           },
           tokens: subscribedNotificationTokens,
+          webpush: {
+            fcmOptions: {
+              link: `https://check.beer/misto/${placeDoc.id}`,
+            },
+          },
         });
       }
       case NotificationEvent.freshKeg: {
@@ -289,6 +294,11 @@ export const dispatchNotification = onCall<FreeTableMessage | FreshKegMessage>(
             body: `Právě bylo vytočeno první pivo ze sudu ${kegData.serial}, ${kegData.beer}.`,
           },
           tokens: subscribedNotificationTokens,
+          webpush: {
+            fcmOptions: {
+              link: `https://check.beer/misto/${placeDoc.id}`,
+            },
+          },
         });
       }
     }

diff --git a/src/backend/Firebase.res b/src/backend/Firebase.res
@@ -117,12 +117,12 @@ external arrayUnion: array<'a> => {..} = "arrayUnion"
 external incrementInt: int => {..} = "increment"
 
 @genType.import("firebase/firestore") @genType.as("DocumentReference")
-type documentReference<'a> = {id: string}
+type rec documentReference<'a> = {id: string, parent: option<collectionReference<'a>>, path: string}
+@genType.import("firebase/firestore") @genType.as("CollectionReference") and collectionReference<'a>
+
 @module("firebase/firestore")
 external doc: (firestore, ~path: string) => documentReference<'a> = "doc"
 
-@genType.import("firebase/firestore") @genType.as("CollectionReference")
-type collectionReference<'a>
 @module("firebase/firestore")
 external collection: (firestore, ~path: string) => collectionReference<'a> = "collection"
 

diff --git a/src/backend/NotificationEvents.res b/src/backend/NotificationEvents.res
@@ -24,16 +24,18 @@ type _freshKegMessage = {tag: notificationEvent, keg: string}
 @module("./NotificationEvents.ts")
 external freshKegMessage: _freshKegMessage = "FreshKegMessage"
 
-let useDispatchFreeTable = () => {
+let useDispatchFreeTableNotification = () => {
   let functions = Reactfire.useFunctions()
   let dispatchNotification = Firebase.Functions.httpsCallable(functions, "dispatchNotification")
-  (place: string) => dispatchNotification({tag: FreeTable, place})
+  (placeRef: Firebase.documentReference<FirestoreModels.place>) =>
+    dispatchNotification({tag: FreeTable, place: placeRef.path})
 }
 
-let useDispatchFreshKeg = () => {
+let useDispatchFreshKegNotification = () => {
   let functions = Reactfire.useFunctions()
   let dispatchNotification = Firebase.Functions.httpsCallable(functions, "dispatchNotification")
-  (keg: string) => dispatchNotification({tag: FreshKeg, keg})
+  (kegRef: Firebase.documentReference<FirestoreModels.keg>) =>
+    dispatchNotification({tag: FreshKeg, keg: kegRef.path})
 }
 
 let useUpdateNotificationToken = () => {

diff --git a/src/pages/Place/Place.res b/src/pages/Place/Place.res
@@ -123,6 +123,8 @@ let make = (~placeId) => {
     let (currentUserRole, _) = place.accounts->Dict.get(currentUser.uid)->Option.getExn
     let isUserAuthorized = UserRoles.isAuthorized(currentUserRole, ...)
     let formatConsumption = BackendUtils.getFormatConsumption(place.consumptionSymbols)
+    let dispatchFreeTableNotification = NotificationEvents.useDispatchFreeTableNotification()
+    let dispatchFreshKegNotification = NotificationEvents.useDispatchFreshKegNotification()
 
     <FormattedCurrency.Provider value={place.currency}>
       <div className={`${Styles.page.narrow} ${classes.root}`}>
@@ -174,7 +176,36 @@ let make = (~placeId) => {
             }}
             onDismiss={hideDialog}
             onSubmit={values => {
-              let kegRef = place.taps->Dict.getUnsafe(values.tap)->Null.getExn
+              let keg = tapsWithKegs->Dict.getUnsafe(values.tap)
+              let kegRef = Db.kegDoc(firestore, placeId, Db.getUid(keg))
+              let firstBeerFromKeg = keg.consumptions->Dict.keysToArray->Array.length === 0
+              if firstBeerFromKeg {
+                dispatchFreshKegNotification(kegRef)
+                ->Promise.then(_ => Promise.resolve())
+                ->Promise.catch(error => {
+                  let exn = Js.Exn.asJsExn(error)->Option.getExn
+                  LogUtils.captureException(exn)
+                  Promise.resolve()
+                })
+                ->ignore
+              } else {
+                let freeTable =
+                  recentConsumptionsByUser
+                  ->Map.values
+                  ->Array.fromIterator
+                  ->Array.every(consumptions => consumptions->Array.length === 0)
+                if freeTable {
+                  dispatchFreeTableNotification(Db.placeDocument(firestore, placeId))
+                  ->Promise.then(_ => Promise.resolve())
+                  ->Promise.catch(error => {
+                    let exn = Js.Exn.asJsExn(error)->Option.getExn
+                    LogUtils.captureException(exn)
+                    Promise.resolve()
+                  })
+                  ->ignore
+                }
+              }
+
               Db.Keg.addConsumption(
                 firestore,
                 ~consumption={