tests/test_team_ws_isolation.py

• daemon · function · L28-L36 — def daemon(tmp_path: Path)
• _RawStream · class · L39-L59 — class _RawStream
• init · method · L47-L49 — def init(self, sock: socket.socket, initial: bytes = b"")
• read · method · L51-L59 — def read(self, n: int) -> bytes
• _WSClient · class · L62-L114 — class _WSClient
• init · method · L65-L87 — def init(self, port: int, cookie: str)
• send · method · L89-L92 — def send(self, obj: dict) -> None
• recv_json · method · L94-L108 — def recv_json(self, timeout: float = 5.0) -> dict | None
• close · method · L110-L114 — def close(self) -> None
• _session_for · function · L117-L124 — def _session_for(daemon, cookie: str) -> str
• test_cross_user_subscription_is_denied · function · L127-L142 — def test_cross_user_subscription_is_denied(daemon)
• test_own_subscription_streams_and_foreign_broadcast_does_not_arrive · function · L145-L173 — def test_own_subscription_streams_and_foreign_broadcast_does_not_arrive(daemon)
• test_admin_may_subscribe_to_any_session · function · L176-L188 — def test_admin_may_subscribe_to_any_session(daemon)
• test_unknown_session_id_cannot_be_pre_subscribed · function · L191-L200 — def test_unknown_session_id_cannot_be_pre_subscribed(daemon)
• test_cross_user_ws_cancel_is_refused · function · L203-L225 — def test_cross_user_ws_cancel_is_refused(daemon)
• test_project_member_may_view_but_cannot_cancel_the_owners_execution · function · L229-L269 — def test_project_member_may_view_but_cannot_cancel_the_owners_execution(daemon)
• test_owner_and_admin_may_cancel_an_execution_over_ws · function · L274-L302 — def test_owner_and_admin_may_cancel_an_execution_over_ws(daemon, username)
• cancel · function · L282-L284 — def cancel(args, *kwargs)
• test_a_live_stream_stops_when_the_subscription_is_revoked · function · L305-L355 — def test_a_live_stream_stops_when_the_subscription_is_revoked(daemon)