feat(Pusher): add debug interest

simonknittel · Jan 18, 2025 · f2e2113 · f2e2113
1 parent 5a7c6a0
commit f2e2113
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 10 deletions.
diff --git a/app/src/app/app/layout.tsx b/app/src/app/app/layout.tsx
@@ -22,7 +22,10 @@ export default async function AppLayout({ children }: Readonly<Props>) {
     <SessionProviderContainer session={authentication.session}>
       <QueryClientProviderContainer>
         <TRPCReactProvider>
-          <BeamsProvider instanceId={env.PUSHER_BEAMS_INSTANCE_ID}>
+          <BeamsProvider
+            instanceId={env.PUSHER_BEAMS_INSTANCE_ID}
+            userId={authentication.session.user.id}
+          >
             <div className="min-h-dvh bg-sinister-radial-gradient">
               <MobileActionBarContainer />
               <DesktopSidebarContainer />

diff --git a/app/src/pusher/components/BeamsContext.tsx b/app/src/pusher/components/BeamsContext.tsx
@@ -1,5 +1,6 @@
 "use client";
 
+import type { User } from "@prisma/client";
 import dynamic from "next/dynamic";
 import type { Dispatch, ReactNode, SetStateAction } from "react";
 import { createContext, useContext, useEffect, useMemo, useState } from "react";
@@ -18,9 +19,10 @@ const BeamsContext = createContext<BeamsContext | undefined>(undefined);
 type Props = Readonly<{
   children: ReactNode;
   instanceId?: string;
+  userId: User["id"];
 }>;
 
-export const BeamsProvider = ({ children, instanceId }: Props) => {
+export const BeamsProvider = ({ children, instanceId, userId }: Props) => {
   const [interests, setInterests] = useState<string[] | undefined>(undefined);
 
   useEffect(() => {
@@ -49,7 +51,7 @@ export const BeamsProvider = ({ children, instanceId }: Props) => {
   return (
     <BeamsContext.Provider value={value}>
       {children}
-      {instanceId && <Client instanceId={instanceId} />}
+      {instanceId && <Client instanceId={instanceId} userId={userId} />}
     </BeamsContext.Provider>
   );
 };

diff --git a/app/src/pusher/components/Client.tsx b/app/src/pusher/components/Client.tsx
@@ -1,15 +1,17 @@
 "use client";
 
+import type { User } from "@prisma/client";
 import * as PusherPushNotifications from "@pusher/push-notifications-web";
 import { useEffect } from "react";
 import toast from "react-hot-toast";
 import { useBeamsContext } from "./BeamsContext";
 
 type Props = Readonly<{
   instanceId: string;
+  userId: User["id"];
 }>;
 
-export const Client = ({ instanceId }: Props) => {
+export const Client = ({ instanceId, userId }: Props) => {
   const { interests } = useBeamsContext();
 
   useEffect(() => {
@@ -24,24 +26,28 @@ export const Client = ({ instanceId }: Props) => {
 
       if (interests.length <= 0) {
         void beamsClient.stop();
-        console.info("[Pusher] Client stopped");
+        console.info("[Pusher] Client stopped.");
         return;
       }
 
       void beamsClient
         .start()
         .then(() => {
-          console.info("[Pusher] Client started");
-          return beamsClient.setDeviceInterests(interests);
+          const _interests = [...interests, `debug-user-${userId}`];
+          console.info(
+            "[Pusher] Client started. Settings interests...",
+            _interests,
+          );
+          return beamsClient.setDeviceInterests(_interests);
         })
         .then(() => {
-          console.info("[Pusher] Device interests set");
+          console.info("[Pusher] Device interests set.");
         });
     } catch (error) {
-      console.error("[Pusher] Error initializing client", error);
+      console.error("[Pusher] Error initializing client.", error);
       toast.error("Benachrichtigungen konnten nicht aktiviert werden.");
     }
-  }, [interests, instanceId]);
+  }, [interests, instanceId, userId]);
 
   return null;
 };