add extra logging

sangonz193 · Apr 21, 2024 · a773cfe · a773cfe
1 parent e36c57f
commit a773cfe
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 1 deletion.
diff --git a/modules/connections/clean-up-signaling-rows.ts b/modules/connections/clean-up-signaling-rows.ts
@@ -1,6 +1,7 @@
 import { User } from "@supabase/supabase-js"
 import { fromPromise } from "xstate"
 
+import { logger } from "@/logger"
 import { createClient } from "@/utils/supabase/client"
 
 type Input = {
@@ -14,10 +15,12 @@ export async function cleanUpSignalingRows({
   supabase,
   remoteUserId,
 }: Input) {
+  logger.info("[cleanUpSignalingRows] cleaning up signaling rows")
   await supabase.from("web_rtc_signals").delete().match({
     from_user_id: currentUser.id,
     to_user_id: remoteUserId,
   })
+  logger.info("[cleanUpSignalingRows] cleaned up signaling rows")
 }
 
 export const cleanUpSignalingRowsActor = fromPromise<void, Input>(

diff --git a/modules/connections/connect-caller-peer.ts b/modules/connections/connect-caller-peer.ts
@@ -51,6 +51,7 @@ export const connectCallerPeerMachine = setup({
       { context: { currentUser, remoteUserId, supabase } },
       offer: RTCSessionDescriptionInit,
     ) => {
+      logger.info("[connectCallerPeerMachine] sending offer", offer)
       await supabase
         .from("web_rtc_signals")
         .insert({
@@ -60,13 +61,18 @@ export const connectCallerPeerMachine = setup({
         })
         .then(({ error }) => {
           if (error)
-            logger.error("[connectCallerPeerMachine] sendOffer error", error)
+            logger.error(
+              "[connectCallerPeerMachine] error sending offer",
+              error,
+            )
+          else logger.info("[connectCallerPeerMachine] offer sent")
         })
     },
     sendIceCandidate: async (
       { context: { currentUser, remoteUserId, supabase } },
       candidate: RTCIceCandidate,
     ) => {
+      logger.info("[connectCallerPeerMachine] sending ice candidate", candidate)
       await supabase
         .from("web_rtc_signals")
         .insert({
@@ -80,6 +86,7 @@ export const connectCallerPeerMachine = setup({
               "[connectCallerPeerMachine] sendIceCandidate error",
               error,
             )
+          else logger.info("[connectCallerPeerMachine] ice candidate sent")
         })
     },
   },

diff --git a/modules/connections/connect-receiver-peer.ts b/modules/connections/connect-receiver-peer.ts
@@ -40,6 +40,7 @@ export const connectReceiverPeerMachine = setup({
       { context: { currentUser, remoteUserId, supabase } },
       answer: RTCSessionDescriptionInit,
     ) => {
+      logger.info("[connectReceiverPeerMachine] sending answer", answer)
       await supabase
         .from("web_rtc_signals")
         .insert({
@@ -50,12 +51,17 @@ export const connectReceiverPeerMachine = setup({
         .then(({ error }) => {
           if (error)
             logger.error("[connectReceiverPeerMachine] sendAnswer error", error)
+          else logger.info("[connectReceiverPeerMachine] sent answer", answer)
         })
     },
     sendIceCandidate: async (
       { context: { currentUser, remoteUserId, supabase } },
       candidate: RTCIceCandidate,
     ) => {
+      logger.info(
+        "[connectReceiverPeerMachine] sending ice candidate",
+        candidate,
+      )
       await supabase
         .from("web_rtc_signals")
         .insert({
@@ -69,6 +75,7 @@ export const connectReceiverPeerMachine = setup({
               "[connectReceiverPeerMachine] sendIceCandidate error",
               error,
             )
+          else logger.info("[connectReceiverPeerMachine] sent ice candidate")
         })
     },
   },