REST Interface — File Upload and Chat

curl -s -X POST http://localhost:8080/api/auth/token \
  -H 'Content-Type: application/json' \
  -d '{"username": "api-user", "password": "your-password"}'

curl -s -X POST http://localhost:8080/api/auth/token \
  -H 'Content-Type: application/json' \
  -d '{"idpToken": "<token from your login provider>"}'

{
  "token": "eyJhbGciOiJSUzI1NiIsImtpZCI6Ii4uLiJ9...",
  "tokenType": "Bearer",
  "expiresIn": 3600,
  "username": "api-user",
  "roles": ["API"],
  "permissions": ["API_ACCESS", "TOPIC_CHAT", "TOPIC_UPLOAD", "TOPIC_VIEW"],
  "topics": [
    { "id": "3f8b2c1a-...", "name": "HR_Assistant", "status": "RUNNING",
      "publicUrl": "https://hr-assistant.kf.example.com" }
  ],
  "graphRagTopics": [],
  "agents": [],
  "pipelines": []
}

TOKEN=$(curl -s -X POST http://localhost:8080/api/auth/token \
  -H 'Content-Type: application/json' \
  -d '{"username":"api-user","password":"your-password"}' | jq -r .token)

curl -N -s -X POST http://localhost:8081/chatbot/stream \
  -H "Authorization: Bearer $TOKEN" \
  -F 'memoryId=session-42' \
  -F 'prompt=How many vacation days do I get after five years?'

curl -s -X POST http://localhost:8081/chatbot/chat \
  -H "Authorization: Bearer $TOKEN" \
  -F 'memoryId=session-42' \
  -F 'prompt=How many vacation days do I get after five years?'

{
  "answer": "After five years of service you are entitled to 30 days.",
  "sourceFiles": [
    {
      "fileName": "hr-policy.pdf",
      "origin": "DOCUMENT",
      "downloadToken": "eyJhbGciOiJIUzI1NiJ9...",
      "caption": null,
      "page": null,
      "documentFileName": null,
      "downloadPath": "/embeddings/file/download?fileName=hr-policy.pdf&token=eyJhbGciOiJIUzI1NiJ9...",
      "downloadUrl": "https://hr-assistant.kf.example.com/embeddings/file/download?fileName=hr-policy.pdf&token=eyJhbGciOiJIUzI1NiJ9...",
      "resourceId": "3f8b2c1a-..."
    }
  ],
  "notices": []
}

{ "kind": "ACCESS_DENIED", "source": "Finance", "message": "You have no permission to use the topic \"Finance\", so it was left out of this answer." }

curl -s -X POST http://localhost:8081/chatbot/chat \
  -H "Authorization: Bearer $TOKEN" \
  -F 'memoryId=session-42' \
  -F 'prompt=Summarise the attached report.' \
  -F 'files=@quarterly-report.pdf'

curl -s -X POST "http://localhost:8081/chatbot/chat/abort?memoryId=session-42" \
  -H "Authorization: Bearer $TOKEN"

curl -s -X POST "http://localhost:8081/embeddings/embed?strategy=SEMANTIC" \
  -H "Authorization: Bearer $TOKEN" \
  -F 'file=@hr-policy.pdf' \
  --form-string 'doclingOptions={"do_ocr": false, "ocr_lang": ["de", "en"]}'

for f in ./docs/*.pdf; do
  echo "Ingesting $f"
  curl -s -f -X POST http://localhost:8081/embeddings/embed \
    -H "Authorization: Bearer $TOKEN" \
    -F "file=@$f" \
    || echo "FAILED: $f"
done

# With your normal token — the usual case for a script
curl -s -o hr-policy.pdf \
  "http://localhost:8081/embeddings/file/download?fileName=hr-policy.pdf" \
  -H "Authorization: Bearer $TOKEN"

# With the downloadToken from a chat answer — no header, so this link also works in a browser
curl -s -o hr-policy.pdf \
  "http://localhost:8081/embeddings/file/download?fileName=hr-policy.pdf&token=$DOWNLOAD_TOKEN"

import json
import requests

APP, TOPIC = "http://localhost:8080", "http://localhost:8081"

token = requests.post(f"{APP}/api/auth/token",
                      json={"username": "api-user", "password": "your-password"},
                      timeout=30).json()["token"]
headers = {"Authorization": f"Bearer {token}"}

# Upload — allow plenty of time; indexing is synchronous
with open("hr-policy.pdf", "rb") as fh:
    requests.post(f"{TOPIC}/embeddings/embed", headers=headers,
                  files={"file": ("hr-policy.pdf", fh)},
                  data={"doclingOptions": json.dumps({"do_ocr": False})},  # optional
                  timeout=600).raise_for_status()

# Ask — whole answer at once
form = {"memoryId": (None, "py-1"),
        "prompt": (None, "How many vacation days after five years?")}
# To attach a file, add: form["files"] = ("report.pdf", open("report.pdf", "rb"))
r = requests.post(f"{TOPIC}/chatbot/chat", headers=headers, files=form, timeout=300)
r.raise_for_status()
answer = r.json()
print(answer["answer"], [s["fileName"] for s in answer["sourceFiles"]])

import json
import requests

def sse_events(response):
    """Yields (event, data) pairs. Joins multi-line data with \n and keeps leading spaces."""
    event, data = None, None
    for line in response.iter_lines(decode_unicode=True):
        if line == "":                       # a blank line ends an event
            if data is not None:
                yield event or "message", "\n".join(data)
            event, data = None, None
        elif line.startswith(":"):           # comment line
            continue
        else:
            field, _, value = line.partition(":")
            if field == "event":
                event = value.strip()
            elif field == "data":
                data = (data or []) + [value]  # value exactly as sent

form = {"memoryId": (None, "py-2"),
        "prompt": (None, "How many vacation days after five years?")}
with requests.post(f"{TOPIC}/chatbot/stream", headers=headers, files=form,
                   stream=True, timeout=300) as r:
    r.raise_for_status()
    r.encoding = "utf-8"                     # the stream has no charset; requests would guess wrong
    answer = ""
    for event, data in sse_events(r):
        if event == "token":
            answer += data
            print(data, end="", flush=True)
        elif event == "done":
            done = json.loads(data)
            print("\nSources:", [s["fileName"] for s in done["sourceFiles"]])
            for notice in done["notices"]:
                print("Note:", notice["message"])
        elif event == "error":
            raise RuntimeError(json.loads(data)["message"])