Method _send_request_once

unity_cli/client.py:288–355

Send a single REQUEST message (no retry). Args: request_id: Unique request identifier. command: Command name. params: Command parameters. timeout_ms: Command timeout in milliseconds. Returns: Response data dictionary.

(
        self,
        request_id: str,
        command: str,
        params: dict[str, Any],
        timeout_ms: int,
    )

        time.sleep(backoff_ms / 1000)

    def _send_request_once(
        self,
        request_id: str,
        command: str,
        params: dict[str, Any],
        timeout_ms: int,
    ) -> dict[str, Any]:
        """Send a single REQUEST message (no retry).

        Args:
            request_id: Unique request identifier.
            command: Command name.
            params: Command parameters.
            timeout_ms: Command timeout in milliseconds.

        Returns:
            Response data dictionary.
        """
        message: dict[str, Any] = {
            "type": "REQUEST",
            "id": request_id,
            "command": command,
            "params": params,
            "timeout_ms": timeout_ms,
            "ts": int(time.time() * 1000),
        }

        if self.instance:
            message["instance"] = self.instance

        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        try:
            try:
                sock.settimeout(self.timeout)
                sock.connect((self.host, self.port))
            except OSError as e:
                raise ConnectionError(
                    f"Cannot connect to Relay Server at {self.host}:{self.port}.\n"
                    "Please ensure the relay server is running:\n"
                    "  $ python -m relay.server --port 6500",
                    "CONNECTION_FAILED",
                ) from e

            self._write_frame(sock, message)

            try:
                response = self._read_frame(sock)
            except builtins.TimeoutError as e:
                raise TimeoutError(
                    f"Response timed out for '{command}' (timeout: {self.timeout}s)",
                    "TIMEOUT",
                ) from e

            if self.on_send:
                try:
                    self.on_send(message, response)
                except Exception as cb_err: