REST API - knowledge

import httpx
r = httpx.post(
    "https://primer.example/v1/ssp",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "id": "pg-main",
        "provider": "pgvector",
        "config": {
            "hostname": "localhost",
            "port": 5432,
            "database": "primer_prod",
            "username": "primer",
            "password": "secret",
            "db_schema": "public",
            "distance_metric": "cosine",
        },
    },
)
r.raise_for_status()

await fetch("/v1/ssp", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    id: "pg-main",
    provider: "pgvector",
    config: {
      hostname: "localhost",
      port: 5432,
      database: "primer_prod",
      username: "primer",
      password: "secret",
      db_schema: "public",
      distance_metric: "cosine",
    },
  }),
});

import httpx
r = httpx.post(
    "https://primer.example/v1/embedding_providers",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "id": "lmstudio-embed",
        "provider": "openai",
        "models": [{"name": "nomic-embed-text-v1.5"}],
        "config": {
            "url": "http://localhost:1234/v1",
            "api_key": "lm-studio",
            "flavor": "lmstudio",
        },
        "limits": {"max_concurrency": 2},
    },
)
r.raise_for_status()

await fetch("/v1/embedding_providers", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    id: "lmstudio-embed",
    provider: "openai",
    models: [{ name: "nomic-embed-text-v1.5" }],
    config: { url: "http://localhost:1234/v1", api_key: "lm-studio", flavor: "lmstudio" },
    limits: { max_concurrency: 2 },
  }),
});

import httpx
r = httpx.post(
    "https://primer.example/v1/collections",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "id": "company-docs",
        "description": "Internal company documentation",
        "embedder": {
            "provider_id": "lmstudio-embed",
            "model": "nomic-embed-text-v1.5",
        },
        "search_provider_id": "pg-main",
        "system": False,
    },
)
r.raise_for_status()

await fetch("/v1/collections", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    id: "company-docs",
    description: "Internal company documentation",
    embedder: { provider_id: "lmstudio-embed", model: "nomic-embed-text-v1.5" },
    search_provider_id: "pg-main",
    system: false,
  }),
});

import httpx
r = httpx.post(
    "https://primer.example/v1/documents",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "id": "doc-postmortem-001",
        "collection_id": "company-docs",
        "name": "Q1 post-mortem",
        "path": "postmortems/q1.md",
        "meta": {"text": "We experienced a 30-minute outage on March 3..."},
    },
)
r.raise_for_status()

await fetch("/v1/documents", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    id: "doc-postmortem-001",
    collection_id: "company-docs",
    name: "Q1 post-mortem",
    path: "postmortems/q1.md",
    meta: { text: "We experienced a 30-minute outage on March 3..." },
  }),
});

import httpx
r = httpx.put(
    "https://primer.example/v1/documents/doc-postmortem-001",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "id": "doc-postmortem-001",
        "collection_id": "company-docs",
        "name": "Q1 post-mortem (revised)",
        "path": "postmortems/q1.md",
        "meta": {"text": "Updated analysis: root cause was a misconfigured timeout..."},
    },
)
r.raise_for_status()

await fetch("/v1/documents/doc-postmortem-001", {
  method: "PUT",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    id: "doc-postmortem-001",
    collection_id: "company-docs",
    name: "Q1 post-mortem (revised)",
    path: "postmortems/q1.md",
    meta: { text: "Updated analysis: root cause was a misconfigured timeout..." },
  }),
});

import httpx
r = httpx.get(
    "https://primer.example/v1/collections/company-docs/documents",
    headers={"Authorization": f"Bearer {token}"},
)
docs = r.json()["documents"]

const r = await fetch("/v1/collections/company-docs/documents", {
  headers: { "Authorization": `Bearer ${token}` },
});
const { documents } = await r.json();

import httpx
r = httpx.get(
    "https://primer.example/v1/collections/company-docs/documents",
    params={"path": "postmortems/q1.md"},
    headers={"Authorization": f"Bearer {token}"},
)
result = r.json()

const r = await fetch(
  "/v1/collections/company-docs/documents?path=postmortems/q1.md",
  { headers: { "Authorization": `Bearer ${token}` } },
);
const result = await r.json();

import httpx
r = httpx.put(
    "https://primer.example/v1/collections/company-docs/documents",
    params={"path": "postmortems/q1.md"},
    headers={"Authorization": f"Bearer {token}"},
    json={"content": "We experienced a 30-minute outage on March 3...", "title": "Q1 post-mortem"},
)
r.raise_for_status()

await fetch("/v1/collections/company-docs/documents?path=postmortems/q1.md", {
  method: "PUT",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ content: "We experienced a 30-minute outage on March 3...", title: "Q1 post-mortem" }),
});

import httpx
r = httpx.delete(
    "https://primer.example/v1/collections/company-docs/documents",
    params={"path": "postmortems/q1.md"},
    headers={"Authorization": f"Bearer {token}"},
)
r.raise_for_status()  # 204

await fetch("/v1/collections/company-docs/documents?path=postmortems/q1.md", {
  method: "DELETE",
  headers: { "Authorization": `Bearer ${token}` },
});

import httpx
r = httpx.post(
    "https://primer.example/v1/collections/company-docs/documents/move",
    headers={"Authorization": f"Bearer {token}"},
    json={"from": "postmortems/q1.md", "to": "archive/postmortems/q1.md"},
)
r.raise_for_status()  # 204

await fetch("/v1/collections/company-docs/documents/move", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ from: "postmortems/q1.md", to: "archive/postmortems/q1.md" }),
});

import httpx
r = httpx.post(
    "https://primer.example/v1/collections/company-docs/search",
    headers={"Authorization": f"Bearer {token}"},
    json={"query": "what caused the outage", "top_k": 5},
)
hits = r.json()["hits"]

const r = await fetch("/v1/collections/company-docs/search", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ query: "what caused the outage", top_k: 5 }),
});
const { hits } = await r.json();

import httpx
r = httpx.get(
    "https://primer.example/v1/collections/company-docs/indexed_documents",
    params={"document_id": "doc-postmortem-001"},
    headers={"Authorization": f"Bearer {token}"},
)
result = r.json()

const r = await fetch(
  "/v1/collections/company-docs/indexed_documents?document_id=doc-postmortem-001",
  { headers: { "Authorization": `Bearer ${token}` } },
);
const result = await r.json();

import httpx
with open("note.md", "rb") as f:
    r = httpx.post(
        "https://primer.example/v1/documents/_convert_file",
        headers={"Authorization": f"Bearer {token}"},
        files={"file": ("note.md", f, "text/markdown")},
    )
text = r.json()["text"]

const fd = new FormData();
fd.append("file", fileBlob, "note.md");
const r = await fetch("/v1/documents/_convert_file", {
  method: "POST",
  headers: { "Authorization": `Bearer ${token}` },
  body: fd,
});
const { text } = await r.json();

import httpx
r = httpx.put(
    "https://primer.example/v1/internal_collections/config",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "embedding_provider_id": "lmstudio-embed",
        "embedding_model": "nomic-embed-text-v1.5",
        "search_provider_id": "pg-main",
    },
)
r.raise_for_status()

await fetch("/v1/internal_collections/config", {
  method: "PUT",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    embedding_provider_id: "lmstudio-embed",
    embedding_model: "nomic-embed-text-v1.5",
    search_provider_id: "pg-main",
  }),
});

import httpx, time
r = httpx.post(
    "https://primer.example/v1/internal_collections/bootstrap",
    headers={"Authorization": f"Bearer {token}"},
)
assert r.status_code == 202

# Poll until done
while True:
    s = httpx.get(
        "https://primer.example/v1/internal_collections/bootstrap/status",
        headers={"Authorization": f"Bearer {token}"},
    )
    if s.json()["status"] == "succeeded":
        break
    time.sleep(1)

const boot = await fetch("/v1/internal_collections/bootstrap", {
  method: "POST",
  headers: { "Authorization": `Bearer ${token}` },
});
// boot.status === 202; poll status

import httpx
r = httpx.delete(
    "https://primer.example/v1/internal_collections/config",
    headers={"Authorization": f"Bearer {token}"},
)
r.raise_for_status()  # 204

await fetch("/v1/internal_collections/config", {
  method: "DELETE",
  headers: { "Authorization": `Bearer ${token}` },
});

import httpx
r = httpx.post(
    "https://primer.example/v1/agents/search",
    headers={"Authorization": f"Bearer {token}"},
    json={"query": "data science automation", "top_k": 5},
)
hits = r.json()["hits"]

const r = await fetch("/v1/agents/search", {
  method: "POST",
  headers: {
    "Authorization": `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ query: "data science automation", top_k: 5 }),
});
const { hits } = await r.json();