Add ttl to create_moq_access

Regenerated MoqAccessConfig from fishjam openapi.yaml (fce-3832/moq-token-ttl).

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_013EKXgj4SvESh4S99791s1N

Author: Karolk99

fishjam/_fishjam_openapi_client/models/moq_access_config.py

@@ -18,10 +18,13 @@ class MoqAccessConfig:
         publish_path (None | str | Unset): Path under the root the token grants publish access to Example: my-stream.
         subscribe_path (None | str | Unset): Path under the root the token grants subscribe access to Example: my-
             stream.
+        ttl (int | None | Unset): Token time to live in seconds. Defaults to 3600 (1 hour), maximum is 86400 (24 hours).
+            Example: 3600.
     """
 
     publish_path: None | str | Unset = UNSET
     subscribe_path: None | str | Unset = UNSET
+    ttl: int | None | Unset = UNSET
 
     def to_dict(self) -> dict[str, Any]:
         publish_path: None | str | Unset
@@ -36,13 +39,21 @@ def to_dict(self) -> dict[str, Any]:
         else:
             subscribe_path = self.subscribe_path
 
+        ttl: int | None | Unset
+        if isinstance(self.ttl, Unset):
+            ttl = UNSET
+        else:
+            ttl = self.ttl
+
         field_dict: dict[str, Any] = {}
 
         field_dict.update({})
         if publish_path is not UNSET:
             field_dict["publishPath"] = publish_path
         if subscribe_path is not UNSET:
             field_dict["subscribePath"] = subscribe_path
+        if ttl is not UNSET:
+            field_dict["ttl"] = ttl
 
         return field_dict
 
@@ -68,9 +79,19 @@ def _parse_subscribe_path(data: object) -> None | str | Unset:
 
         subscribe_path = _parse_subscribe_path(d.pop("subscribePath", UNSET))
 
+        def _parse_ttl(data: object) -> int | None | Unset:
+            if data is None:
+                return data
+            if isinstance(data, Unset):
+                return data
+            return cast(int | None | Unset, data)
+
+        ttl = _parse_ttl(d.pop("ttl", UNSET))
+
         moq_access_config = cls(
             publish_path=publish_path,
             subscribe_path=subscribe_path,
+            ttl=ttl,
         )
 
         return moq_access_config

fishjam/api/_fishjam_client.py

@@ -514,20 +514,25 @@ def create_moq_access(
         self,
         publish_path: str | None = None,
         subscribe_path: str | None = None,
+        ttl: int | None = None,
     ) -> MoqAccess:
         """Generates MoQ relay connection details.
 
         Args:
             publish_path: Path the access grants publish access to.
             subscribe_path: Path the access grants subscribe access to.
+            ttl: Token time to live in seconds. Defaults to 3600 (1 hour),
+                maximum is 86400 (24 hours).
 
         Returns:
             MoqAccess: The relay connection details, containing the
             ``connection_url`` (with the JWT embedded as a ``?jwt=`` query
             parameter) and the ``token`` itself.
         """
         config = MoqAccessConfig(
-            publish_path=publish_path, subscribe_path=subscribe_path
+            publish_path=publish_path,
+            subscribe_path=subscribe_path,
+            ttl=ttl if ttl is not None else UNSET,
         )
         response = cast(
             MoqAccess,

tests/test_room_api.py

@@ -1,3 +1,5 @@
+import base64
+import json
 from unittest.mock import Mock, patch
 
 import httpx
@@ -342,6 +344,18 @@ def test_valid_both(self, room_api: FishjamClient):
         assert isinstance(access.connection_url, str)
         assert isinstance(access.token, str)
 
+    def test_ttl_sets_token_expiry(self, room_api: FishjamClient):
+        access = room_api.create_moq_access(publish_path="test-stream", ttl=120)
+
+        _header, payload, _signature = access.token.split(".")
+        payload += "=" * (-len(payload) % 4)
+        claims = json.loads(base64.urlsafe_b64decode(payload))
+        assert claims["exp"] - claims["iat"] == 120
+
+    def test_invalid_ttl(self, room_api: FishjamClient):
+        with pytest.raises(BadRequestError):
+            room_api.create_moq_access(publish_path="test-stream", ttl=0)
+
     def test_unauthorized(self):
         room_api = FishjamClient(FISHJAM_ID, "invalid")