Add Meeting class for meeting recordings

Author: ashish-spext

videodb/client.py

@@ -18,6 +18,7 @@
 from videodb.video import Video
 from videodb.audio import Audio
 from videodb.image import Image
+from videodb.meeting import Meeting
 
 from videodb._upload import (
     upload,
@@ -299,7 +300,7 @@ def record_meeting(
         callback_url: str,
         callback_data: dict = {},
         time_zone: str = "UTC",
-    ) -> dict:
+    ) -> Meeting:
         """Record a meeting and upload it to the default collection.
 
         :param str link: Meeting link
@@ -308,8 +309,8 @@ def record_meeting(
         :param str callback_url: URL to receive callback once recording is done
         :param dict callback_data: Data to be sent in the callback (optional)
         :param str time_zone: Time zone for the meeting (default ``UTC``)
-        :return: Response data from the API
-        :rtype: dict
+        :return: :class:`Meeting <Meeting>` object representing the recording bot
+        :rtype: :class:`videodb.meeting.Meeting`
         """
 
         response = self.post(
@@ -323,14 +324,5 @@ def record_meeting(
                 "time_zone": time_zone,
             },
         )
-        return response
-
-    def get_meeting_info(self, bot_id: str) -> dict:
-        """Get the information of a given meeting bot.
-
-        :param str bot_id: ID returned when recording was initiated
-        :return: Information of the meeting bot
-        :rtype: dict
-        """
-
-        return self.get(path=f"{ApiPath.collection}/default/{ApiPath.meeting}/{bot_id}")
+        meeting_id = response.get("meeting_id")
+        return Meeting(self, id=meeting_id, collection_id="default", **response)

videodb/collection.py

@@ -12,6 +12,7 @@
 from videodb.video import Video
 from videodb.audio import Audio
 from videodb.image import Image
+from videodb.meeting import Meeting
 from videodb.rtstream import RTStream
 from videodb.search import SearchFactory, SearchResult
 
@@ -493,7 +494,7 @@ def record_meeting(
         callback_url: str,
         callback_data: dict = {},
         time_zone: str = "UTC",
-    ) -> dict:
+    ) -> Meeting:
         """Record a meeting and upload it to this collection.
 
         :param str link: Meeting link
@@ -502,11 +503,11 @@ def record_meeting(
         :param str callback_url: URL to receive callback once recording is done
         :param dict callback_data: Data to be sent in the callback (optional)
         :param str time_zone: Time zone for the meeting (default ``UTC``)
-        :return: Response data from the API
-        :rtype: dict
+        :return: :class:`Meeting <Meeting>` object representing the recording bot
+        :rtype: :class:`videodb.meeting.Meeting`
         """
 
-        return self._connection.post(
+        response = self._connection.post(
             path=f"{ApiPath.collection}/{self.id}/{ApiPath.meeting}/{ApiPath.record}",
             data={
                 "link": link,
@@ -517,15 +518,5 @@ def record_meeting(
                 "time_zone": time_zone,
             },
         )
-
-    def get_meeting_info(self, bot_id: str) -> dict:
-        """Get the recording info for a meeting bot in this collection.
-
-        :param str bot_id: ID returned when recording was initiated
-        :return: Information of the meeting bot
-        :rtype: dict
-        """
-
-        return self._connection.get(
-            path=f"{ApiPath.collection}/{self.id}/{ApiPath.meeting}/{bot_id}"
-        )
+        meeting_id = response.get("meeting_id")
+        return Meeting(self._connection, id=meeting_id, collection_id=self.id, **response)

videodb/meeting.py

@@ -0,0 +1,81 @@
+from videodb._constants import ApiPath
+
+from videodb.exceptions import (
+    VideodbError,
+)
+
+
+class Meeting:
+    """Meeting class representing a meeting recording bot."""
+
+    def __init__(self, _connection, id: str, collection_id: str, **kwargs) -> None:
+        self._connection = _connection
+        self.id = id
+        self.collection_id = collection_id
+        self._update_attributes(kwargs)
+
+    def __repr__(self) -> str:
+        return f"Meeting(id={self.id}, collection_id={self.collection_id}, name={self.name}, status={self.status}, bot_name={self.bot_name})"
+
+    def _update_attributes(self, data: dict) -> None:
+        """Update instance attributes from API response data."""
+        self.bot_name = data.get("bot_name")
+        self.name = data.get("meeting_name")
+        self.meeting_url = data.get("meeting_url")
+        self.status = data.get("status")
+        self.time_zone = data.get("time_zone")
+
+    def refresh(self) -> "Meeting":
+        """Refresh meeting data from the server.
+
+        Returns:
+            self: The Meeting instance with updated data
+
+        Raises:
+            APIError: If the API request fails
+        """
+        response = self._connection.get(
+            path=f"{ApiPath.collection}/{self.collection_id}/{ApiPath.meeting}/{self.id}"
+        )
+
+        if response:
+            self._update_attributes(response)
+        else:
+            raise VideodbError(f"Failed to refresh meeting {self.id}")
+
+        return self
+
+    @property
+    def is_active(self) -> bool:
+        """Check if the meeting is currently active."""
+        return self.status in ["initializing", "processing"]
+
+    @property
+    def is_completed(self) -> bool:
+        """Check if the meeting has completed."""
+        return self.status in ["done"]
+
+    def wait_for_status(
+        self, target_status: str, timeout: int = 14400, interval: int = 300
+    ) -> bool:
+        """Wait for the meeting to reach a specific status.
+
+        Args:
+            target_status: The status to wait for
+            timeout: Maximum time to wait in seconds
+            interval: Time between status checks in seconds
+
+        Returns:
+            bool: True if status reached, False if timeout
+        """
+        import time
+
+        start_time = time.time()
+
+        while time.time() - start_time < timeout:
+            self.refresh()
+            if self.status == target_status:
+                return True
+            time.sleep(interval)
+
+        return False