Upload 3 files

Dockerfile

@@ -12,7 +12,6 @@ ENV PYTHONUNBUFFERED=1 \
 RUN apt-get update && apt-get install -y --no-install-recommends \
     ffmpeg \
     fonts-dejavu-core \
-    libmagic1 \
     ca-certificates \
     && rm -rf /var/lib/apt/lists/*
 

api.py

@@ -1,14 +1,19 @@
 from __future__ import annotations
 
+import json
+import shutil
+import uuid
 from pathlib import Path
 from typing import Any
 
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI, File, Form, HTTPException, UploadFile
 from fastapi.responses import FileResponse
 from pydantic import BaseModel, Field
 
 from renderer.core.config import Settings
+from renderer.core.ingest import stage_upload
 from renderer.core.models import AIReelsRequest, RenderRequest, Scene
+from renderer.core.utils import safe_filename
 from renderer.jobs import JobManager
 from renderer.scenes import Timeline
 
@@ -51,6 +56,12 @@ class BatchPayload(BaseModel):
     jobs: list[RenderPayload]
 
 
+class UploadedAsset(BaseModel):
+    filename: str
+    path: str
+    reference: str
+
+
 @api.get("/health")
 def health() -> dict[str, str]:
     return {"status": "ok"}
@@ -77,6 +88,33 @@ def render_batch(payload: BatchPayload) -> dict[str, list[str]]:
     return {"job_ids": job_ids}
 
 
+@api.post("/render/upload")
+async def render_upload(request_json: str = Form(...), files: list[UploadFile] = File(default=[])) -> dict[str, str]:
+    uploads = await _stage_uploads(files)
+    payload_data = _replace_upload_refs(json.loads(request_json), uploads)
+    payload = RenderPayload.model_validate(payload_data)
+    job_id = job_manager.submit_render(_render_request(payload))
+    return {"job_id": job_id, "status_url": f"/status/{job_id}", "download_url": f"/download/{job_id}"}
+
+
+@api.post("/render/ai-reels/upload")
+async def render_ai_reels_upload(request_json: str = Form(...), files: list[UploadFile] = File(default=[])) -> dict[str, str]:
+    uploads = await _stage_uploads(files)
+    payload_data = _replace_upload_refs(json.loads(request_json), uploads)
+    payload = AIReelsPayload.model_validate(payload_data)
+    job_id = job_manager.submit_ai_reels(AIReelsRequest(**payload.model_dump()))
+    return {"job_id": job_id, "status_url": f"/status/{job_id}", "download_url": f"/download/{job_id}"}
+
+
+@api.post("/assets/upload")
+async def upload_assets(files: list[UploadFile] = File(...)) -> dict[str, list[UploadedAsset]]:
+    uploads = await _stage_uploads(files)
+    assets = [
+        UploadedAsset(filename=filename, path=path, reference=f"upload://{filename}") for filename, path in uploads.items()
+    ]
+    return {"assets": [asset.model_dump() for asset in assets]}
+
+
 @api.get("/status/{job_id}")
 def status(job_id: str) -> dict:
     try:
@@ -122,3 +160,38 @@ def _render_request(payload: RenderPayload) -> RenderRequest:
     )
     Timeline(request.scenes)
     return request
+
+
+async def _stage_uploads(files: list[UploadFile]) -> dict[str, str]:
+    upload_dir = settings.temp_dir / "uploads" / uuid.uuid4().hex
+    staged: dict[str, str] = {}
+    total_bytes = 0
+    for upload in files:
+        filename = safe_filename(upload.filename or f"asset_{len(staged)}")
+        target = upload_dir / filename
+        target.parent.mkdir(parents=True, exist_ok=True)
+        with target.open("wb") as output:
+            while True:
+                chunk = await upload.read(1024 * 1024)
+                if not chunk:
+                    break
+                total_bytes += len(chunk)
+                if total_bytes > settings.max_download_bytes:
+                    shutil.rmtree(upload_dir, ignore_errors=True)
+                    raise HTTPException(status_code=413, detail="Uploaded assets exceed MAX_DOWNLOAD_BYTES")
+                output.write(chunk)
+        staged[filename] = str(stage_upload(target, upload_dir, filename))
+    return staged
+
+
+def _replace_upload_refs(value: Any, uploads: dict[str, str]) -> Any:
+    if isinstance(value, dict):
+        return {key: _replace_upload_refs(item, uploads) for key, item in value.items()}
+    if isinstance(value, list):
+        return [_replace_upload_refs(item, uploads) for item in value]
+    if isinstance(value, str) and value.startswith("upload://"):
+        name = safe_filename(value.removeprefix("upload://"))
+        if name not in uploads:
+            raise HTTPException(status_code=400, detail=f"Missing uploaded file for reference: upload://{name}")
+        return uploads[name]
+    return value

app.py

@@ -15,7 +15,7 @@ from renderer.templates import list_templates
 
 
 def create_dashboard() -> gr.Blocks:
-    with gr.Blocks(title="Basyx FFmpeg Rendering Engine") as demo:
+    with gr.Blocks(title="Basyx FFmpeg Rendering Engine") as dashboard:
         gr.Markdown(
             "# Basyx FFmpeg Rendering Engine\n"
             "CPU-first rendering backend for reels, shorts, audiograms, captions, slideshows, and batch jobs."
@@ -70,7 +70,7 @@ def create_dashboard() -> gr.Blocks:
             inspect_output = gr.JSON(label="Metadata")
             inspect_button.click(fn=_inspect_asset, inputs=asset_path, outputs=inspect_output)
 
-    return demo
+    return dashboard
 
 
 def _submit_render_json(payload: str) -> dict[str, Any]: