Method _read_message

python/copilot/_jsonrpc.py:329–355

Read a single JSON-RPC message with a Content-Length header (blocking). Returns: Parsed JSON message, or None if the connection is closed.

(self)

        return b"".join(chunks)

    def _read_message(self) -> dict | None:
        """
        Read a single JSON-RPC message with a Content-Length header (blocking).

        Returns:
            Parsed JSON message, or None if the connection is closed.
        """
        # Read header line
        header_line = self.process.stdout.readline()
        if not header_line:
            return None

        # Parse Content-Length
        header = header_line.decode("utf-8").strip()
        if not header.startswith("Content-Length:"):
            return None

        content_length = int(header.split(":")[1].strip())

        # Read empty line
        self.process.stdout.readline()

        # Read exact content using loop to handle short reads
        content_bytes = self._read_exact(content_length)
        content = content_bytes.decode("utf-8")

        return json.loads(content)

    def _handle_message(self, message: dict):
        """Handle an incoming message (response or notification)"""