feat: build complete ReliefLensAI backend

Full multimodal disaster triage backend including:
- FastAPI app with CORS, lifespan, health check
- Pydantic v2 schemas: report, signal, incident, resource, dispatch, amd, crisis_room
- 11 skills: transcribe_audio, caption_image, extract_location, normalize_signal,
detect_duplicates, classify_priority, recommend_resources, generate_dispatch_message,
calculate_confidence, fetch_amd_metrics, export_incident_report
- 8 agents: intake, transcription, vision, normalization, dedup, triage, resource, dispatch
- Services: vLLM client (demo+real mode), storage (file-backed JSON cache), pipeline
- API routes: /crisis-room, /reports, /incidents, /amd, /demo
- Demo data: 29-report Santa Ana flood scenario (text/audio/image/csv)
- Tests: 30 passing across schemas, skills, and API
- Docker, .env.example, setup/run scripts
- Demo mode enabled by default (no external dependencies required)

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Co-authored-by: IngSeb0 <141876214+IngSeb0@users.noreply.github.com>

backend/.env.example

@@ -0,0 +1,13 @@
+# AMD / vLLM Settings
+VLLM_BASE_URL=http://localhost:8000/v1
+VLLM_API_KEY=not-needed
+VLLM_MODEL=Qwen/Qwen2.5-72B-Instruct
+VLLM_VISION_MODEL=Qwen/Qwen2-VL-7B-Instruct
+
+# App Settings
+APP_ENV=development
+DEBUG=true
+DEMO_MODE=true
+
+# Storage
+STORAGE_PATH=./data

backend/Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    build-essential \
+    && rm -rf /var/lib/apt/lists/*
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY . .
+
+RUN mkdir -p data
+
+EXPOSE 8080
+
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8080"]

backend/agents/__init__.py

@@ -0,0 +1,19 @@
+from .intake_agent import IntakeAgent
+from .transcription_agent import TranscriptionAgent
+from .vision_agent import VisionAgent
+from .normalization_agent import NormalizationAgent
+from .dedup_agent import DedupAgent
+from .triage_agent import TriageAgent
+from .resource_agent import ResourceAgent
+from .dispatch_agent import DispatchAgent
+
+__all__ = [
+    "IntakeAgent",
+    "TranscriptionAgent",
+    "VisionAgent",
+    "NormalizationAgent",
+    "DedupAgent",
+    "TriageAgent",
+    "ResourceAgent",
+    "DispatchAgent",
+]

backend/agents/dedup_agent.py

@@ -0,0 +1,19 @@
+from __future__ import annotations
+import logging
+from typing import List
+
+from schemas.signal import NormalizedSignal
+from skills.detect_duplicates import detect_duplicates
+
+logger = logging.getLogger(__name__)
+
+
+class DedupAgent:
+    def __init__(self, threshold: float = 0.75) -> None:
+        self.threshold = threshold
+
+    async def run(self, signals: List[NormalizedSignal]) -> List[NormalizedSignal]:
+        logger.info("DedupAgent: processing %d signals", len(signals))
+        unique = await detect_duplicates(signals, threshold=self.threshold)
+        logger.info("DedupAgent: %d unique signals after dedup", len(unique))
+        return unique

backend/agents/dispatch_agent.py

@@ -0,0 +1,39 @@
+from __future__ import annotations
+import logging
+from typing import Any, List
+
+from schemas.dispatch import DispatchMessage
+from schemas.incident import Incident
+from schemas.resource import ResourceRecommendation
+from skills.generate_dispatch_message import generate_dispatch_message
+
+logger = logging.getLogger(__name__)
+
+
+class DispatchAgent:
+    def __init__(self, vllm_client: Any = None) -> None:
+        self.vllm_client = vllm_client
+
+    async def run(
+        self,
+        incidents: List[Incident],
+        all_resources: List[ResourceRecommendation],
+    ) -> List[DispatchMessage]:
+        logger.info("DispatchAgent: generating messages for %d incidents", len(incidents))
+        messages: List[DispatchMessage] = []
+        resource_by_incident = {}
+        for r in all_resources:
+            resource_by_incident.setdefault(r.incident_id, []).append(r)
+
+        for incident in incidents:
+            incident_resources = resource_by_incident.get(incident.id, [])
+            msg = await generate_dispatch_message(
+                incident,
+                incident_resources,
+                channel="radio",
+                vllm_client=self.vllm_client,
+            )
+            messages.append(msg)
+
+        logger.info("DispatchAgent: generated %d dispatch messages", len(messages))
+        return messages

backend/agents/intake_agent.py

@@ -0,0 +1,39 @@
+from __future__ import annotations
+import logging
+from datetime import datetime
+
+from schemas.report import ReportInput, ReportType
+from schemas.signal import NormalizedSignal, SignalType
+
+logger = logging.getLogger(__name__)
+
+
+class IntakeAgent:
+    async def run(self, report: ReportInput) -> NormalizedSignal:
+        logger.debug("IntakeAgent processing report %s (type=%s)", report.id, report.report_type)
+
+        content = report.content or ""
+        modality = report.report_type.value
+
+        if report.report_type == ReportType.LOCATION:
+            signal_type = SignalType.FLOOD
+            description = f"Location data received: {content[:200]}"
+            confidence = 0.70
+        elif report.report_type == ReportType.CSV:
+            signal_type = SignalType.FLOOD
+            description = f"CSV batch data: {content[:200]}"
+            confidence = 0.70
+        else:
+            signal_type = SignalType.UNKNOWN
+            description = content[:200] if content else f"Report from {modality}"
+            confidence = 0.60
+
+        return NormalizedSignal(
+            source_report_id=report.id,
+            signal_type=signal_type,
+            description=description,
+            raw_text=content,
+            confidence=confidence,
+            modality=modality,
+            created_at=datetime.utcnow(),
+        )

backend/agents/normalization_agent.py

@@ -0,0 +1,45 @@
+from __future__ import annotations
+import logging
+from datetime import datetime
+
+from schemas.signal import NormalizedSignal, SignalType
+from skills.normalize_signal import normalize_signal
+
+logger = logging.getLogger(__name__)
+
+
+class NormalizationAgent:
+    def __init__(self, vllm_client=None) -> None:
+        self.vllm_client = vllm_client
+
+    async def run(self, raw_text: str, report_id: str, modality: str) -> NormalizedSignal:
+        logger.debug("NormalizationAgent processing text from report %s", report_id)
+        data = await normalize_signal(raw_text, modality, report_id, vllm_client=self.vllm_client)
+
+        signal_type_str = data.get("signal_type", "unknown")
+        try:
+            signal_type = SignalType(signal_type_str)
+        except ValueError:
+            signal_type = SignalType.UNKNOWN
+
+        created_raw = data.get("created_at", datetime.utcnow().isoformat())
+        if isinstance(created_raw, str):
+            try:
+                created_at = datetime.fromisoformat(created_raw)
+            except ValueError:
+                created_at = datetime.utcnow()
+        else:
+            created_at = created_raw
+
+        return NormalizedSignal(
+            source_report_id=report_id,
+            signal_type=signal_type,
+            description=data.get("description", raw_text[:200]),
+            location=data.get("location"),
+            coordinates=data.get("coordinates"),
+            affected_people=data.get("affected_people"),
+            raw_text=raw_text,
+            confidence=data.get("confidence", 0.7),
+            modality=modality,
+            created_at=created_at,
+        )

backend/agents/resource_agent.py

@@ -0,0 +1,23 @@
+from __future__ import annotations
+import logging
+from typing import Any, List
+
+from schemas.incident import Incident
+from schemas.resource import ResourceRecommendation
+from skills.recommend_resources import recommend_resources
+
+logger = logging.getLogger(__name__)
+
+
+class ResourceAgent:
+    def __init__(self, vllm_client: Any = None) -> None:
+        self.vllm_client = vllm_client
+
+    async def run(self, incidents: List[Incident]) -> List[ResourceRecommendation]:
+        logger.info("ResourceAgent: generating recommendations for %d incidents", len(incidents))
+        all_recommendations: List[ResourceRecommendation] = []
+        for incident in incidents:
+            recs = await recommend_resources(incident, self.vllm_client)
+            all_recommendations.extend(recs)
+        logger.info("ResourceAgent: generated %d total recommendations", len(all_recommendations))
+        return all_recommendations

backend/agents/transcription_agent.py

@@ -0,0 +1,29 @@
+from __future__ import annotations
+import logging
+
+from core.config import get_settings
+from schemas.report import ReportInput
+from skills.transcribe_audio import transcribe_audio
+
+logger = logging.getLogger(__name__)
+
+
+class TranscriptionAgent:
+    def __init__(self) -> None:
+        self.settings = get_settings()
+
+    async def run(self, report: ReportInput) -> str:
+        logger.debug("TranscriptionAgent processing report %s", report.id)
+        file_path = report.file_path or ""
+        if not file_path and report.content:
+            file_path = report.content
+
+        result = await transcribe_audio(file_path, demo_mode=self.settings.demo_mode)
+        transcription: str = result.get("transcription", "")
+        logger.info(
+            "Transcribed audio report %s: %.50s... (confidence=%.2f)",
+            report.id,
+            transcription,
+            result.get("confidence", 0),
+        )
+        return transcription

backend/agents/triage_agent.py

@@ -0,0 +1,106 @@
+from __future__ import annotations
+import logging
+import uuid
+from datetime import datetime
+from typing import Any, List, Optional
+
+from schemas.incident import EvidenceItem, Incident, IncidentStatus, Priority
+from schemas.signal import NormalizedSignal, SignalType
+from skills.calculate_confidence import calculate_confidence
+from skills.classify_priority import classify_priority
+
+logger = logging.getLogger(__name__)
+
+_PRIORITY_ORDER = {Priority.P0: 0, Priority.P1: 1, Priority.P2: 2, Priority.P3: 3}
+
+
+class TriageAgent:
+    def __init__(self, session_id: str, vllm_client: Any = None) -> None:
+        self.session_id = session_id
+        self.vllm_client = vllm_client
+
+    async def run(self, signals: List[NormalizedSignal]) -> List[Incident]:
+        logger.info("TriageAgent: creating incidents from %d signals", len(signals))
+        incidents: List[Incident] = []
+
+        groups: dict = {}
+        for signal in signals:
+            key = (signal.signal_type, signal.location or "unknown")
+            groups.setdefault(key, []).append(signal)
+
+        for (signal_type, location), group_signals in groups.items():
+            priority = await classify_priority(group_signals[0], self.vllm_client)
+
+            total_affected: Optional[int] = None
+            for s in group_signals:
+                if s.affected_people:
+                    total_affected = (total_affected or 0) + s.affected_people
+
+            confidence = await calculate_confidence(group_signals)
+            title = self._make_title(signal_type, location)
+            description = self._make_description(signal_type, location, group_signals, total_affected)
+
+            coords = next((s.coordinates for s in group_signals if s.coordinates), None)
+            evidence = [
+                EvidenceItem(
+                    report_id=s.source_report_id,
+                    modality=s.modality,
+                    description=s.description[:150],
+                )
+                for s in group_signals
+            ]
+
+            incident = Incident(
+                id=str(uuid.uuid4()),
+                session_id=self.session_id,
+                title=title,
+                description=description,
+                priority=priority,
+                status=IncidentStatus.NEW,
+                signal_ids=[s.id for s in group_signals],
+                evidence=evidence,
+                location=location if location != "unknown" else None,
+                coordinates=coords,
+                affected_people=total_affected,
+                confidence=confidence,
+                created_at=datetime.utcnow(),
+                updated_at=datetime.utcnow(),
+            )
+            incidents.append(incident)
+
+        incidents.sort(key=lambda x: _PRIORITY_ORDER.get(x.priority, 99))
+        logger.info("TriageAgent: created %d incidents", len(incidents))
+        return incidents
+
+    def _make_title(self, signal_type: SignalType, location: str) -> str:
+        type_labels = {
+            SignalType.PERSON_TRAPPED: "Persona(s) Atrapada(s)",
+            SignalType.MEDICAL_EMERGENCY: "Emergencia Médica",
+            SignalType.STRUCTURAL_DAMAGE: "Daño Estructural",
+            SignalType.FLOOD: "Inundación",
+            SignalType.FIRE: "Incendio",
+            SignalType.MISSING_PERSON: "Persona Desaparecida",
+            SignalType.RESOURCE_REQUEST: "Solicitud de Recursos",
+            SignalType.SAFE_STATUS: "Reporte de Seguridad",
+            SignalType.UNKNOWN: "Incidente Desconocido",
+        }
+        label = type_labels.get(signal_type, "Incidente")
+        loc = location.title() if location and location != "unknown" else "Barrio Santa Ana"
+        return f"{label} — {loc}"
+
+    def _make_description(
+        self,
+        signal_type: SignalType,
+        location: str,
+        signals: List[NormalizedSignal],
+        affected: Optional[int],
+    ) -> str:
+        parts = [f"Tipo: {signal_type.value.replace('_', ' ').title()}."]
+        if location and location != "unknown":
+            parts.append(f"Ubicación: {location}.")
+        if affected:
+            parts.append(f"Personas afectadas estimadas: {affected}.")
+        parts.append(f"Basado en {len(signals)} señal(es) recibida(s).")
+        if signals:
+            parts.append(f"Reporte más reciente: {signals[-1].description[:100]}.")
+        return " ".join(parts)

backend/agents/vision_agent.py

@@ -0,0 +1,28 @@
+from __future__ import annotations
+import logging
+
+from core.config import get_settings
+from schemas.report import ReportInput
+from skills.caption_image import caption_image
+
+logger = logging.getLogger(__name__)
+
+
+class VisionAgent:
+    def __init__(self) -> None:
+        self.settings = get_settings()
+
+    async def run(self, report: ReportInput) -> str:
+        logger.debug("VisionAgent processing report %s", report.id)
+        image_path = report.file_path or ""
+        if not image_path and report.content:
+            image_path = report.content
+
+        result = await caption_image(image_path, demo_mode=self.settings.demo_mode)
+        caption: str = result.get("caption", "")
+        hazards = result.get("hazards", [])
+        if hazards:
+            caption += f" Hazards identified: {', '.join(hazards)}."
+
+        logger.info("Captioned image report %s: %.80s...", report.id, caption)
+        return caption

backend/api/routes/amd.py

@@ -0,0 +1,15 @@
+from __future__ import annotations
+
+from fastapi import APIRouter
+
+from core.config import get_settings
+from schemas.amd import AMDPerformanceMetric
+from skills.fetch_amd_metrics import fetch_amd_metrics
+
+router = APIRouter(prefix="/amd", tags=["amd"])
+
+
+@router.get("/performance", response_model=AMDPerformanceMetric)
+async def get_amd_performance() -> AMDPerformanceMetric:
+    settings = get_settings()
+    return await fetch_amd_metrics(settings.vllm_base_url, demo_mode=settings.demo_mode)

backend/api/routes/crisis_room.py

@@ -0,0 +1,42 @@
+from __future__ import annotations
+import logging
+import uuid
+from typing import Optional
+
+from fastapi import APIRouter, HTTPException
+from pydantic import BaseModel
+
+from schemas.crisis_room import CrisisRoomSummary
+from schemas.report import UploadBatch
+from services.pipeline import Pipeline
+from services.storage import get_storage
+
+logger = logging.getLogger(__name__)
+router = APIRouter(prefix="/crisis-room", tags=["crisis-room"])
+
+
+class CrisisRoomRequest(BaseModel):
+    batch: UploadBatch
+    session_id: Optional[str] = None
+
+
+@router.post("", response_model=CrisisRoomSummary)
+async def create_crisis_room(request: CrisisRoomRequest) -> CrisisRoomSummary:
+    if request.session_id:
+        request.batch.session_id = request.session_id
+    pipeline = Pipeline()
+    try:
+        summary = await pipeline.process_batch(request.batch)
+    except Exception as exc:
+        logger.exception("Pipeline error: %s", exc)
+        raise HTTPException(status_code=500, detail=f"Pipeline error: {exc}")
+    return summary
+
+
+@router.get("/{session_id}", response_model=dict)
+async def get_crisis_room(session_id: str) -> dict:
+    storage = get_storage()
+    session = await storage.get_session(session_id)
+    if session is None:
+        raise HTTPException(status_code=404, detail=f"Session {session_id} not found")
+    return session

backend/api/routes/demo.py

@@ -0,0 +1,70 @@
+from __future__ import annotations
+import json
+import logging
+import uuid
+from datetime import datetime
+from pathlib import Path
+from typing import Any, Dict, List
+
+from fastapi import APIRouter, HTTPException
+
+from schemas.report import ReportInput, ReportType, UploadBatch
+from services.pipeline import Pipeline
+
+logger = logging.getLogger(__name__)
+router = APIRouter(prefix="/demo", tags=["demo"])
+
+_SCENARIO_PATH = Path(__file__).parent.parent.parent.parent / "demo_data" / "scenario_flood_santa_ana.json"
+
+
+def _load_scenario() -> Dict[str, Any]:
+    if _SCENARIO_PATH.exists():
+        return json.loads(_SCENARIO_PATH.read_text(encoding="utf-8"))
+    return {
+        "scenario_name": "Inundación Barrio Santa Ana",
+        "description": "Demo scenario — file not found",
+        "reports": [],
+    }
+
+
+@router.get("/scenario")
+async def get_demo_scenario() -> Dict[str, Any]:
+    return _load_scenario()
+
+
+@router.post("/run")
+async def run_demo() -> Dict[str, Any]:
+    scenario = _load_scenario()
+    session_id = str(uuid.uuid4())
+    reports: List[ReportInput] = []
+
+    for raw in scenario.get("reports", []):
+        rtype_str = raw.get("report_type", "text")
+        try:
+            rtype = ReportType(rtype_str)
+        except ValueError:
+            rtype = ReportType.TEXT
+
+        reports.append(ReportInput(
+            id=raw.get("id", str(uuid.uuid4())),
+            session_id=session_id,
+            report_type=rtype,
+            content=raw.get("content"),
+            metadata=raw.get("metadata", {}),
+            created_at=datetime.utcnow(),
+        ))
+
+    batch = UploadBatch(
+        session_id=session_id,
+        reports=reports,
+        scenario_name=scenario.get("scenario_name", "Demo"),
+    )
+
+    pipeline = Pipeline()
+    try:
+        summary = await pipeline.process_batch(batch)
+    except Exception as exc:
+        logger.exception("Demo pipeline error: %s", exc)
+        raise HTTPException(status_code=500, detail=str(exc))
+
+    return summary.model_dump(mode="json")

backend/api/routes/incidents.py

@@ -0,0 +1,90 @@
+from __future__ import annotations
+import logging
+from datetime import datetime
+from typing import List, Optional
+
+from fastapi import APIRouter, HTTPException, Query
+from pydantic import BaseModel
+
+from schemas.dispatch import DispatchMessage
+from schemas.incident import Incident, IncidentStatus, Priority
+from services.storage import get_storage
+from skills.generate_dispatch_message import generate_dispatch_message
+
+logger = logging.getLogger(__name__)
+router = APIRouter(prefix="/incidents", tags=["incidents"])
+
+
+class IncidentUpdate(BaseModel):
+    status: Optional[IncidentStatus] = None
+    human_approved: Optional[bool] = None
+    notes: Optional[str] = None
+    priority: Optional[Priority] = None
+
+
+@router.get("", response_model=List[dict])
+async def list_incidents(
+    session_id: Optional[str] = Query(default=None),
+    priority: Optional[Priority] = Query(default=None),
+    status: Optional[IncidentStatus] = Query(default=None),
+) -> List[dict]:
+    storage = get_storage()
+    incidents = await storage.list_incidents()
+
+    if session_id:
+        incidents = [i for i in incidents if i.get("session_id") == session_id]
+    if priority:
+        incidents = [i for i in incidents if i.get("priority") == priority.value]
+    if status:
+        incidents = [i for i in incidents if i.get("status") == status.value]
+
+    return incidents
+
+
+@router.get("/{incident_id}", response_model=dict)
+async def get_incident(incident_id: str) -> dict:
+    storage = get_storage()
+    incident = await storage.get_incident(incident_id)
+    if incident is None:
+        raise HTTPException(status_code=404, detail=f"Incident {incident_id} not found")
+    return incident
+
+
+@router.patch("/{incident_id}", response_model=dict)
+async def update_incident(incident_id: str, update: IncidentUpdate) -> dict:
+    storage = get_storage()
+    updates = {k: v for k, v in update.model_dump().items() if v is not None}
+    updates["updated_at"] = datetime.utcnow().isoformat()
+    if "priority" in updates and isinstance(updates["priority"], Priority):
+        updates["priority"] = updates["priority"].value
+    if "status" in updates and isinstance(updates["status"], IncidentStatus):
+        updates["status"] = updates["status"].value
+
+    updated = await storage.update_incident(incident_id, updates)
+    if updated is None:
+        raise HTTPException(status_code=404, detail=f"Incident {incident_id} not found")
+    return updated
+
+
+@router.post("/{incident_id}/dispatch-message", response_model=dict)
+async def create_dispatch_message(incident_id: str, channel: str = "radio") -> dict:
+    storage = get_storage()
+    incident_data = await storage.get_incident(incident_id)
+    if incident_data is None:
+        raise HTTPException(status_code=404, detail=f"Incident {incident_id} not found")
+
+    incident = Incident(**incident_data)
+    all_resources_raw = await storage.list_resources()
+    resources = [r for r in all_resources_raw if r.get("incident_id") == incident_id]
+
+    from schemas.resource import ResourceRecommendation
+    resource_objs = []
+    for r in resources:
+        try:
+            resource_objs.append(ResourceRecommendation(**r))
+        except Exception:
+            pass
+
+    msg = await generate_dispatch_message(incident, resource_objs, channel=channel)
+    await storage.save_dispatch(msg.id, msg.model_dump(mode="json"))
+    return msg.model_dump(mode="json")

backend/api/routes/reports.py

@@ -0,0 +1,93 @@
+from __future__ import annotations
+import logging
+import uuid
+from datetime import datetime
+from typing import List, Optional
+
+from fastapi import APIRouter, File, Form, HTTPException, UploadFile
+from pydantic import BaseModel
+
+from schemas.report import ReportInput, ReportType, UploadBatch
+from services.pipeline import Pipeline
+from services.storage import get_storage
+
+logger = logging.getLogger(__name__)
+router = APIRouter(prefix="/reports", tags=["reports"])
+
+
+@router.post("/upload")
+async def upload_reports(
+    session_id: Optional[str] = Form(default=None),
+    scenario_name: Optional[str] = Form(default=None),
+    files: List[UploadFile] = File(default=[]),
+    text_messages: Optional[str] = Form(default=None),
+) -> dict:
+    sid = session_id or str(uuid.uuid4())
+    reports: List[ReportInput] = []
+
+    if text_messages:
+        for i, msg in enumerate(text_messages.split("|||")):
+            msg = msg.strip()
+            if msg:
+                reports.append(ReportInput(
+                    id=str(uuid.uuid4()),
+                    session_id=sid,
+                    report_type=ReportType.TEXT,
+                    content=msg,
+                    metadata={"source": "upload", "index": i},
+                    created_at=datetime.utcnow(),
+                ))
+
+    for file in files:
+        filename = file.filename or "unknown"
+        name_lower = filename.lower()
+        if name_lower.endswith((".mp3", ".wav", ".ogg", ".m4a")):
+            rtype = ReportType.AUDIO
+        elif name_lower.endswith((".jpg", ".jpeg", ".png", ".webp")):
+            rtype = ReportType.IMAGE
+        elif name_lower.endswith(".csv"):
+            rtype = ReportType.CSV
+        else:
+            rtype = ReportType.TEXT
+
+        content = await file.read()
+        reports.append(ReportInput(
+            id=str(uuid.uuid4()),
+            session_id=sid,
+            report_type=rtype,
+            content=content.decode("utf-8", errors="replace") if rtype in (ReportType.TEXT, ReportType.CSV) else None,
+            file_path=filename,
+            metadata={"original_filename": filename, "size_bytes": len(content)},
+            created_at=datetime.utcnow(),
+        ))
+
+    storage = get_storage()
+    await storage.save_session(sid, {
+        "session_id": sid,
+        "scenario_name": scenario_name,
+        "total_reports": len(reports),
+        "status": "uploaded",
+        "created_at": datetime.utcnow().isoformat(),
+    })
+
+    return {"session_id": sid, "batch_id": sid, "report_count": len(reports), "status": "uploaded"}
+
+
+@router.post("/process")
+async def process_batch(batch: UploadBatch) -> dict:
+    pipeline = Pipeline()
+    try:
+        summary = await pipeline.process_batch(batch)
+    except Exception as exc:
+        logger.exception("Batch processing error: %s", exc)
+        raise HTTPException(status_code=500, detail=str(exc))
+    return summary.model_dump(mode="json")
+
+
+@router.get("/{session_id}")
+async def list_session_reports(session_id: str) -> dict:
+    storage = get_storage()
+    session = await storage.get_session(session_id)
+    if session is None:
+        raise HTTPException(status_code=404, detail=f"Session {session_id} not found")
+    return {"session_id": session_id, "session": session}

backend/core/config.py

@@ -0,0 +1,20 @@
+from functools import lru_cache
+from pydantic_settings import BaseSettings
+
+
+class Settings(BaseSettings):
+    vllm_base_url: str = "http://localhost:8000/v1"
+    vllm_api_key: str = "not-needed"
+    vllm_model: str = "Qwen/Qwen2.5-72B-Instruct"
+    vllm_vision_model: str = "Qwen/Qwen2-VL-7B-Instruct"
+    app_env: str = "development"
+    debug: bool = True
+    demo_mode: bool = True
+    storage_path: str = "./data"
+
+    model_config = {"env_file": ".env", "env_file_encoding": "utf-8", "extra": "ignore"}
+
+
+@lru_cache()
+def get_settings() -> Settings:
+    return Settings()

backend/data/dispatch/03a16c03-94e5-4e6f-ba8a-237658e28a5b.json

@@ -0,0 +1 @@
+{"id": "03a16c03-94e5-4e6f-ba8a-237658e28a5b", "incident_id": "53250214-30ee-4f0b-8be8-5b04aed8e1ef", "channel": "radio", "message": "ALERTA P0 \u2014 BARRIO SANTA ANA: Tipo: Flood. Ubicaci\u00f3n: Barrio Santa Ana. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte m \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 53250214. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.503776", "approved": false}

backend/data/dispatch/12791726-6e83-4d2f-aea9-9ba2733edbe9.json

@@ -0,0 +1 @@
+{"id": "12791726-6e83-4d2f-aea9-9ba2733edbe9", "incident_id": "1c43f156-18ad-4322-8aa3-725416683112", "channel": "radio", "message": "ALERTA P0 \u2014 CENTRO COMUNITARIO: Tipo: Flood. Ubicaci\u00f3n: Centro Comunitario. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 1c43f156. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.503795", "approved": false}

backend/data/dispatch/143f2fa6-e703-4a7e-84a4-92a5ee09d550.json

@@ -0,0 +1 @@
+{"id": "143f2fa6-e703-4a7e-84a4-92a5ee09d550", "incident_id": "e76d4ac7-3a14-40c5-b13d-ade472600a0a", "channel": "radio", "message": "ALERTA P0 \u2014 Barrio Santa Ana: Tipo: Flood. Ubicaci\u00f3n: Barrio Santa Ana. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte m \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: e76d4ac7. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:30.587101", "approved": false}

backend/data/dispatch/2048c8c5-ca83-467f-959c-a6838a3897b2.json

@@ -0,0 +1 @@
+{"id": "2048c8c5-ca83-467f-959c-a6838a3897b2", "incident_id": "d8ebe4ff-807a-4469-b7fb-1c2e215a7827", "channel": "radio", "message": "ALERTA P0 \u2014 PUENTE: Tipo: Flood. Ubicaci\u00f3n: Puente. Personas afectadas estimadas: 60. Basado en 2 se\u00f1al(es) recibida(s). Reporte m\u00e1s recient \u2014 60 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: d8ebe4ff. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.415505", "approved": false}

backend/data/dispatch/22eb6be8-481a-4e35-a3f1-007b71fe871d.json

@@ -0,0 +1 @@
+{"id": "22eb6be8-481a-4e35-a3f1-007b71fe871d", "incident_id": "4588efff-8ded-444f-8d4d-e48651a094ca", "channel": "radio", "message": "ALERTA P0 \u2014 CENTRO COMUNITARIO: Tipo: Flood. Ubicaci\u00f3n: Centro Comunitario. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 4588efff. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.415568", "approved": false}

backend/data/dispatch/36562d51-406e-4ff6-8fb8-4a97135aa904.json

@@ -0,0 +1 @@
+{"id": "36562d51-406e-4ff6-8fb8-4a97135aa904", "incident_id": "cc64a7fe-38af-4e72-b78b-eb05aa3176e8", "channel": "radio", "message": "ALERTA P0 \u2014 SECTOR EL PROGRESO INFORMAMOS QUE EL NIVEL DEL AGUA COMENZ\u00d3 A BAJAR LEVEMENTE EN LAS \u00daLTIMAS 2 HORAS: Tipo: Flood. Ubicaci\u00f3n: Sector El Progreso Informamos Que El Nivel Del Agua Comenz\u00f3 A Bajar Levemente En Las \u00daltimas 2 H \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: cc64a7fe. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.415598", "approved": false}

backend/data/dispatch/36d98de7-9007-4c70-a694-e066d515ba9c.json

@@ -0,0 +1 @@
+{"id": "36d98de7-9007-4c70-a694-e066d515ba9c", "incident_id": "9ca75909-d9ea-49ad-90e0-e371a8b3576c", "channel": "radio", "message": "ALERTA P0 \u2014 CALLE SUCRE EST\u00c1 COMPLETAMENTE INUNDADA: Tipo: Flood. Ubicaci\u00f3n: Calle Sucre Est\u00e1 Completamente Inundada. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 9ca75909. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:12.415578", "approved": false}

backend/data/dispatch/372c2577-8f0a-42f5-ad2b-ae205ec79e1d.json

@@ -0,0 +1 @@
+{"id": "372c2577-8f0a-42f5-ad2b-ae205ec79e1d", "incident_id": "5e88dc0d-5c0c-4b05-98cf-0674cd48392a", "channel": "radio", "message": "ALERTA P0 \u2014 Calle Sucre Est\u00e1 Completamente Inundada: Tipo: Flood. Ubicaci\u00f3n: Calle Sucre Est\u00e1 Completamente Inundada. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 5e88dc0d. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:30.498178", "approved": false}

backend/data/dispatch/3ec4f10a-3f9d-427d-aca8-3134efa35105.json

@@ -0,0 +1 @@
+{"id": "3ec4f10a-3f9d-427d-aca8-3134efa35105", "incident_id": "6cac476b-78e0-4226-b31f-1839b7185642", "channel": "radio", "message": "ALERTA P0 \u2014 Santa Ana: Tipo: Flood. Ubicaci\u00f3n: Santa Ana. Personas afectadas estimadas: 180. Basado en 6 se\u00f1al(es) recibida(s). Reporte m\u00e1s rec \u2014 180 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 6cac476b. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:30.498064", "approved": false}

backend/data/dispatch/3f2d7e95-ee1c-443e-8825-cc32c7bea9b4.json

@@ -0,0 +1 @@
+{"id": "3f2d7e95-ee1c-443e-8825-cc32c7bea9b4", "incident_id": "7de575c3-3ed9-4645-a814-f446bfda0714", "channel": "radio", "message": "ALERTA P0 \u2014 Centro Comunitario: Tipo: Flood. Ubicaci\u00f3n: Centro Comunitario. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 7de575c3. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:30.587121", "approved": false}

backend/data/dispatch/46f1763e-8b79-4726-9f58-42f572b1634a.json

@@ -0,0 +1 @@
+{"id": "46f1763e-8b79-4726-9f58-42f572b1634a", "incident_id": "1816328e-f3ed-4e13-a87d-552b278a58a1", "channel": "radio", "message": "ALERTA P0 \u2014 Calle Bolivar: Tipo: Flood. Ubicaci\u00f3n: Calle Bolivar. Personas afectadas estimadas: 30. Basado en 1 se\u00f1al(es) recibida(s). Reporte m\u00e1s  \u2014 30 personas afectadas. Recursos necesarios: 2x Equipo de rescate acu\u00e1tico, 3x Lanchas de evacuaci\u00f3n, 200x Agua potable embotellada. Coordinar con: Brigada Alfa \u2014 Rescate Cr\u00edtico. ID incidente: 1816328e. CAMBIO.", "brigade_target": "Brigada Alfa \u2014 Rescate Cr\u00edtico", "created_at": "2026-05-06T01:07:30.498241", "approved": false}