💄(frontend) add minor layout adjustments

Propose minor layout adjustments to ensure the DINUM version with French
copywriting does not look visually awkward due to line breaks.

compose.yml

@@ -235,7 +235,7 @@ services:
       - livekit-egress
 
   livekit-egress:
-      image: livekit/egress
+      image: livekit/egress:v1.11.0
       environment:
         EGRESS_CONFIG_FILE: ./livekit-egress.yaml
       volumes:

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

@@ -1,7 +1,11 @@
 """Recording-related LiveKit Events Service"""
 
+# pylint: disable=no-member
+
 from logging import getLogger
 
+from livekit import api
+
 from core import models, utils
 
 logger = getLogger(__name__)
@@ -14,6 +18,27 @@ class RecordingEventsError(Exception):
 class RecordingEventsService:
     """Handles recording-related Livekit webhook events."""
 
+    @staticmethod
+    def handle_update(recording, egress_status):
+        """Handle egress status updates and sync recording state to room metadata."""
+
+        room_name = str(recording.room.id)
+
+        status_mapping = {
+            api.EgressStatus.EGRESS_ACTIVE: "started",
+            api.EgressStatus.EGRESS_ENDING: "saving",
+            api.EgressStatus.EGRESS_ABORTED: "aborted",
+        }
+
+        recording_status = status_mapping.get(egress_status)
+        if recording_status:
+            try:
+                utils.update_room_metadata(
+                    room_name, {"recording_status": recording_status}
+                )
+            except utils.MetadataUpdateException as e:
+                logger.exception("Failed to update room's metadata: %s", e)
+
     @staticmethod
     def handle_limit_reached(recording):
         """Stop recording and notify participants when limit is reached."""

src/backend/core/recording/worker/mediator.py

@@ -105,10 +105,4 @@ class WorkerServiceMediator:
         finally:
             recording.save()
 
-        try:
-            room_name = str(recording.room.id)
-            utils.update_room_metadata(room_name, {"recording_status": "saving"})
-        except utils.MetadataUpdateException as e:
-            logger.exception("Failed to update room's metadata: %s", e)
-
         logger.info("Worker stopped for room %s", recording.room)

src/backend/core/services/livekit_events.py

@@ -118,8 +118,10 @@ class LiveKitEventsService:
         except Exception as e:
             raise InvalidPayloadError("Invalid webhook payload") from e
 
-        if self._filter_regex and not self._filter_regex.search(data.room.name):
-            logger.info("Filtered webhook event for room '%s'", data.room.name)
+        room_name = data.room.name or data.egress_info.room_name
+
+        if self._filter_regex and not self._filter_regex.search(room_name):
+            logger.info("Filtered webhook event for room '%s'", room_name)
             return
 
         try:
@@ -138,23 +140,19 @@ class LiveKitEventsService:
         # pylint: disable=not-callable
         handler(data)
 
-    def _handle_egress_started(self, data):
-        """Handle 'egress_started' event."""
+    def _handle_egress_updated(self, data):
+        """Handle 'egress_updated' event."""
 
+        egress_id = data.egress_info.egress_id
         try:
-            recording = models.Recording.objects.get(
-                worker_id=data.egress_info.egress_id
-            )
+            recording = models.Recording.objects.get(worker_id=egress_id)
         except models.Recording.DoesNotExist as err:
             raise ActionFailedError(
-                f"Recording with worker ID {data.egress_info.egress_id} does not exist"
+                f"Recording with worker ID {egress_id} does not exist"
             ) from err
 
-        try:
-            room_name = str(recording.room.id)
-            utils.update_room_metadata(room_name, {"recording_status": "started"})
-        except utils.MetadataUpdateException as e:
-            logger.exception("Failed to update room's metadata: %s", e)
+        egress_status = data.egress_info.status
+        self.recording_events.handle_update(recording, egress_status)
 
     def _handle_egress_ended(self, data):
         """Handle 'egress_ended' event."""

src/backend/core/tests/recording/worker/test_mediator.py

@@ -122,10 +122,7 @@ def test_mediator_start_recording_from_forbidden_status(
     mock_update_room_metadata.assert_not_called()
 
 
-@mock.patch("core.utils.update_room_metadata")
-def test_mediator_stop_recording_success(
-    mock_update_room_metadata, mediator, mock_worker_service
-):
+def test_mediator_stop_recording_success(mediator, mock_worker_service):
     """Test successful recording stop"""
     # Setup
     mock_recording = RecordingFactory(
@@ -143,15 +140,8 @@ def test_mediator_stop_recording_success(
     mock_recording.refresh_from_db()
     assert mock_recording.status == RecordingStatusChoices.STOPPED
 
-    mock_update_room_metadata.assert_called_once_with(
-        str(mock_recording.room.id), {"recording_status": "saving"}
-    )
 
-
-@mock.patch("core.utils.update_room_metadata")
-def test_mediator_stop_recording_aborted(
-    mock_update_room_metadata, mediator, mock_worker_service
-):
+def test_mediator_stop_recording_aborted(mediator, mock_worker_service):
     """Test recording stop when worker returns ABORTED"""
     # Setup
     mock_recording = RecordingFactory(
@@ -166,15 +156,10 @@ def test_mediator_stop_recording_aborted(
     mock_recording.refresh_from_db()
     assert mock_recording.status == RecordingStatusChoices.ABORTED
 
-    mock_update_room_metadata.assert_called_once_with(
-        str(mock_recording.room.id), {"recording_status": "saving"}
-    )
-
 
 @pytest.mark.parametrize("error_class", [WorkerConnectionError, WorkerResponseError])
-@mock.patch("core.utils.update_room_metadata")
 def test_mediator_stop_recording_worker_errors(
-    mock_update_room_metadata, mediator, mock_worker_service, error_class
+    mediator, mock_worker_service, error_class
 ):
     """Test handling of worker errors during stop"""
     # Setup
@@ -190,5 +175,3 @@ def test_mediator_stop_recording_worker_errors(
     # Verify recording updates
     mock_recording.refresh_from_db()
     assert mock_recording.status == RecordingStatusChoices.FAILED_TO_STOP
-
-    mock_update_room_metadata.assert_not_called()

src/backend/core/tests/services/test_livekit_events.py

@@ -94,22 +94,55 @@ def test_handle_egress_ended_success(
     assert recording.status == "stopped"
 
 
+@pytest.mark.parametrize(
+    ("egress_status", "status"),
+    (
+        (EgressStatus.EGRESS_ACTIVE, "started"),
+        (EgressStatus.EGRESS_ENDING, "saving"),
+        (EgressStatus.EGRESS_ABORTED, "aborted"),
+    ),
+)
 @mock.patch("core.utils.update_room_metadata")
-def test_handle_egress_started_success(mock_update_room_metadata, service):
-    """Should successfully start recording and update room's metadata."""
+def test_handle_egress_updated_success(
+    mock_update_room_metadata, egress_status, status, service
+):
+    """Should successfully update room's metadata."""
 
     recording = RecordingFactory(worker_id="worker-1", status="initiated")
     mock_data = mock.MagicMock()
     mock_data.egress_info.egress_id = recording.worker_id
-    mock_data.egress_info.status = EgressStatus.EGRESS_ACTIVE
+    mock_data.egress_info.status = egress_status
 
-    service._handle_egress_started(mock_data)
+    service._handle_egress_updated(mock_data)
 
     mock_update_room_metadata.assert_called_once_with(
-        str(recording.room.id), {"recording_status": "started"}
+        str(recording.room.id), {"recording_status": status}
     )
 
 
+@pytest.mark.parametrize(
+    "egress_status",
+    (
+        EgressStatus.EGRESS_FAILED,
+        EgressStatus.EGRESS_LIMIT_REACHED,
+    ),
+)
+@mock.patch("core.utils.update_room_metadata")
+def test_handle_egress_updated_non_handled(
+    mock_update_room_metadata, egress_status, service
+):
+    """Should ignore certain egress status and don't trigger metadata updates."""
+
+    recording = RecordingFactory(worker_id="worker-1", status="initiated")
+    mock_data = mock.MagicMock()
+    mock_data.egress_info.egress_id = recording.worker_id
+    mock_data.egress_info.status = egress_status
+
+    service._handle_egress_updated(mock_data)
+
+    mock_update_room_metadata.assert_not_called()
+
+
 @pytest.mark.parametrize(
     ("mode", "notification_type"),
     (

src/frontend/src/features/notifications/components/ToastRecordingRequest.tsx

@@ -66,16 +66,22 @@ export function ToastRecordingRequest({
           name: participant?.name,
         })}
         {!options.isMenuOpen && (
-          <Button
-            size="sm"
-            variant="text"
+          <div
             className={css({
-              color: 'primary.300',
+              marginLeft: '0.5rem',
             })}
-            onPress={options.openMenu}
           >
-            {t('openMenu')}
-          </Button>
+            <Button
+              size="sm"
+              variant="text"
+              className={css({
+                color: 'primary.300',
+              })}
+              onPress={options.openMenu}
+            >
+              {t('openMenu')}
+            </Button>
+          </div>
         )}
       </HStack>
     </StyledToastContainer>

src/frontend/src/features/recording/components/ControlsButton.tsx

@@ -161,6 +161,7 @@ export const ControlsButton = ({
         fullWidth
         onPress={handle}
         isDisabled={isDisabled}
+        size="compact"
       >
         {t('button.start')}
       </Button>

src/frontend/src/features/recording/components/RowWrapper.tsx

@@ -29,9 +29,10 @@ export const RowWrapper = ({
       className={css({
         width: '100%',
         background: 'gray.100',
-        padding: '8px',
+        paddingBlock: '0.5rem',
+        paddingInline: '0',
         display: 'flex',
-        marginTop: '4px',
+        marginTop: '0.25rem',
       })}
     >
       <div
@@ -40,6 +41,7 @@ export const RowWrapper = ({
           display: 'flex',
           justifyContent: 'center',
           alignItems: 'center',
+          paddingInline: '0.25rem',
         })}
       >
         {/*  fixme - doesn't handle properly material-symbols  */}
@@ -47,10 +49,11 @@ export const RowWrapper = ({
       </div>
       <div
         className={css({
-          flex: 5,
+          flex: 6,
           display: 'flex',
           alignItems: 'center',
           gap: '0.25rem',
+          paddingInlineEnd: '8px',
         })}
       >
         {children}

src/frontend/src/primitives/buttonRecipe.ts

@@ -31,6 +31,12 @@ export const buttonRecipe = cva({
         borderRadius: 4,
         '--square-padding': '0',
       },
+      compact: {
+        borderRadius: 4,
+        paddingX: '0.5',
+        paddingY: '0.625',
+        '--square-padding': '{spacing.0.625}',
+      },
     },
     square: {
       true: {

src/frontend/src/styles/icons.css

@@ -4,7 +4,6 @@
 .material-symbols {
   font-weight: normal;
   font-style: normal;
-  font-display: block;
   font-size: 24px;
   display: inline-block;
   line-height: 1;

src/helm/env.d/dev-dinum/values.meet.yaml.gotmpl

@@ -49,6 +49,7 @@ backend:
     {{- end }}
     {{- end }}
     LIVEKIT_API_URL: https://livekit.127.0.0.1.nip.io/
+    LIVEKIT_WEBHOOK_EVENTS_FILTER_REGEX: "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}"
     ALLOW_UNREGISTERED_ROOMS: False
     FRONTEND_SILENCE_LIVEKIT_DEBUG: False
     FRONTEND_SUPPORT: "{'id': '58ea6697-8eba-4492-bc59-ad6562585041', 'help_article_transcript': 'https://lasuite.crisp.help/fr/article/visio-transcript-1sjq43x', 'help_article_recording': 'https://lasuite.crisp.help/fr/article/visio-enregistrement-wgc8o0', 'help_article_more_tools': 'https://lasuite.crisp.help/fr/article/visio-tools-bvxj23'}"
@@ -98,7 +99,7 @@ backend:
   # Extra volume mounts to manage our local custom CA and avoid to set ssl_verify: false
   extraVolumeMounts:
     - name: certs
-      mountPath: /usr/local/lib/python3.12/site-packages/certifi/cacert.pem
+      mountPath: /usr/local/lib/python3.13/site-packages/certifi/cacert.pem
       subPath: cacert.pem
 
   # Extra volumes to manage our local custom CA and avoid to set ssl_verify: false

src/helm/env.d/dev-keycloak/values.egress.yaml.gotmpl

@@ -1,6 +1,9 @@
 replicaCount: 1
 terminationGracePeriodSeconds: 18000
 
+image:
+  tag: v1.11.0
+
 egress:
   log_level: debug
   ws_url: ws://livekit-livekit-server:80

src/helm/env.d/dev-keycloak/values.meet.yaml.gotmpl

@@ -51,6 +51,7 @@ backend:
     LIVEKIT_API_URL: https://livekit.127.0.0.1.nip.io/
     LIVEKIT_FORCE_WSS_PROTOCOL: True
     LIVEKIT_ENABLE_FIREFOX_PROXY_WORKAROUND: True
+    LIVEKIT_WEBHOOK_EVENTS_FILTER_REGEX: "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}"
     ALLOW_UNREGISTERED_ROOMS: False
     FRONTEND_SILENCE_LIVEKIT_DEBUG: False
     FRONTEND_SUPPORT: "{'id': '58ea6697-8eba-4492-bc59-ad6562585041', 'help_article_transcript': 'https://lasuite.crisp.help/fr/article/visio-transcript-1sjq43x', 'help_article_recording': 'https://lasuite.crisp.help/fr/article/visio-enregistrement-wgc8o0', 'help_article_more_tools': 'https://lasuite.crisp.help/fr/article/visio-tools-bvxj23'}"

src/helm/env.d/dev/values.meet.yaml.gotmpl

@@ -71,6 +71,7 @@ backend:
     {{- end }}
     {{- end }}
     LIVEKIT_API_URL: https://livekit.127.0.0.1.nip.io/
+    LIVEKIT_WEBHOOK_EVENTS_FILTER_REGEX: "[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}"
     ALLOW_UNREGISTERED_ROOMS: False
     FRONTEND_SILENCE_LIVEKIT_DEBUG: False
     FRONTEND_SUPPORT: "{'id': '58ea6697-8eba-4492-bc59-ad6562585041'}"