Function doctor

src/cocoindex_code/client.py:362–394

Run doctor checks via daemon, streaming results to on_result callback.

(
    project_root: str | None = None,
    on_result: Callable[[DoctorCheckResult], None] | None = None,
)

def doctor(
    project_root: str | None = None,
    on_result: Callable[[DoctorCheckResult], None] | None = None,
) -> list[DoctorCheckResult]:
    """Run doctor checks via daemon, streaming results to on_result callback."""
    if project_root is not None:
        project_root = normalize_input_path(project_root)
    conn = _connect_and_handshake()
    try:
        conn.send_bytes(encode_request(DoctorRequest(project_root=project_root)))
        results: list[DoctorCheckResult] = []
        while True:
            try:
                data = conn.recv_bytes()
            except EOFError:
                raise RuntimeError("Connection to daemon lost during doctor checks")
            resp = decode_response(data)
            if isinstance(resp, ErrorResponse):
                detail = f"Daemon error: {resp.message}"
                if resp.traceback:
                    detail += f"\n{resp.traceback}"
                raise RuntimeError(detail)
            if isinstance(resp, DoctorResponse):
                results.append(resp.result)
                if on_result is not None:
                    on_result(resp.result)
                if resp.final:
                    break
            else:
                raise RuntimeError(f"Unexpected response: {type(resp).__name__}")
        return results
    finally:
        conn.close()


# ---------------------------------------------------------------------------