把研究问题交给 Agent，
把多源检索交给 LitScout。

export LITSCOUT_BASE_URL="__LITSCOUT_ORIGIN__"
export LITSCOUT_CDK="<LITSCOUT_CDK>"

curl -sS "$LITSCOUT_BASE_URL/api/v1/me/capabilities" \
  -H "Authorization: Bearer $LITSCOUT_CDK" \
  -H "Accept: application/json"

curl -sS "$LITSCOUT_BASE_URL/api/v1/jobs/preview" \
  -H "Authorization: Bearer $LITSCOUT_CDK" \
  -H "Content-Type: application/json" \
  --data @plan.json

curl -sS "$LITSCOUT_BASE_URL/api/v1/jobs" \
  -H "Authorization: Bearer $LITSCOUT_CDK" \
  -H "Idempotency-Key: 7e8f3d5b-6e9d-4b8a-9b5f-4ad31e42d901" \
  -H "Content-Type: application/json" \
  --data @plan.json

curl -sS "$LITSCOUT_BASE_URL/api/v1/jobs/<job_id>" \
  -H "Authorization: Bearer $LITSCOUT_CDK"

curl -sS "$LITSCOUT_BASE_URL/api/v1/jobs/<job_id>/results" \
  -H "Authorization: Bearer $LITSCOUT_CDK"

import asyncio
import os
import uuid

import httpx

BASE_URL = "__LITSCOUT_ORIGIN__"
CDK = os.environ["LITSCOUT_CDK"]
TERMINAL = {"succeeded", "partial", "failed", "cancelled", "expired"}


async def discover(payload: dict) -> dict:
    headers = {"Authorization": f"Bearer {CDK}"}
    async with httpx.AsyncClient(base_url=BASE_URL, headers=headers) as client:
        preview = await client.post("/api/v1/jobs/preview", json=payload)
        preview.raise_for_status()
        if not preview.json()["valid"]:
            raise RuntimeError(preview.json()["denied"])

        accepted = await client.post(
            "/api/v1/jobs",
            json=payload,
            headers={"Idempotency-Key": str(uuid.uuid4())},
        )
        accepted.raise_for_status()
        job_id = accepted.json()["jobId"]

        while True:
            job = (await client.get(f"/api/v1/jobs/{job_id}")).json()
            if job["status"] in TERMINAL:
                break
            await asyncio.sleep(job.get("pollAfterSeconds", 2))

        result = await client.get(f"/api/v1/jobs/{job_id}/results")
        result.raise_for_status()
        return result.json()

import os

from litscout_client import LitScoutClient


async with LitScoutClient(
    base_url="__LITSCOUT_ORIGIN__",
    cdk=os.environ["LITSCOUT_CDK"],
) as client:
    capabilities = await client.capabilities()
    bundle = await client.discover(payload, timeout=300)

    job = bundle["job"]
    papers = bundle["results"]["items"]
    source_runs = job["sourceRuns"]