Fix DDA dev bugs and polish from full review pass.

Job poll/history fallback, stale job reconciliation, after_full for T2 view, lat/lng on reports/PDF, review submit in file mode, and UI hardening.

Co-authored-by: Cursor <cursoragent@cursor.com>

Dockerfile

@@ -21,7 +21,7 @@ WORKDIR /app
 
 # Build-time info + cache-bust:
 # Changing APP_BUILD forces Docker to re-run subsequent layers (including pip install).
-ARG APP_BUILD=35
+ARG APP_BUILD=36
 ENV MAX_GEOTIFF_MB=5120
 ENV APP_BUILD=${APP_BUILD}
 ENV GDAL_CONFIG=/usr/bin/gdal-config

app/dda/bootstrap.py

@@ -23,18 +23,32 @@ def init_dda_database():
     ensure_local_year_folders()
     try:
         with engine.connect() as conn:
+            for stmt in (
+                "ALTER TABLE users ADD COLUMN role VARCHAR(32) DEFAULT 'analyst'",
+                "ALTER TABLE detection_runs ADD COLUMN after_full_path VARCHAR(512) DEFAULT ''",
+            ):
+                try:
+                    conn.execute(sa_text(stmt))
+                    conn.commit()
+                except Exception:
+                    conn.rollback()
             try:
-                conn.execute(sa_text("ALTER TABLE users ADD COLUMN role VARCHAR(32) DEFAULT 'analyst'"))
+                conn.execute(sa_text(
+                    "CREATE UNIQUE INDEX IF NOT EXISTS ix_dda_region_reviews_run_region "
+                    "ON dda_region_reviews (run_id, region_id)"
+                ))
                 conn.commit()
             except Exception:
                 conn.rollback()
     except Exception as exc:
-        logger.warning("DDA user role migration skipped: %s", exc)
+        logger.warning("DDA schema migration skipped: %s", exc)
 
     from ..database import SessionLocal
     db = SessionLocal()
     try:
         seed_delhi_hierarchy(db)
+        from .job_runner import reconcile_stale_jobs
+        reconcile_stale_jobs(db)
     finally:
         db.close()
 

app/dda/dept_export.py

@@ -3,7 +3,6 @@ from __future__ import annotations
 
 import csv
 import io
-import json
 import logging
 import os
 from dataclasses import dataclass
@@ -12,6 +11,7 @@ from typing import Any, Dict, List, Optional
 import requests
 
 from ..models import DetectionRun
+from .geo_regions import region_lat_lng
 
 logger = logging.getLogger(__name__)
 
@@ -39,8 +39,7 @@ def regions_to_csv_rows(run: DetectionRun, regions: List[dict]) -> str:
         "latitude", "longitude", "area_sq_m", "review_status", "notes",
     ])
     for r in regions:
-        lat = r.get("latitude") or (r.get("latLng") or {}).get("lat")
-        lng = r.get("longitude") or (r.get("latLng") or {}).get("lng")
+        lat, lng = region_lat_lng(r)
         writer.writerow([
             run.id,
             run.title,

app/dda/detect_service.py

@@ -115,10 +115,17 @@ def run_detection_and_save(
     relative_before_full = ""
     relative_before_thumb = ""
     relative_after_thumb = ""
+    relative_after_full = ""
     try:
+        after_for_slider = Image.fromarray(
+            preprocess_image(after_pil, max_size=max_size or get_detection_max_size())
+        )
         before_full_file = OVERLAYS_DIR / f"{base_name}_before.png"
         before_for_slider.save(before_full_file)
         relative_before_full = f"overlays/{base_name}_before.png"
+        after_full_file = OVERLAYS_DIR / f"{base_name}_after.png"
+        after_for_slider.save(after_full_file)
+        relative_after_full = f"overlays/{base_name}_after.png"
         before_thumb_pil = before_pil.copy()
         before_thumb_pil.thumbnail((THUMB_MAX_SIZE, THUMB_MAX_SIZE), Image.Resampling.LANCZOS)
         before_thumb_pil.save(OVERLAYS_DIR / f"{base_name}_before_thumb.png")
@@ -157,6 +164,7 @@ def run_detection_and_save(
         before_full_path=relative_before_full,
         before_thumb_path=relative_before_thumb,
         after_thumb_path=relative_after_thumb,
+        after_full_path=relative_after_full,
         regions_json=json.dumps(regions_serializable),
     )
     db.add(run)
@@ -204,6 +212,7 @@ def run_detection_and_save(
         "beforeFullUrl": f"/api/overlay/{relative_before_full}" if relative_before_full else None,
         "beforeThumbUrl": f"/api/overlay/{relative_before_thumb}" if relative_before_thumb else None,
         "afterThumbUrl": f"/api/overlay/{relative_after_thumb}" if relative_after_thumb else None,
+        "afterFullUrl": f"/api/overlay/{relative_after_full}" if relative_after_full else None,
         "notificationSent": notification_sent,
         "notificationError": notification_error,
         "createdAt": _isoformat_ist(run.created_at),

app/dda/geo_regions.py

@@ -112,3 +112,17 @@ def enrich_regions_geo(
             enriched["latLng"] = None
         out.append(enriched)
     return out
+
+
+def region_lat_lng(region: dict) -> tuple[Optional[float], Optional[float]]:
+    """Read lat/lng from region dict (supports latLng object or flat keys)."""
+    ll = region.get("latLng") or {}
+    lat = region.get("latitude", ll.get("lat") if isinstance(ll, dict) else None)
+    lng = region.get("longitude", ll.get("lng") if isinstance(ll, dict) else None)
+    if lat is None or lng is None:
+        return None, None
+    try:
+        return float(lat), float(lng)
+    except (TypeError, ValueError):
+        return None, None
+

app/dda/job_runner.py

@@ -138,6 +138,33 @@ def is_job_runner_busy() -> bool:
         return _active_job_id is not None
 
 
+def reconcile_stale_jobs(db: Session) -> int:
+    """Mark orphaned running jobs failed after server restart; re-queue oldest queued job."""
+    if is_job_runner_busy():
+        return 0
+    fixed = 0
+    running = db.query(DetectionJob).filter(DetectionJob.status == "running").all()
+    for job in running:
+        job.status = "failed"
+        job.error_message = "Job interrupted (server restarted). Please run detection again."
+        job.completed_at = _utcnow()
+        fixed += 1
+    if fixed:
+        db.commit()
+        logger.info("Reconciled %d stale running job(s)", fixed)
+
+    if not is_job_runner_busy():
+        next_queued = (
+            db.query(DetectionJob)
+            .filter(DetectionJob.status == "queued")
+            .order_by(DetectionJob.created_at.asc())
+            .first()
+        )
+        if next_queued:
+            enqueue_detection_job(next_queued.id)
+    return fixed
+
+
 def create_local_folder_job(
     db: Session,
     *,

app/dda/jobs_routes.py

@@ -120,6 +120,7 @@ def get_job(job_id: int, db: Session = Depends(get_db)):
             raise
         except Exception as exc:
             logger.warning("Could not load full run for job %s: %s", job_id, exc)
+            data["resultError"] = str(exc)[:500]
     return data
 
 
@@ -140,6 +141,7 @@ def _run_detail(db: Session, run: DetectionRun, user_id: int) -> dict:
         if overlay_file.exists():
             overlay_b64 = base64.b64encode(overlay_file.read_bytes()).decode("utf-8")
 
+    from .config import get_detection_max_side
     from .detect_service import _isoformat_ist
 
     return {
@@ -160,7 +162,9 @@ def _run_detail(db: Session, run: DetectionRun, user_id: int) -> dict:
         "beforeFullUrl": f"/api/overlay/{run.before_full_path}" if run.before_full_path else None,
         "beforeThumbUrl": f"/api/overlay/{run.before_thumb_path}" if run.before_thumb_path else None,
         "afterThumbUrl": f"/api/overlay/{run.after_thumb_path}" if run.after_thumb_path else None,
+        "afterFullUrl": f"/api/overlay/{run.after_full_path}" if getattr(run, "after_full_path", None) else None,
         "createdAt": _isoformat_ist(run.created_at),
+        "detectionMaxSide": get_detection_max_side(),
     }
 
 
@@ -172,6 +176,8 @@ def list_jobs(
 ):
     """Recent detection jobs for in-app notifications / reports feed (FR-05 partial)."""
     _require_dda()
+    from .job_runner import reconcile_stale_jobs
+    reconcile_stale_jobs(db)
     user = get_or_create_guest_user(db)
     q = db.query(DetectionJob).filter(DetectionJob.created_by == user.id)
     if status:

app/dda/library_routes.py

@@ -69,6 +69,7 @@ def dda_config():
     max_gb = MAX_GEOTIFF_BYTES / (1024 ** 3)
     return {
         "mode": "dda",
+        "appMode": "dda",
         "maxUploadMb": MAX_GEOTIFF_BYTES // (1024 * 1024),
         "maxUploadGb": round(max_gb, 2),
         "maxGeotiffMb": MAX_GEOTIFF_BYTES // (1024 * 1024),

app/dda/report_pdf.py

@@ -38,6 +38,7 @@ def build_report_dict(run: DetectionRun, *, include_overlay_b64: bool = False, r
         "beforeFullUrl": f"/api/overlay/{run.before_full_path}" if run.before_full_path else None,
         "beforeThumbUrl": f"/api/overlay/{run.before_thumb_path}" if run.before_thumb_path else None,
         "afterThumbUrl": f"/api/overlay/{run.after_thumb_path}" if run.after_thumb_path else None,
+        "afterFullUrl": f"/api/overlay/{run.after_full_path}" if getattr(run, "after_full_path", None) else None,
         "createdAt": _isoformat_ist(run.created_at),
         "pdfUrl": f"/api/dda/reports/{run.id}/pdf",
     }
@@ -49,7 +50,7 @@ def build_report_dict(run: DetectionRun, *, include_overlay_b64: bool = False, r
     return payload
 
 
-def generate_report_pdf(run: DetectionRun) -> tuple[bytes, str]:
+def generate_report_pdf(run: DetectionRun, *, regions: Optional[List[dict]] = None) -> tuple[bytes, str]:
     """Build PDF bytes and suggested download filename."""
     from reportlab.lib import colors
     from reportlab.lib.pagesizes import A4
@@ -58,7 +59,10 @@ def generate_report_pdf(run: DetectionRun) -> tuple[bytes, str]:
     from reportlab.platypus import Image as RLImage
     from reportlab.platypus import Paragraph, SimpleDocTemplate, Spacer, Table, TableStyle
 
-    regions: List[dict] = json.loads(run.regions_json or "[]")
+    from .geo_regions import region_lat_lng
+
+    if regions is None:
+        regions = json.loads(run.regions_json or "[]")
     buf = BytesIO()
     doc = SimpleDocTemplate(buf, pagesize=A4, leftMargin=18 * mm, rightMargin=18 * mm, topMargin=16 * mm, bottomMargin=16 * mm)
     styles = getSampleStyleSheet()
@@ -102,10 +106,9 @@ def generate_report_pdf(run: DetectionRun) -> tuple[bytes, str]:
 
     story.append(Paragraph("Detected regions", styles["Heading3"]))
     if regions:
-        table_data = [["#", "DDA type", "Internal type", "Conf.", "Area (px)", "Lat", "Lng"]]
+        table_data = [["#", "DDA type", "Internal type", "Conf.", "Area (px)", "Lat", "Lng", "Review"]]
         for r in regions[:50]:
-            lat = r.get("latitude") or r.get("lat")
-            lng = r.get("longitude") or r.get("lng")
+            lat, lng = region_lat_lng(r)
             table_data.append([
                 str(r.get("id", "")),
                 r.get("ddaChangeType") or r.get("objectType") or "—",
@@ -114,6 +117,7 @@ def generate_report_pdf(run: DetectionRun) -> tuple[bytes, str]:
                 f'{r.get("area", 0):,}',
                 f"{lat:.5f}" if lat is not None else "—",
                 f"{lng:.5f}" if lng is not None else "—",
+                r.get("reviewStatus") or "pending",
             ])
         tbl = Table(table_data, repeatRows=1, colWidths=[22, 72, 72, 36, 52, 48, 48])
         tbl.setStyle(TableStyle([

app/dda/reports_routes.py

@@ -55,8 +55,9 @@ def download_report_pdf(run_id: int, db: Session = Depends(get_db)):
     _require_dda()
     user = get_or_create_guest_user(db)
     run = _get_user_run(db, run_id, user.id)
+    regions = merge_reviews(db, run.id, load_regions(run))
     try:
-        pdf_bytes, filename = generate_report_pdf(run)
+        pdf_bytes, filename = generate_report_pdf(run, regions=regions)
     except ImportError as exc:
         raise HTTPException(status_code=503, detail="PDF export is not available (reportlab missing)") from exc
     except Exception as exc:
@@ -79,8 +80,7 @@ def notify_report(run_id: int, body: ReportNotifyBody, db: Session = Depends(get
     _require_dda()
     user = get_or_create_guest_user(db)
     run = _get_user_run(db, run_id, user.id)
-    import json
-    regions = json.loads(run.regions_json or "[]")
+    regions = merge_reviews(db, run.id, load_regions(run))
     report_url = f"{get_public_base_url()}/dda/reports/{run.id}"
     sent, error = send_notification(
         recipient=body.email.strip(),

app/dda/review_routes.py

@@ -124,10 +124,7 @@ def submit_confirmed(run_id: int, db: Session = Depends(get_db)):
         raise HTTPException(status_code=502, detail=result.message)
 
     submitted_ids = [int(r["id"]) for r in confirmed if r.get("id") is not None]
-    if result.mode == "api":
-        mark_confirmed_submitted(db, run.id, submitted_ids)
-        for r in confirmed:
-            r["reviewStatus"] = "submitted"
+    mark_confirmed_submitted(db, run.id, submitted_ids)
 
     return {
         "ok": True,

app/main.py

@@ -485,7 +485,11 @@ def get_run(
     regions = _load_regions_json(run.regions_json)
     if IS_DDA_MODE:
         from .dda.review_service import merge_reviews
+        from .dda.config import get_detection_max_side
         regions = merge_reviews(db, run.id, regions)
+        detection_max_side = get_detection_max_side()
+    else:
+        detection_max_side = None
     return {
         "id": run.id,
         "title": run.title,
@@ -503,7 +507,9 @@ def get_run(
         "beforeFullUrl": f"/api/overlay/{run.before_full_path}" if (getattr(run, "before_full_path", None) or "").strip() else None,
         "beforeThumbUrl": f"/api/overlay/{run.before_thumb_path}" if (getattr(run, "before_thumb_path", None) or "").strip() else None,
         "afterThumbUrl": f"/api/overlay/{run.after_thumb_path}" if (getattr(run, "after_thumb_path", None) or "").strip() else None,
+        "afterFullUrl": f"/api/overlay/{run.after_full_path}" if (getattr(run, "after_full_path", None) or "").strip() else None,
         "createdAt": _isoformat_ist(run.created_at),
+        "detectionMaxSide": detection_max_side,
     }
 
 
@@ -546,12 +552,17 @@ def delete_run(
     if not run:
         raise HTTPException(status_code=404, detail="Run not found")
     # Delete overlay and thumbnail files if they exist
-    for path_attr in ("overlay_path", "before_full_path", "before_thumb_path", "after_thumb_path"):
+    for path_attr in ("overlay_path", "before_full_path", "before_thumb_path", "after_thumb_path", "after_full_path"):
         path_val = getattr(run, path_attr, None)
         if path_val:
             f = OVERLAYS_DIR.parent / path_val
             if f.exists():
                 f.unlink(missing_ok=True)
+    if IS_DDA_MODE:
+        from .dda.models import DetectionJob, RegionReview
+        db.query(RegionReview).filter(RegionReview.run_id == run_id).delete()
+        for job in db.query(DetectionJob).filter(DetectionJob.run_id == run_id).all():
+            job.run_id = None
     db.delete(run)
     db.commit()
     return {"ok": True, "deleted_id": run_id}

app/models.py

@@ -36,6 +36,7 @@ class DetectionRun(Base):
     before_full_path = Column(String(512), default="")
     before_thumb_path = Column(String(512), default="")
     after_thumb_path = Column(String(512), default="")
+    after_full_path = Column(String(512), default="")
     zone = Column(String(128), default="")
     village = Column(String(128), default="")
     regions_json = Column(Text, default="[]")

library_sources/2026/.gitkeep

@@ -0,0 +1 @@
+

static/css/dda.css

@@ -478,3 +478,17 @@
   0%, 100% { box-shadow: 0 0 0 0 rgba(16, 185, 129, 0.5); }
   50% { box-shadow: 0 0 0 6px rgba(16, 185, 129, 0); }
 }
+
+.regions-table-wrap {
+  overflow-x: auto;
+  max-width: 100%;
+}
+.regions-table-wrap .regions-table {
+  min-width: 960px;
+}
+
+@media (max-width: 768px) {
+  .dda-compare-slots {
+    grid-template-columns: 1fr;
+  }
+}

static/js/dda/app.js

@@ -1,5 +1,23 @@
 const API = '';
 
+function escapeHtml(text) {
+  if (text == null) return '';
+  return String(text)
+    .replace(/&/g, '&')
+    .replace(/</g, '&lt;')
+    .replace(/>/g, '&gt;')
+    .replace(/"/g, '&quot;');
+}
+
+function formatApiError(detail) {
+  if (!detail) return null;
+  if (typeof detail === 'string') return detail;
+  if (Array.isArray(detail)) {
+    return detail.map((d) => (d && d.msg) || JSON.stringify(d)).join('; ');
+  }
+  return String(detail);
+}
+
 async function ddaApi(method, path, options = {}) {
   const headers = { ...options.headers };
   if (options.body && !(options.body instanceof FormData)) {
@@ -9,7 +27,7 @@ async function ddaApi(method, path, options = {}) {
   const text = await res.text();
   let data = null;
   try { data = text ? JSON.parse(text) : null; } catch (_) {}
-  if (!res.ok) throw new Error(data?.detail || res.statusText || 'Request failed');
+  if (!res.ok) throw new Error(formatApiError(data?.detail) || res.statusText || 'Request failed');
   return data;
 }
 
@@ -113,10 +131,16 @@ async function initDda() {
       uploadLimit.textContent = `Files on your computer are not on the server. Upload .tif images here (up to ${localCfg.maxUploadGb} GB each).`;
     }
 
-    if (!localCfg.isHosted && ddaConfig.appMode !== 'dda') {
+    const appMode = ddaConfig.appMode || ddaConfig.mode || localCfg.appMode || 'dda';
+    if (!localCfg.isHosted && appMode !== 'dda') {
       showDdaError('DDA mode is off. Run locally with: python run.py');
     }
 
+    const urlTab = new URLSearchParams(window.location.search).get('tab');
+    if (urlTab) {
+      document.querySelector(`.dda-tab[data-tab="${urlTab}"]`)?.click();
+    }
+
     const yearsData = await ddaApi('GET', '/api/dda/local/years');
     localYears = yearsData.years || [];
     if (typeof renderYearTree === 'function') renderYearTree(localYears);
@@ -137,7 +161,8 @@ async function loadHierarchyTree() {
       el.innerHTML = '<p class="dim">No zones seeded.</p>';
       return;
     }
-    el.innerHTML = zones.map((z) => {
+    el.innerHTML = `<p class="dim" style="margin-bottom:0.5rem">DB hierarchy (upload API). Local library uses year folders.</p>` +
+      zones.map((z) => {
       const villages = z.villages || [];
       const zoneCount = villages.reduce((s, v) => s + (v.imageCount || 0), 0);
       const villageItems = villages.map((v) =>
@@ -180,11 +205,11 @@ async function loadLibraryImages() {
     grid.innerHTML = items.map((img) => {
       const thumb = img.thumbUrl ? img.thumbUrl.replace(/path=[^&]+/, 'path=' + encodeURIComponent(img.path)) : '';
       return `
-      <div class="dda-card-img" draggable="true" data-image-path="${img.path.replace(/"/g, '&quot;')}" title="${img.filename}">
+      <div class="dda-card-img" draggable="true" data-image-path="${img.path.replace(/"/g, '&quot;')}" title="${escapeHtml(img.filename)}">
         ${thumb ? `<img src="${thumb}" alt="" loading="lazy" />` : '<div class="meta">No preview</div>'}
         <div class="meta">
-          <strong>${img.year}</strong><br/>
-          ${img.filename}<br/>
+          <strong>${escapeHtml(String(img.year))}</strong><br/>
+          ${escapeHtml(img.filename)}<br/>
           <span class="dim">${formatBytes(img.fileSizeBytes)}</span>
         </div>
       </div>`;

static/js/dda/compare.js

@@ -306,7 +306,9 @@ async function runDetectionWithFallback(form, loadingEl) {
       return await pollJobUntilDone(queued.jobId, loadingEl);
     } catch (err) {
       const msg = String(err.message || '');
-      if (!msg.includes('Not Found') && !msg.includes('404')) throw err;
+      const useSync = msg.includes('Not Found') || msg.includes('404')
+        || msg.includes('503') || msg.includes('409') || msg.includes('busy');
+      if (!useSync) throw err;
       loadingEl.textContent = 'Running detection (sync fallback)…';
     }
   }
@@ -321,9 +323,17 @@ async function pollJobUntilDone(jobId, loadingEl) {
     if (loadingEl) {
       loadingEl.textContent = `Detection job #${jobId} — ${status}… (${i + 1})`;
     }
-    if (status === 'completed' && job.result) {
-      if (typeof window.refreshDdaNotifications === 'function') window.refreshDdaNotifications();
-      return { result: job.result, jobId };
+    if (status === 'completed') {
+      if (job.result) {
+        if (typeof window.refreshDdaNotifications === 'function') window.refreshDdaNotifications();
+        return { result: job.result, jobId };
+      }
+      if (job.runId) {
+        const data = await ddaApi('GET', `/api/history/${job.runId}`);
+        if (typeof window.refreshDdaNotifications === 'function') window.refreshDdaNotifications();
+        return { result: data, jobId };
+      }
+      if (job.resultError) throw new Error(job.resultError);
     }
     if (status === 'failed') throw new Error(job.errorMessage || 'Detection job failed');
     await new Promise((r) => setTimeout(r, 2000));

static/js/dda/report_page.js

@@ -18,6 +18,13 @@ function formatCoord(v) {
   return Number.isFinite(n) ? n.toFixed(5) : '—';
 }
 
+function regionLatLng(r) {
+  const ll = r.latLng || {};
+  const lat = r.latitude ?? ll.lat;
+  const lng = r.longitude ?? ll.lng;
+  return { lat, lng };
+}
+
 async function loadReportPage() {
   const runId = parseReportRunId();
   const loading = document.getElementById('report-loading');
@@ -58,16 +65,19 @@ async function loadReportPage() {
     const regions = data.regions || [];
     if (tbody) {
       tbody.innerHTML = regions.length
-        ? regions.map((r) => `
+        ? regions.map((r) => {
+            const { lat, lng } = regionLatLng(r);
+            return `
             <tr>
               <td>${r.id ?? ''}</td>
               <td>${r.ddaChangeType || r.objectType || '—'}</td>
               <td>${r.internalObjectType || r.objectType || '—'}</td>
               <td>${((r.confidence ?? 0) * 100).toFixed(0)}%</td>
               <td>${(r.area ?? 0).toLocaleString()}</td>
-              <td>${formatCoord(r.latitude ?? r.lat)}</td>
-              <td>${formatCoord(r.longitude ?? r.lng)}</td>
-            </tr>`).join('')
+              <td>${formatCoord(lat)}</td>
+              <td>${formatCoord(lng)}</td>
+            </tr>`;
+          }).join('')
         : '<tr><td colspan="7" class="dim">No regions detected.</td></tr>';
     }
 
@@ -81,8 +91,8 @@ async function loadReportPage() {
     if (viewBtn) {
       viewBtn.disabled = false;
       viewBtn.onclick = () => {
-        window.location.href = '/?tab=reports';
         try { sessionStorage.setItem('dda_open_run', String(runId)); } catch (_) {}
+        window.location.href = '/?tab=reports';
       };
     }
 

static/js/dda/reports.js

@@ -75,7 +75,7 @@ async function loadReportsList() {
           ${rows.map((r) => `
             <tr>
               <td>${formatReportDate(r.createdAt)}</td>
-              <td>${r.title}</td>
+              <td>${escapeHtml(r.title)}</td>
               <td><span class="dda-status dda-status-${r.status}">${r.status}</span></td>
               <td>${r.changePct != null ? r.changePct.toFixed(2) + '%' : '—'}</td>
               <td>${r.regions ?? '—'}</td>

static/js/dda/result.js

@@ -74,7 +74,7 @@ function updateDdaReviewSummary(regions) {
     const s = r.reviewStatus || 'pending';
     counts[s] = (counts[s] || 0) + 1;
   });
-  el.textContent = `Review: ${counts.confirmed} confirmed · ${counts.false_positive} false positive · ${counts.pending} pending`;
+  el.textContent = `Review: ${counts.confirmed} confirmed · ${counts.false_positive} false positive · ${counts.submitted || 0} submitted · ${counts.pending} pending`;
 }
 
 function setupDdaReviewBar(runId, regions) {
@@ -156,7 +156,7 @@ function showDdaResult(data) {
     ? 'data:image/png;base64,' + data.overlayBase64Png
     : (data.overlayUrl || '');
   const beforeSrc = data.beforeFullUrl || data.beforeThumbUrl || '';
-  const afterSrc = data.afterThumbUrl || data.afterFullUrl || beforeSrc;
+  const afterSrc = data.afterFullUrl || data.afterThumbUrl || beforeSrc;
 
   ddaViewUrls = { before: beforeSrc, after: afterSrc, overlay: overlaySrc };
   setDdaViewMode('slider');
@@ -176,7 +176,7 @@ function showDdaResult(data) {
   beforeImg.onload = onReady;
   setTimeout(() => { resetDdaCompareSlider(); resetDdaZoom(); }, 500);
 
-  const regions = (data.regions || []).slice(0, 60);
+  const regions = data.regions || [];
   ddaRegionList = regions;
   ddaRegionRows = regions.map((r) => {
     const tr = document.createElement('tr');

templates/index_dda.html

@@ -5,7 +5,7 @@
   <meta name="viewport" content="width=device-width, initial-scale=1.0" />
   <title>DDA Change Detection</title>
   <link rel="stylesheet" href="/static/css/style.css?v=30" />
-  <link rel="stylesheet" href="/static/css/dda.css?v=10" />
+  <link rel="stylesheet" href="/static/css/dda.css?v=11" />
 </head>
 <body>
   <div class="app dda-app">
@@ -259,11 +259,11 @@
     </div>
   </div>
 
-  <script src="/static/js/dda/app.js?v=11"></script>
+  <script src="/static/js/dda/app.js?v=12"></script>
   <script src="/static/js/dda/library.js?v=6"></script>
-  <script src="/static/js/dda/result.js?v=5"></script>
-  <script src="/static/js/dda/compare.js?v=8"></script>
-  <script src="/static/js/dda/reports.js?v=3"></script>
+  <script src="/static/js/dda/result.js?v=6"></script>
+  <script src="/static/js/dda/compare.js?v=9"></script>
+  <script src="/static/js/dda/reports.js?v=4"></script>
   <script src="/static/js/dda/notifications.js?v=1"></script>
 </body>
 </html>

templates/report_dda.html

@@ -5,7 +5,7 @@
   <meta name="viewport" content="width=device-width, initial-scale=1.0" />
   <title>DDA Detection Report</title>
   <link rel="stylesheet" href="/static/css/style.css?v=30" />
-  <link rel="stylesheet" href="/static/css/dda.css?v=9" />
+  <link rel="stylesheet" href="/static/css/dda.css?v=11" />
 </head>
 <body>
   <div class="app dda-app dda-report-page">
@@ -62,6 +62,6 @@
     </div>
   </div>
   <script src="/static/js/dda/app.js?v=11"></script>
-  <script src="/static/js/dda/report_page.js?v=1"></script>
+  <script src="/static/js/dda/report_page.js?v=2"></script>
 </body>
 </html>