From fef4745c77d0a1dce0f3deb4b942be3a45ec4420 Mon Sep 17 00:00:00 2001
From: leo <260626284+cameledev@users.noreply.github.com>
Date: Wed, 18 Mar 2026 15:12:38 +0100
Subject: [PATCH] add Recording type to variables

---
 src/backend/core/recording/services/metadata_collector.py | 5 +++--
 src/backend/core/recording/services/recording_events.py   | 5 +++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/backend/core/recording/services/metadata_collector.py b/src/backend/core/recording/services/metadata_collector.py
index be63326a..ebed85e1 100644
--- a/src/backend/core/recording/services/metadata_collector.py
+++ b/src/backend/core/recording/services/metadata_collector.py
@@ -10,6 +10,7 @@ from livekit.protocol.agent_dispatch import (
 )
 
 from core import utils
+from core.models import Recording
 
 logger = getLogger(__name__)
 
@@ -22,7 +23,7 @@ class MetadataCollectorService:
     """Wip."""
 
     @async_to_sync
-    async def start(self, recording):
+    async def start(self, recording: Recording):
         """Wip."""
 
         lkapi = utils.create_livekit_client()
@@ -60,7 +61,7 @@ class MetadataCollectorService:
         return dispatch_id
 
     @async_to_sync
-    async def stop(self, recording):
+    async def stop(self, recording: Recording):
         """Wip."""
 
         room_id = str(recording.room.id)
diff --git a/src/backend/core/recording/services/recording_events.py b/src/backend/core/recording/services/recording_events.py
index 48a682fb..8fac30aa 100644
--- a/src/backend/core/recording/services/recording_events.py
+++ b/src/backend/core/recording/services/recording_events.py
@@ -7,6 +7,7 @@ from logging import getLogger
 from livekit import api
 
 from core import models, utils
+from core.models import Recording
 
 logger = getLogger(__name__)
 
@@ -19,7 +20,7 @@ class RecordingEventsService:
     """Handles recording-related LiveKit webhook events."""
 
     @staticmethod
-    def handle_update(recording, egress_status):
+    def handle_update(recording: Recording, egress_status):
         """Handle egress status updates and sync recording state to room metadata."""
 
         room_name = str(recording.room.id)
@@ -40,7 +41,7 @@ class RecordingEventsService:
                 logger.exception("Failed to update room's metadata: %s", e)
 
     @staticmethod
-    def handle_limit_reached(recording):
+    def handle_limit_reached(recording: Recording):
         """Stop recording and notify participants when limit is reached."""
 
         recording.status = models.RecordingStatusChoices.STOPPED