import httpx

# Multipart upload via REST API (not available in SDK — use base64 upload below for SDK)
async with httpx.AsyncClient() as http:
    with open("essay.pdf", "rb") as f:
        response = await http.post(
            "https://api.cerebe.ai/api/v1/storage/upload",
            headers={"X-API-Key": "ck_live_..."},
            files={"file": ("essay.pdf", f, "application/pdf")},
            data={
                "session_id": "session_abc",
                "user_id": "user_123",
                "purpose": "assessment",
                "processing": "ocr,summarize",
                "bridge_to_memory": "true",
            },
        )
    result = response.json()

print(f"Upload ID: {result['upload_id']}")
print(f"CDN URL: {result['cdn_url']}")

// Multipart upload via REST API (not available in SDK — use base64 upload below for SDK)
const form = new FormData()
form.append('file', fs.createReadStream('essay.pdf'))
form.append('session_id', 'session_abc')
form.append('user_id', 'user_123')
form.append('purpose', 'assessment')
form.append('processing', 'ocr,summarize')
form.append('bridge_to_memory', 'true')

const response = await fetch('https://api.cerebe.ai/api/v1/storage/upload', {
  method: 'POST',
  headers: { 'X-API-Key': 'ck_live_...' },
  body: form,
})
const result = await response.json()

console.log(`Upload ID: ${result.upload_id}`)
console.log(`CDN URL: ${result.cdn_url}`)

curl -X POST https://api.cerebe.ai/api/v1/storage/upload \
  -H "X-API-Key: ck_live_..." \
  -F "file=@essay.pdf" \
  -F "session_id=session_abc" \
  -F "user_id=user_123" \
  -F "purpose=assessment" \
  -F "processing=ocr,summarize" \
  -F "bridge_to_memory=true"

import base64

with open("image.png", "rb") as f:
    content_b64 = base64.b64encode(f.read()).decode()

result = await client.storage.upload(
    content=content_b64,
    filename="image.png",
    content_type="image/png",
    session_id="session_abc",
    user_id="user_123",
)

curl -X POST https://api.cerebe.ai/api/v1/storage/upload-base64 \
  -H "X-API-Key: ck_live_..." \
  -H "Content-Type: application/json" \
  -d '{
    "content": "iVBORw0KGgo...",
    "filename": "image.png",
    "content_type": "image/png",
    "session_id": "session_abc",
    "user_id": "user_123"
  }'

import httpx

url = await client.storage.get_url(upload_id="upl_a1b2c3d4")

async with httpx.AsyncClient() as http:
    response = await http.get(url)
    response.raise_for_status()
    with open("downloaded.pdf", "wb") as f:
        f.write(response.content)

const { url } = await client.storage.getUrl('upl_a1b2c3d4')

const response = await fetch(url)
fs.writeFileSync('downloaded.pdf', Buffer.from(await response.arrayBuffer()))

curl https://api.cerebe.ai/api/v1/storage/upl_a1b2c3d4/content \
  -H "X-API-Key: ck_live_..." \
  -o downloaded.pdf

presigned = await client.storage.presigned_upload(
    file_name="large-video.mp4",
    file_type="video/mp4",
    file_size=52428800,
    content_hash="sha256_abc123...",
    tenant_id="my_app",
)

print(f"Upload to: {presigned['upload_url']}")
print(f"Expires in: {presigned['expires_in']}s")

# Upload directly to the presigned URL
import httpx
async with httpx.AsyncClient() as http:
    with open("large-video.mp4", "rb") as f:
        await http.put(presigned["upload_url"], content=f.read())

# Step 1: Get presigned URL
curl -X POST https://api.cerebe.ai/api/v1/storage/presigned-upload \
  -H "X-API-Key: ck_live_..." \
  -H "Content-Type: application/json" \
  -d '{
    "file_name": "large-video.mp4",
    "file_type": "video/mp4",
    "file_size": 52428800,
    "content_hash": "sha256_abc123...",
    "tenant_id": "my_app"
  }'

# Step 2: Upload directly to the returned URL
curl -X PUT "<upload_url_from_step_1>" \
  -H "Content-Type: video/mp4" \
  --data-binary @large-video.mp4