Files & RAG

import httpx

client = httpx.Client(headers={"Authorization": "Bearer rsk_..."})

# Register the file
init = client.post(
    "https://api.meshapi.ai/v1/files",
    json={
        "file_name": "handbook.pdf",
        "mime_type": "application/pdf",
        "embed": True,
    },
).json()

file_id = init["file_id"]
signed_url = init["signed_url"]

# Upload bytes to the signed URL. No auth header; send required_headers verbatim.
with open("handbook.pdf", "rb") as f:
    httpx.put(signed_url, content=f.read(), headers=init["required_headers"])

print(f"File ID: {file_id}")

import fs from "fs";

const init = await fetch("https://api.meshapi.ai/v1/files", {
  method: "POST",
  headers: {
    Authorization: "Bearer <YOUR_RSK_KEY>",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    file_name: "handbook.pdf",
    mime_type: "application/pdf",
    embed: true,
  }),
}).then((r) => r.json());

const { file_id, signed_url, required_headers } = init;

// Upload bytes directly to the signed URL, sending required_headers verbatim
await fetch(signed_url, {
  method: "PUT",
  headers: required_headers,
  body: fs.readFileSync("handbook.pdf"),
});

console.log("File ID:", file_id);

import time

deadline = time.monotonic() + 600
while True:
    status = client.get(f"https://api.meshapi.ai/v1/files/{file_id}").json()
    print(status["upload_status"], status["embedding_status"])
    if status["upload_status"] == "failed" or status["embedding_status"] in ("ready", "failed"):
        break
    if time.monotonic() > deadline:
        raise TimeoutError(f"file {file_id} not ready after 10 minutes")
    time.sleep(3)

const poll = async () => {
  const deadline = Date.now() + 10 * 60 * 1000;
  while (true) {
    const status = await fetch(
      `https://api.meshapi.ai/v1/files/${file_id}`,
      { headers: { Authorization: "Bearer <YOUR_RSK_KEY>" } }
    ).then((r) => r.json());

    console.log(status.upload_status, status.embedding_status);
    if (status.upload_status === "failed" || ["ready", "failed"].includes(status.embedding_status)) break;
    if (Date.now() > deadline) throw new Error(`file ${file_id} not ready after 10 minutes`);
    await new Promise((r) => setTimeout(r, 3000));
  }
};
await poll();

results = client.post(
    "https://api.meshapi.ai/v1/files/search",
    json={
        "query": "What is the refund policy?",
        "top_k": 5,
    },
).json()

for r in results["results"]:
    print(f"[{r['score']:.3f}] {r['text'][:200]}")

const results = await fetch("https://api.meshapi.ai/v1/files/search", {
  method: "POST",
  headers: {
    Authorization: "Bearer <YOUR_RSK_KEY>",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    query: "What is the refund policy?",
    top_k: 5,
  }),
}).then((r) => r.json());

for (const r of results.results) {
  console.log(`[${r.score.toFixed(3)}] ${r.text.slice(0, 200)}`);
}

const API = "https://api.meshapi.ai";
const headers = {
  Authorization: "Bearer <YOUR_RSK_KEY>",
  "Content-Type": "application/json",
};

const question = "What is the refund policy?";

// 1. Retrieve relevant chunks
const search = await fetch(`${API}/v1/files/search`, {
  method: "POST",
  headers,
  body: JSON.stringify({ query: question, top_k: 3 }),
}).then((r) => r.json());

const context = search.results.map((r: any) => r.text).join("\n\n");

// 2. Ask the model
const chat = await fetch(`${API}/v1/chat/completions`, {
  method: "POST",
  headers,
  body: JSON.stringify({
    model: "openai/gpt-4o-mini",
    messages: [
      {
        role: "system",
        content: `Answer using only the context below.\n\n${context}`,
      },
      { role: "user", content: question },
    ],
  }),
}).then((r) => r.json());

console.log(chat.choices[0].message.content);

resp = client.delete(f"https://api.meshapi.ai/v1/files/{file_id}")
resp.raise_for_status()
print(resp.status_code)  # 204

const resp = await fetch(`https://api.meshapi.ai/v1/files/${file_id}`, {
  method: "DELETE",
  headers: { Authorization: "Bearer <YOUR_RSK_KEY>" },
});

console.log(resp.status); // 204