re_answer_re_offer のテスト

tests/client.py

@@ -289,6 +289,7 @@ def __init__(
  self._candidate_messages: list[dict[str, Any]] = []
  self._re_offer_messages: list[dict[str, Any]] = []
  self._re_answer_messages: list[dict[str, Any]] = []
+ self._disconnect_message: Optional[dict[str, Any]] = None
 
  # callback
  self._connection.on_signaling_message = self._on_signaling_message
@@ -344,6 +345,10 @@ def re_offer_messages(self) -> list[dict[str, Any]]:
  def re_answer_messages(self) -> list[dict[str, Any]]:
  return self._re_answer_messages
 
+ @property
+ def disconnect_message(self) -> Optional[dict[str, Any]]:
+ return self._disconnect_message
+
  @property
  def connected(self) -> bool:
  return self._connected.is_set()
@@ -362,7 +367,6 @@ def _on_signaling_message(
  signaling_direction: SoraSignalingDirection,
  raw_message: str,
  ):
- print(raw_message)
  message: dict[str, Any] = json.loads(raw_message)
  match message["type"]:
  case "connect":
@@ -389,6 +393,9 @@ def _on_signaling_message(
  case "re-answer":
  assert signaling_direction == SoraSignalingDirection.SENT
  self._re_answer_messages.append(message)
+ case "disconnect":
+ assert signaling_direction == SoraSignalingDirection.SENT
+ self._disconnect_message = message
  case _:
  NotImplementedError(f"Unknown signaling message type: {message['type']}")
 

tests/test_re_offer_re_answer_sdp.py

@@ -0,0 +1,52 @@
+import sys
+import uuid
+
+from client import Recvonly, Sendonly
+
+
+def test_re_offer_re_answer_sdp(setup):
+ signaling_urls = setup.get("signaling_urls")
+ channel_id_prefix = setup.get("channel_id_prefix")
+ metadata = setup.get("metadata")
+
+ channel_id = f"{channel_id_prefix}_{__name__}_{sys._getframe().f_code.co_name}_{uuid.uuid4()}"
+
+ recvonly = Recvonly(
+ signaling_urls,
+ channel_id,
+ metadata=metadata,
+ )
+ recvonly.connect()
+
+ sendonly1 = Sendonly(
+ signaling_urls,
+ channel_id,
+ audio=True,
+ video=True,
+ metadata=metadata,
+ )
+ sendonly1.connect(fake_audio=True, fake_video=True)
+ sendonly1.disconnect()
+
+ sendonly2 = Sendonly(
+ signaling_urls,
+ channel_id,
+ audio=True,
+ video=True,
+ metadata=metadata,
+ )
+ sendonly2.connect(fake_audio=True, fake_video=True)
+
+ sendonly3 = Sendonly(
+ signaling_urls,
+ channel_id,
+ audio=True,
+ video=True,
+ metadata=metadata,
+ )
+ sendonly3.connect(fake_audio=True, fake_video=True)
+
+ sendonly2.disconnect()
+ sendonly3.disconnect()
+
+ recvonly.disconnect()