wip troubleshoot

src/backend/core/recording/services/recording_events.py

@@ -24,6 +24,8 @@ class RecordingEventsService:
 
         room_name = str(recording.room.id)
 
+        print('$$ handle_update')
+
         status_mapping = {
             api.EgressStatus.EGRESS_ACTIVE: "started",
             api.EgressStatus.EGRESS_ENDING: "saving",
@@ -31,12 +33,18 @@ class RecordingEventsService:
         }
 
         recording_status = status_mapping.get(egress_status)
+
+        print('$$ recording_status')
+        print(recording_status)
+
         if recording_status:
             try:
+                print('$$ update')
                 utils.update_room_metadata(
                     room_name, {"recording_status": recording_status}
                 )
             except utils.MetadataUpdateException as e:
+                print('$$ exception')
                 logger.exception("Failed to update room's metadata: %s", e)
 
     @staticmethod

src/backend/core/services/livekit_events.py

@@ -122,6 +122,10 @@ class LiveKitEventsService:
             logger.info("Filtered webhook event for room '%s'", data.room.name)
             return
 
+        print('$$ data.event')
+        print(data.event)
+        print(data)
+
         try:
             webhook_type = LiveKitWebhookEventType(data.event)
         except ValueError as e:
@@ -129,6 +133,9 @@ class LiveKitEventsService:
                 f"Unknown webhook type: {data.event}"
             ) from e
 
+        print("$$ webhook_type")
+        print(webhook_type)
+
         handler_name = f"_handle_{webhook_type.value}"
         handler = getattr(self, handler_name, None)
 
@@ -141,6 +148,8 @@ class LiveKitEventsService:
     def _handle_egress_updated(self, data):
         """Handle 'egress_updated' event."""
 
+        print("$$ _handle_egress_updated")
+
         egress_id = data.egress_info.egress_id
         try:
             recording = models.Recording.objects.get(worker_id=egress_id)
@@ -149,7 +158,11 @@ class LiveKitEventsService:
                 f"Recording with worker ID {egress_id} does not exist"
             ) from err
 
+        print("$$ egress found")
+
         egress_status = data.egress_info.status
+        print('$$ egress_status')
+        print(egress_status)
         self.recording_events.handle_update(recording, egress_status)
 
     def _handle_egress_ended(self, data):

src/backend/core/utils.py

@@ -276,6 +276,8 @@ async def update_room_metadata(
         room = response.rooms[0]
 
         existing_metadata = json.loads(room.metadata) if room.metadata else {}
+        print('$$ existing_metadata')
+        print(existing_metadata)
 
         if remove_keys:
             for key in remove_keys:
@@ -283,6 +285,9 @@ async def update_room_metadata(
 
         updated_metadata = {**existing_metadata, **metadata}
 
+        print('$$ updated_metadata')
+        print(updated_metadata)
+
         await lkapi.room.update_room_metadata(
             UpdateRoomMetadataRequest(
                 room=room_name, metadata=json.dumps(updated_metadata).encode("utf-8")