Knowledge base & RAG

BASE="https://apisandbox.turfai.in/api"
DOC_ID=45

curl -X POST "$BASE/documents/$DOC_ID/enable-rag" \
  -H "Authorization: Bearer $TURFAI_JWT" \
  -H "Content-Type: application/json" \
  -d '{ "force_reprocess": false }'

import os, requests

BASE = "https://apisandbox.turfai.in/api"
HEAD = {"Authorization": f"Bearer {os.environ['TURFAI_JWT']}", "Content-Type": "application/json"}
DOC_ID = 45

r = requests.post(f"{BASE}/documents/{DOC_ID}/enable-rag", headers=HEAD,
                  json={"force_reprocess": False})
r.raise_for_status()
print(r.json())  # {"status": "queued", "job_id": "...", "document_id": "45", ...}

const BASE = "https://apisandbox.turfai.in/api";
const HEAD = {
  Authorization: `Bearer ${process.env.TURFAI_JWT}`,
  "Content-Type": "application/json",
};
const DOC_ID = 45;

const res = await fetch(`${BASE}/documents/${DOC_ID}/enable-rag`, {
  method: "POST",
  headers: HEAD,
  body: JSON.stringify({ force_reprocess: false }),
});
console.log(await res.json()); // { status: "queued", job_id: "...", document_id: "45" }

# Poll once; re-run until processing_status == "completed"
curl -s "$BASE/documents/$DOC_ID/rag-status" \
  -H "Authorization: Bearer $TURFAI_JWT"

import time

while True:
    s = requests.get(f"{BASE}/documents/{DOC_ID}/rag-status", headers=HEAD).json()
    status = s["processing_status"]
    print(status, s.get("chunk_count"))
    if status == "completed":
        break
    if status == "failed":
        raise RuntimeError(s.get("error") or "RAG indexing failed")
    time.sleep(3)

async function waitForRag(docId: number) {
  while (true) {
    const s = await (
      await fetch(`${BASE}/documents/${docId}/rag-status`, { headers: HEAD })
    ).json();
    if (s.processing_status === "completed") return s;
    if (s.processing_status === "failed") throw new Error(s.error ?? "RAG indexing failed");
    await new Promise((r) => setTimeout(r, 3000));
  }
}
await waitForRag(DOC_ID);

curl -X POST "$BASE/rag/query" \
  -H "Authorization: Bearer $TURFAI_JWT" \
  -H "Content-Type: application/json" \
  -d '{
    "query": "What is the remote work policy?",
    "top_k": 5,
    "use_reranking": true,
    "similarity_threshold": 0.3
  }'

r = requests.post(f"{BASE}/rag/query", headers=HEAD, json={
    "query": "What is the remote work policy?",
    "top_k": 5,
    "use_reranking": True,
    "similarity_threshold": 0.3,
})
data = r.json()
print(data["answer"])
for s in data["sources"]:
    print(s["document_title"], round(s["similarity_score"], 2), s.get("signed_url"))

const res = await fetch(`${BASE}/rag/query`, {
  method: "POST",
  headers: HEAD,
  body: JSON.stringify({
    query: "What is the remote work policy?",
    top_k: 5,
    use_reranking: true,
    similarity_threshold: 0.3,
  }),
});
const data = await res.json();
console.log(data.answer);
data.sources.forEach((s: any) => console.log(s.document_title, s.similarity_score));

# Turn 1 — note the session_id in the response
curl -s -X POST "$BASE/rag/query" \
  -H "Authorization: Bearer $TURFAI_JWT" -H "Content-Type: application/json" \
  -d '{ "query": "How many remote days are allowed?" }'

# Turn 2 — pass that session_id so "and for managers?" resolves in context
curl -s -X POST "$BASE/rag/query" \
  -H "Authorization: Bearer $TURFAI_JWT" -H "Content-Type: application/json" \
  -d '{ "query": "And for managers?", "session_id": "sess-abc123" }'

first = requests.post(f"{BASE}/rag/query", headers=HEAD,
                      json={"query": "How many remote days are allowed?"}).json()
sid = first["session_id"]

followup = requests.post(f"{BASE}/rag/query", headers=HEAD,
                         json={"query": "And for managers?", "session_id": sid}).json()
print(followup["answer"])

const first = await (await fetch(`${BASE}/rag/query`, {
  method: "POST", headers: HEAD,
  body: JSON.stringify({ query: "How many remote days are allowed?" }),
})).json();

const followup = await (await fetch(`${BASE}/rag/query`, {
  method: "POST", headers: HEAD,
  body: JSON.stringify({ query: "And for managers?", session_id: first.session_id }),
})).json();
console.log(followup.answer);