Method send_raw

examples/API Test/test_api.py:311–358

Send bytes; if expected_id is set, skip push notifications until that response arrives.

(
        self,
        data: bytes,
        expected_id: Optional[str] = None,
        timeout: float = SOCKET_TIMEOUT,
    )

            return None

    def send_raw(
        self,
        data: bytes,
        expected_id: Optional[str] = None,
        timeout: float = SOCKET_TIMEOUT,
    ) -> Optional[dict]:
        """Send bytes; if expected_id is set, skip push notifications until that response arrives."""
        if not self.socket:
            return None

        try:
            if self.verbose:
                print(f"[SEND] {data.decode('utf-8', errors='replace').strip()}")

            self.socket.sendall(data)

            if expected_id:
                end_time = time.time() + timeout
                while True:
                    remaining = end_time - time.time()
                    if remaining <= 0:
                        if self.verbose:
                            print(
                                f"[ERROR] Timeout waiting for response ID {expected_id}"
                            )
                        return None

                    msg = self.recv_message(timeout=remaining)
                    if not msg:
                        return None

                    if (
                        msg.get("type") == MessageType.RESPONSE
                        and msg.get("id") == expected_id
                    ):
                        return msg

                    if self.verbose:
                        print(
                            f"[DEBUG] Discarding push notification while waiting for {expected_id}"
                        )
            else:
                return self.recv_message(timeout=timeout)

        except Exception as e:
            if self.verbose:
                print(f"[ERROR] {e}")
            return None

    def send_json(self, obj: dict) -> Optional[dict]:
        data = json.dumps(obj, separators=(",", ":")) + "\n"