From 0aa1d9fa82af78698a52d4139936b4951678a589 Mon Sep 17 00:00:00 2001
From: Adam Ridene <rideneadam.99@gmail.com>
Date: Sun, 19 Jul 2026 02:21:32 +0100
Subject: [PATCH] refactor: make manual operator reporting the primary fault
 ingestion path

Legacy machines without digital connectivity are the norm in
mid-size plants. Previously the system treated MQTT as the default
and manual input as a demo simulation; this inverts that model.

Changes
-------
- source field on WorkOrder and FaultIn, defaulting to 'manual'
- ManualFaultForm always visible, machine as <select>, 'Simulate'
  button removed from both dashboards
- Standalone mobile-optimized operator page at /operator/report
  (3-tap submission, RTL-ready, dark mode)
- MQTT made purely opt-in (empty broker URL by default, listener
  conditional, health check returns configured: False)
- SourceBadge component showing manual/mqtt provenance in table
- GET /api/fault-codes endpoint with caching
- Fault code hints filtered by selected machine on operator page
- Dedup: handle_fault checks for recent (machine, fault_code)
  within 30s window to avoid duplicate work orders
- Dashboard quick-link card pointing to /operator/report
- Landing copy, FAQ, i18n updated to describe three-tier model
  (manual / REST / MQTT) with no hardware required for Tier 1
- README documents the three-tier ingestion architecture
---
 README.md                          |  18 ++-
 src/torq/agent/schemas.py          |   1 +
 src/torq/api/main.py               |  38 +++--
 src/torq/api/routes.py             |  49 +++++--
 src/torq/config.py                 |   9 +-
 src/torq/db/models.py              |  21 ++-
 src/torq/events/listener.py        |   1 +
 src/torq/operator/report.html      | 215 +++++++++++++++++++++++++++++
 src/torq/pipeline.py               |   9 +-
 src/torq/workorder/generate.py     |   4 +-
 uv.lock                            |  11 ++
 web/src/api.js                     |   2 +
 web/src/i18n.jsx                   |  30 ++--
 web/src/pages/Dashboard.jsx        |  79 +++++------
 web/src/pages/Dashboard.module.css | 145 ++++++++++++++-----
 15 files changed, 514 insertions(+), 118 deletions(-)
 create mode 100644 src/torq/operator/report.html

diff --git a/README.md b/README.md
index 3aebab2..91959d9 100644
--- a/README.md
+++ b/README.md
@@ -21,13 +21,25 @@
 
 TORQ is an event-driven predictive-maintenance engine that turns machine faults into grounded diagnoses, approval-ready work orders, and technician dispatches.
 
-A fault arrives over REST or MQTT. TORQ retrieves relevant OEM guidance and past repairs, asks an OpenAI-compatible model for a structured diagnosis, creates an English/French/Arabic work order, and queues it for supervisor review. Resolved repairs return to the knowledge base so the next diagnosis can reuse what worked.
+A fault arrives — from a floor operator, a REST API call, or an MQTT event. TORQ retrieves relevant OEM guidance and past repairs, asks an OpenAI-compatible model for a structured diagnosis, creates an English/French/Arabic work order, and queues it for supervisor review. Resolved repairs return to the knowledge base so the next diagnosis can reuse what worked.
+
+### Three-tier fault ingestion
+
+TORQ is designed to work in plants with *any* level of digital connectivity. Faults enter through one of three tiers, each tagged with a `source` label visible in the dashboard:
+
+| Tier | Method | source tag | Hardware needed | For plants that… |
+|------|--------|------------|-----------------|------------------|
+| **1 — Manual** | Dashboard form or REST `POST /api/faults` | `manual` | None | Have no digital machine connectivity at all — operators report what they see, hear, or smell. |
+| **2 — REST API** | Any system that can `POST /api/faults` | `rest` | Existing IT systems | Already use a CMMS, ERP, or custom maintenance tool that can emit fault events. |
+| **3 — MQTT** | MQTT broker subscription | `mqtt` | ESP32 bridge (~$20) or existing SCADA | Want automated ingestion — a $20 ESP32 with clamp-on sensors bridges legacy machines to the broker, or modern PLCs publish directly to MQTT. |
+
+**Tier 1 is the default.** No retrofitting, no sensors, no PLC integration required. The dashboard's fault-report form is the primary ingestion path. Tiers 2 and 3 layer on as plants grow their digital footprint.
 
 ## Why TORQ?
 
 | Traditional maintenance flow | TORQ |
 | --- | --- |
-| Faults wait to be noticed and triaged | REST and MQTT fault ingestion starts the workflow immediately |
+| Faults wait to be noticed and triaged | Operators report faults from the dashboard in seconds — REST and MQTT are optional add-ons |
 | Technicians search manuals and logs by hand | Dense + BM25 retrieval surfaces relevant guidance and repair history |
 | Diagnosis quality depends on who is available | Structured, source-aware AI diagnosis creates a consistent starting point |
 | Work orders are manually written and translated | Approval-ready EN/FR/AR work orders and PDFs are generated automatically |
@@ -139,7 +151,7 @@ When a repair is marked resolved, TORQ records the actual fix, technician notes,
 
 ### Supervisor and operations views
 
-The built-in dashboard supports fault simulation, approval, rejection, resolution, and downtime metrics. A separate React dashboard adds work-order details, multilingual content, PDF downloads, retrieval evaluation charts, and an editable ROI calculator.
+The built-in dashboard supports manual fault reporting, approval, rejection, resolution, and downtime metrics. A separate React dashboard adds work-order details, multilingual content (with source badges — manual vs. mqtt), PDF downloads, retrieval evaluation charts, and an editable ROI calculator.
 
 ### Multiple integration surfaces
 
diff --git a/src/torq/agent/schemas.py b/src/torq/agent/schemas.py
index 160c314..463f90a 100644
--- a/src/torq/agent/schemas.py
+++ b/src/torq/agent/schemas.py
@@ -38,6 +38,7 @@ class WorkOrder(BaseModel):
     status: str = "pending"  # pending | approved | rejected | dispatched | resolved | failed
     assigned_to: str | None = None
     confidence: float = 0.5
+    source: str = "manual"
     fault_arrived_at: str | None = None
     created_at: str = Field(default_factory=_now)
     dispatched_at: str | None = None
diff --git a/src/torq/api/main.py b/src/torq/api/main.py
index e122a99..5b2c055 100644
--- a/src/torq/api/main.py
+++ b/src/torq/api/main.py
@@ -6,6 +6,8 @@
 from contextlib import asynccontextmanager
 from typing import AsyncIterator
 
+from pathlib import Path
+
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import HTMLResponse
@@ -24,9 +26,7 @@ async def lifespan(app: FastAPI) -> AsyncIterator[None]:
 
     models.init_db()
     mqtt_client = None
-    if settings.enable_fallbacks:
-        print("[MQTT] fallbacks enabled, skipping broker connection")
-    else:
+    if settings.mqtt_broker_url:
         mqtt_client = listener.build_client()
         live.mqtt_client = mqtt_client
         try:
@@ -36,7 +36,7 @@ async def lifespan(app: FastAPI) -> AsyncIterator[None]:
                 keepalive=60,
             )
             mqtt_client.loop_start()
-            print("[MQTT] background listener started")
+            print(f"[MQTT] listening on {settings.mqtt_broker_url}:{settings.mqtt_port}")
         except Exception as exc:
             print(f"[MQTT] broker unreachable ({exc}), continuing without live feed")
             mqtt_client = None
@@ -64,6 +64,11 @@ def dashboard() -> str:
     return DASHBOARD_HTML
 
 
+@app.get("/operator/report", response_class=HTMLResponse)
+def operator_report() -> str:
+    return Path(__file__).parent.parent.joinpath("operator", "report.html").read_text(encoding="utf-8")
+
+
 DASHBOARD_HTML = r"""
 <!doctype html><html><head><meta charset="utf-8">
 <title>TORQ Dashboard</title>
@@ -101,7 +106,7 @@ def dashboard() -> str:
 </style></head><body>
 <header>
   <h1>TORQ <span>Fault-to-Fix</span> &mdash; Supervisor Dashboard</h1>
-  <span class="mqtt-status"><span class="status-dot disconnected" id="mqtt-dot"></span> MQTT <span id="mqtt-label">disconnected</span></span>
+  <span class="mqtt-status" id="mqtt-status"></span>
 </header>
 <main>
   <div class="tiles" id="tiles"></div>
@@ -109,7 +114,10 @@ def dashboard() -> str:
   <h2>&#9889; LIVE FAULT FEED</h2>
   <div id="live-feed"><div class="feed-empty">Waiting for faults&hellip;</div></div>
 
-  <button class="sim" onclick="simulate()">&#9889; Simulate fault (E-471, CM-350 Line 2)</button>
+  <div style="background:#111c28;border:1px solid #223;border-radius:10px;padding:14px 16px;margin-bottom:16px;display:flex;gap:12px;align-items:center;flex-wrap:wrap">
+    <a href="/operator/report" target="_blank" style="color:#e6edf3;font-size:14px;font-weight:700;text-decoration:none;background:#1f6feb;padding:8px 16px;border-radius:6px">&#128241; Report a fault (open on phone)</a>
+    <span style="color:#8b98a5;font-size:13px">Select machine → enter fault code → submitted</span>
+  </div>
   <h2>PENDING APPROVAL</h2><table id="pending"></table>
   <h2>ALL WORK ORDERS</h2><table id="all"></table>
 </main>
@@ -118,11 +126,6 @@ def dashboard() -> str:
 const post = p => fetch('/api'+p,{method:'POST'}).then(r=>r.json());
 const esc = s => String(s).replace(/[&<>"]/g,function(m){return{'&':'&amp;','<':'&lt;','>':'&gt;','"':'&quot;'}[m]||m});
 
-async function simulate(){
-  await fetch('/api/faults',{method:'POST',headers:{'Content-Type':'application/json'},
-    body:JSON.stringify({fault_code:'E-471',machine:'CM-350 Line 2',context:'Motor tripped after hours running.'})});
-  load();
-}
 async function approve(id){await post('/work-orders/'+id+'/approve');load();}
 async function reject(id){await post('/work-orders/'+id+'/reject');load();}
 async function resolve(id){
@@ -186,5 +189,18 @@ def dashboard() -> str:
       '<td>'+(w.status==='dispatched'?'<button onclick="resolve(\''+w.id+'\')">Mark fixed</button>':'')+'</td></tr>').join('');
 }
 load(); setInterval(load, 4000);
+
+// Show MQTT status (configured/connected/not configured)
+fetch('/api/health').then(r=>r.json()).then(h=>{
+  const m = h.integrations?.mqtt_broker || {};
+  const el = document.getElementById('mqtt-status');
+  if (!m.configured) {
+    el.innerHTML = '<span style="opacity:0.4">MQTT — not configured</span>';
+  } else {
+    const dot = m.connected ? 'connected' : 'disconnected';
+    const label = m.connected ? 'connected' : 'disconnected';
+    el.innerHTML = '<span class="status-dot '+dot+'"></span> MQTT <span>'+label+'</span>';
+  }
+}).catch(()=>{});
 </script></body></html>
 """
diff --git a/src/torq/api/routes.py b/src/torq/api/routes.py
index e6677a8..a49db61 100644
--- a/src/torq/api/routes.py
+++ b/src/torq/api/routes.py
@@ -19,6 +19,8 @@
 
 router = APIRouter()
 
+_FAULT_CODES_CACHE: list[dict[str, str]] | None = None
+
 
 class MachineIn(BaseModel):
     id: str = Field(max_length=100)
@@ -31,6 +33,7 @@ class FaultIn(BaseModel):
     machine: str = ""
     context: str = ""
     translate: bool = True
+    source: str = "manual"
 
 
 class OutcomeIn(BaseModel):
@@ -53,6 +56,31 @@ def machine(machine_id: str) -> dict[str, Any]:
     return registered
 
 
+@router.get("/fault-codes")
+def fault_codes() -> list[dict[str, str]]:
+    """Return known fault codes from the scenarios file — used by the operator report form."""
+    global _FAULT_CODES_CACHE
+    if _FAULT_CODES_CACHE is not None:
+        return _FAULT_CODES_CACHE
+    try:
+        scenarios = json.loads(settings.scenarios_file.read_text(encoding="utf-8"))
+        seen: set[str] = set()
+        result: list[dict[str, str]] = []
+        for s in scenarios:
+            code = s.get("fault_code", "").strip()
+            if code and code not in seen:
+                seen.add(code)
+                result.append({
+                    "fault_code": code,
+                    "machine": s.get("machine", ""),
+                    "description": s.get("expected_topic", ""),
+                })
+        _FAULT_CODES_CACHE = result
+        return result
+    except (OSError, json.JSONDecodeError):
+        return []
+
+
 @router.post("/machines", status_code=201)
 def create_machine(machine: MachineIn) -> dict[str, Any]:
     machine_id = machine.id.strip()
@@ -71,7 +99,7 @@ def report_fault(f: FaultIn) -> WorkOrder:
     arrival = datetime.now(timezone.utc).isoformat()
     return handle_fault(
         f.fault_code, f.machine, f.context,
-        translate=f.translate, fault_arrived_at=arrival,
+        translate=f.translate, fault_arrived_at=arrival, source=f.source,
     )
 
 
@@ -280,13 +308,14 @@ async def _check_twilio() -> bool:
         return False
 
 
-async def _check_mqtt() -> bool:
-    if live.mqtt_client is None:
-        return False
+async def _check_mqtt() -> dict[str, bool]:
+    configured = bool(settings.mqtt_broker_url)
+    if not configured:
+        return {"configured": False, "connected": False}
     try:
-        return live.mqtt_client.is_connected()
+        return {"configured": True, "connected": live.mqtt_client is not None and live.mqtt_client.is_connected()}
     except Exception:
-        return False
+        return {"configured": True, "connected": False}
 
 
 @router.get("/health")
@@ -302,7 +331,7 @@ async def health_check() -> dict[str, Any]:
     qdrant_ok = await qdrant_task
     llm_ok = await llm_task
     twilio_ok = await twilio_task
-    mqtt_ok = await mqtt_task
+    mqtt_status = await mqtt_task
 
     overall_healthy = db_ok
 
@@ -324,9 +353,9 @@ async def health_check() -> dict[str, Any]:
                 "connected": twilio_ok,
             },
             "mqtt_broker": {
-                "connected": mqtt_ok,
-                "broker": settings.mqtt_broker_url,
-                "fallbacks_active": settings.enable_fallbacks,
+                "configured": mqtt_status["configured"],
+                "connected": mqtt_status["connected"],
+                "broker": settings.mqtt_broker_url if settings.mqtt_broker_url else "(not configured)",
             },
         },
     }
diff --git a/src/torq/config.py b/src/torq/config.py
index c64a1ab..49da74b 100644
--- a/src/torq/config.py
+++ b/src/torq/config.py
@@ -46,11 +46,10 @@ def _ensure_llm_key(self):
     twilio_auth_token: str = ""
     twilio_whatsapp_from: str = ""
 
-    # MQTT (machine fault events). Public broker by default; $0, no auth.
-    # Public unauthenticated broker + fixed topic means anyone can publish fake
-    # faults (each spawns a diagnosis run) or read plant data. For production,
-    # point at an authenticated broker over TLS and set credentials.
-    mqtt_broker_url: str = "broker.hivemq.com"
+    # MQTT (machine fault events). Empty by default — purely opt-in.
+    # Set MQTT_BROKER_URL to enable the listener for plants with digital
+    # machine connectivity. For authenticated brokers, also set credentials.
+    mqtt_broker_url: str = ""
     mqtt_port: int = 1883
     mqtt_topic: str = "torq/demo/faults"
 
diff --git a/src/torq/db/models.py b/src/torq/db/models.py
index 00a76f9..d44bea9 100644
--- a/src/torq/db/models.py
+++ b/src/torq/db/models.py
@@ -1,7 +1,7 @@
 """Persistence for work orders and the machine registry."""
 
 import json
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import Any
 
 from torq.agent.schemas import WorkOrder
@@ -122,6 +122,25 @@ def list_all() -> list[WorkOrder]:
     return [WorkOrder.model_validate_json(r["data"]) for r in rows]
 
 
+def find_recent(machine: str, fault_code: str, window_sec: int = 30) -> WorkOrder | None:
+    """Return the most recent work order for (machine, fault_code) within window_sec, if any."""
+    with get_conn() as conn:
+        rows = conn.execute(
+            "SELECT data FROM work_orders WHERE machine = ? AND fault_code = ? ORDER BY rowid DESC LIMIT 1",
+            (machine, fault_code),
+        ).fetchall()
+    if not rows:
+        return None
+    wo = WorkOrder.model_validate_json(rows[0]["data"])
+    if not wo.created_at:
+        return None
+    try:
+        age = (datetime.now(timezone.utc) - datetime.fromisoformat(wo.created_at)).total_seconds()
+    except ValueError:
+        return None
+    return wo if age <= window_sec else None
+
+
 def _secs(start: str | None, end: str | None) -> float | None:
     if not start or not end:
         return None
diff --git a/src/torq/events/listener.py b/src/torq/events/listener.py
index b117005..f1d8835 100644
--- a/src/torq/events/listener.py
+++ b/src/torq/events/listener.py
@@ -39,6 +39,7 @@ def handle_payload(payload: bytes) -> WorkOrder | None:
         machine=event.machine_id,
         context=event.context,
         fault_arrived_at=arrival,
+        source="mqtt",
     )
     sev = MachineFaultEvent.SEVERITY_LABELS.get(event.severity, "unknown")
     print(
diff --git a/src/torq/operator/report.html b/src/torq/operator/report.html
new file mode 100644
index 0000000..3edd0dc
--- /dev/null
+++ b/src/torq/operator/report.html
@@ -0,0 +1,215 @@
+<!DOCTYPE html>
+<html lang="en" dir="ltr">
+<head>
+<meta charset="UTF-8">
+<meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no">
+<meta name="theme-color" content="#0f0f0f">
+<title>TORQ — Report a Fault</title>
+<style>
+  *, *::before, *::after { box-sizing: border-box; margin: 0; padding: 0; }
+  :root {
+    --bg: #0f0f0f; --surface: #1a1a1a; --border: #2a2a2a;
+    --text: #e8e8e8; --muted: #888; --accent: #e8e8e8;
+    --success: #2da44e; --danger: #cf222e;
+    --radius: 12px; --radius-sm: 8px;
+    --font: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, sans-serif;
+    --mono: "SF Mono", "Cascadia Code", Consolas, monospace;
+  }
+  body {
+    font-family: var(--font); background: var(--bg); color: var(--text);
+    min-height: 100vh; display: flex; flex-direction: column;
+    line-height: 1.5; -webkit-font-smoothing: antialiased;
+  }
+  html[dir="rtl"] body { text-align: right; }
+
+  .container { max-width: 440px; margin: 0 auto; padding: 24px 20px; width: 100%; flex: 1; display: flex; flex-direction: column; }
+
+  .logo { font-weight: 900; font-size: 20px; letter-spacing: -0.02em; margin-bottom: 4px; }
+  .logo span { color: var(--muted); }
+  .subtitle { font-size: 13px; color: var(--muted); margin-bottom: 28px; line-height: 1.5; }
+
+  .card { background: var(--surface); border: 1px solid var(--border); border-radius: var(--radius); padding: 20px; }
+
+  .form-group { margin-bottom: 16px; }
+  .form-group:last-of-type { margin-bottom: 20px; }
+  .form-label { display: block; font-size: 12px; font-weight: 700; color: var(--muted); text-transform: uppercase; letter-spacing: 0.05em; margin-bottom: 6px; }
+
+  select, input, textarea {
+    width: 100%; padding: 12px 14px; font-size: 15px; font-family: var(--font);
+    background: var(--bg); border: 1px solid var(--border); border-radius: var(--radius-sm);
+    color: var(--text); outline: none; -webkit-appearance: none; appearance: none;
+    transition: border-color 0.2s;
+  }
+  select { background-image: url("data:image/svg+xml,%3Csvg xmlns='http://www.w3.org/2000/svg' width='12' height='8' viewBox='0 0 12 8'%3E%3Cpath fill='%23888' d='M6 8L0 0h12z'/%3E%3C/svg%3E"); background-repeat: no-repeat; background-position: right 14px center; padding-right: 36px; }
+  html[dir="rtl"] select { background-position: left 14px center; padding-right: 14px; padding-left: 36px; }
+  select:focus, input:focus, textarea:focus { border-color: var(--text); }
+  textarea { resize: vertical; min-height: 60px; font-size: 14px; }
+
+  .fault-hints { display: flex; flex-wrap: wrap; gap: 6px; margin-top: 8px; }
+  .fault-hint {
+    font-size: 11px; font-family: var(--mono); padding: 4px 10px;
+    background: var(--surface); border: 1px solid var(--border); border-radius: 20px;
+    color: var(--muted); cursor: pointer; transition: all 0.15s;
+  }
+  .fault-hint:active { border-color: var(--text); color: var(--text); }
+
+  .submit-btn {
+    width: 100%; padding: 14px; font-family: var(--font); font-weight: 700; font-size: 15px;
+    background: var(--text); color: var(--bg); border: none; border-radius: var(--radius-sm);
+    cursor: pointer; transition: opacity 0.2s; letter-spacing: 0.01em;
+  }
+  .submit-btn:disabled { opacity: 0.35; cursor: default; }
+  .submit-btn:active:not(:disabled) { opacity: 0.8; }
+
+  .submit-btn.loading { position: relative; color: transparent; pointer-events: none; }
+  .submit-btn.loading::after {
+    content: ""; position: absolute; inset: 50% 0 0 50%;
+    width: 20px; height: 20px; margin: -10px 0 0 -10px;
+    border: 2px solid var(--bg); border-top-color: transparent;
+    border-radius: 50%; animation: spin 0.6s linear infinite;
+  }
+  @keyframes spin { to { transform: rotate(360deg); } }
+
+  .success { display: none; text-align: center; padding: 40px 0; flex-direction: column; align-items: center; gap: 12px; }
+  .success.visible { display: flex; }
+  .success-icon { font-size: 48px; }
+  .success-title { font-size: 18px; font-weight: 700; }
+  .success-desc { font-size: 13px; color: var(--muted); }
+  .success-link { color: var(--text); font-size: 13px; text-decoration: underline; cursor: pointer; margin-top: 8px; }
+
+  .footer { text-align: center; font-size: 11px; color: var(--muted); padding: 20px 0; margin-top: auto; }
+  .footer span { opacity: 0.5; }
+
+  @media (prefers-color-scheme: light) {
+    :root { --bg: #f5f5f5; --surface: #fff; --border: #ddd; --text: #111; --muted: #777; }
+  }
+</style>
+</head>
+<body>
+<div class="container" id="app">
+  <div class="logo">TORQ <span>· Report a fault</span></div>
+  <p class="subtitle">Select the machine, enter the fault code, and submit. The diagnosis and work order are generated automatically.</p>
+
+  <form class="card" id="faultForm" autocomplete="off">
+    <div class="form-group">
+      <label class="form-label" for="machineSelect">Machine</label>
+      <select id="machineSelect" required>
+        <option value="">Loading machines…</option>
+      </select>
+    </div>
+
+    <div class="form-group">
+      <label class="form-label" for="faultCodeInput">Fault code</label>
+      <input id="faultCodeInput" type="text" inputmode="text" placeholder="e.g. E-471" required autocomplete="off">
+      <div class="fault-hints" id="faultHints"></div>
+    </div>
+
+    <div class="form-group">
+      <label class="form-label" for="contextInput">Context <span style="font-weight:400;text-transform:none;letter-spacing:0;color:var(--muted)">(optional)</span></label>
+      <textarea id="contextInput" placeholder="What do you see, hear, or smell?"></textarea>
+    </div>
+
+    <button class="submit-btn" type="submit" id="submitBtn">Submit fault report</button>
+  </form>
+
+  <div class="success" id="success">
+    <div class="success-icon">✓</div>
+    <div class="success-title">Fault reported</div>
+    <div class="success-desc" id="successMsg">Diagnosis in progress. Work order will be queued for supervisor review.</div>
+    <a class="success-link" onclick="resetForm()">Report another fault</a>
+  </div>
+</div>
+<div class="footer"><span>TORQ · Fault-to-Fix Engine</span></div>
+
+<script>
+const API = "/api";
+
+const machineSelect = document.getElementById("machineSelect");
+const faultCodeInput = document.getElementById("faultCodeInput");
+const contextInput = document.getElementById("contextInput");
+const form = document.getElementById("faultForm");
+const submitBtn = document.getElementById("submitBtn");
+const success = document.getElementById("success");
+const successMsg = document.getElementById("successMsg");
+
+let faultCodes = [];
+
+async function loadMachines() {
+  try {
+    const res = await fetch(API + "/machines");
+    const machines = await res.json();
+    machineSelect.innerHTML = '<option value="">Select machine…</option>'
+      + machines.map(m => `<option value="${m.id}">${m.id}</option>`).join("");
+  } catch (e) {
+    machineSelect.innerHTML = '<option value="">Could not load machines — try again</option>';
+  }
+}
+
+function renderHints() {
+  const container = document.getElementById("faultHints");
+  const selected = machineSelect.value;
+  const filtered = selected
+    ? faultCodes.filter(c => c.machine === selected)
+    : faultCodes;
+  container.innerHTML = filtered.length
+    ? filtered.map(c => `<span class="fault-hint" data-code="${c.fault_code}">${c.fault_code}</span>`).join("")
+    : '<span style="font-size:12px;color:var(--muted)">' + (selected ? "No known codes for this machine" : "Select a machine to see known codes") + '</span>';
+  container.querySelectorAll(".fault-hint").forEach(el => {
+    el.addEventListener("click", () => { faultCodeInput.value = el.dataset.code; });
+  });
+}
+
+async function loadFaultCodes() {
+  try {
+    const res = await fetch(API + "/fault-codes");
+    faultCodes = await res.json();
+    renderHints();
+  } catch (e) {
+    document.getElementById("faultHints").innerHTML = "";
+  }
+}
+
+machineSelect.addEventListener("change", renderHints);
+
+form.addEventListener("submit", async (e) => {
+  e.preventDefault();
+  const machine = machineSelect.value;
+  const faultCode = faultCodeInput.value.trim();
+  const context = contextInput.value.trim();
+  if (!machine || !faultCode) return;
+
+  submitBtn.disabled = true;
+  submitBtn.classList.add("loading");
+
+  try {
+    const res = await fetch(API + "/faults", {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ fault_code: faultCode, machine, context, source: "manual" }),
+    });
+    if (!res.ok) throw new Error(await res.text());
+    form.style.display = "none";
+    success.classList.add("visible");
+  } catch (err) {
+    successMsg.textContent = "Error: " + err.message;
+    form.style.display = "none";
+    success.classList.add("visible");
+  } finally {
+    submitBtn.disabled = false;
+    submitBtn.classList.remove("loading");
+  }
+});
+
+function resetForm() {
+  form.reset();
+  form.style.display = "";
+  success.classList.remove("visible");
+  machineSelect.value = "";
+  faultCodeInput.value = "";
+  contextInput.value = "";
+}
+
+loadMachines(); loadFaultCodes();
+</script>
+</body>
+</html>
\ No newline at end of file
diff --git a/src/torq/pipeline.py b/src/torq/pipeline.py
index 0134456..d982c74 100644
--- a/src/torq/pipeline.py
+++ b/src/torq/pipeline.py
@@ -4,6 +4,7 @@
 
 from torq.agent.diagnose import diagnose
 from torq.agent.schemas import WorkOrder
+from torq.db import models
 from torq.dispatch import approval
 from torq.events import live
 from torq.workorder.generate import build_work_order
@@ -15,13 +16,19 @@ def handle_fault(
     context: str = "",
     translate: bool = True,
     fault_arrived_at: str | None = None,
+    source: str = "manual",
 ) -> WorkOrder:
     """Fault event -> diagnosis -> work order -> queued for supervisor approval."""
     if fault_arrived_at is None:
         fault_arrived_at = datetime.now(timezone.utc).isoformat()
+
+    existing = models.find_recent(machine, fault_code) if machine else None
+    if existing:
+        return existing
+
     live.push_activity("fault_received", machine, fault_code)
     live.push_activity("diagnosing", machine, fault_code, detail="reading manuals + repair history")
     diag = diagnose(fault_code, machine, context)
-    wo = build_work_order(diag, translate=translate, fault_arrived_at=fault_arrived_at)
+    wo = build_work_order(diag, translate=translate, fault_arrived_at=fault_arrived_at, source=source)
     live.push_activity("work_order_created", machine, fault_code, detail=diag.root_cause, wo_id=wo.id)
     return approval.submit(wo)
diff --git a/src/torq/workorder/generate.py b/src/torq/workorder/generate.py
index 660efda..d9994ca 100644
--- a/src/torq/workorder/generate.py
+++ b/src/torq/workorder/generate.py
@@ -68,7 +68,8 @@ def _translate(en_text: str) -> dict[str, str]:
 
 
 def build_work_order(
-    diag: Diagnosis, translate: bool = True, fault_arrived_at: str | None = None
+    diag: Diagnosis, translate: bool = True, fault_arrived_at: str | None = None,
+    source: str = "manual",
 ) -> WorkOrder:
     en = _render_en(diag)
     content = {"en": en}
@@ -88,5 +89,6 @@ def build_work_order(
         investigation=diag.investigation,
         content=content,
         confidence=diag.confidence,
+        source=source,
         fault_arrived_at=fault_arrived_at,
     )
diff --git a/uv.lock b/uv.lock
index 9817848..051dfa8 100644
--- a/uv.lock
+++ b/uv.lock
@@ -204,6 +204,15 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/64/b4/17d4b0b2a2dc85a6df63d1157e028ed19f90d4cd97c36717afef2bc2f395/attrs-26.1.0-py3-none-any.whl", hash = "sha256:c647aa4a12dfbad9333ca4e71fe62ddc36f4e63b2d260a37a8b83d2f043ac309", size = 67548, upload-time = "2026-03-19T14:22:23.645Z" },
 ]
 
+[[package]]
+name = "cachetools"
+version = "7.1.4"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/f4/8b/0d3945a13955303b81272f759a0331e54c5c793da455e6f5706b89d2639c/cachetools-7.1.4.tar.gz", hash = "sha256:437f55a4e0c1b01a4f3077cc470e6991d47430970e36fbcb77e2be0df4fc1cd6", size = 40085, upload-time = "2026-05-21T22:40:43.376Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/8c/7b/1fc1c09cc0756cf25861a3be10565915953876da48bb228fb9a672b20a42/cachetools-7.1.4-py3-none-any.whl", hash = "sha256:323dc4127934744db5b54eb4924482d7edafbf9554e820d1531c2e08c0e4ef54", size = 16761, upload-time = "2026-05-21T22:40:41.845Z" },
+]
+
 [[package]]
 name = "certifi"
 version = "2026.6.17"
@@ -2908,6 +2917,7 @@ name = "torq"
 version = "0.1.0"
 source = { editable = "." }
 dependencies = [
+    { name = "cachetools" },
     { name = "chonkie" },
     { name = "fastapi" },
     { name = "fpdf2" },
@@ -2933,6 +2943,7 @@ dev = [
 
 [package.metadata]
 requires-dist = [
+    { name = "cachetools", specifier = ">=5.5.0" },
     { name = "chonkie", specifier = ">=1.7.0" },
     { name = "fastapi", specifier = ">=0.139.2" },
     { name = "fpdf2", specifier = ">=2.8.7" },
diff --git a/web/src/api.js b/web/src/api.js
index c6a710f..52bc52a 100644
--- a/web/src/api.js
+++ b/web/src/api.js
@@ -43,4 +43,6 @@ export const recordOutcome = (id, body) =>
     body: JSON.stringify(body),
   });
 
+export const getMachines = () => j("/machines").catch(() => []);
+
 export const getHealth = () => j("/health").catch(() => null);
diff --git a/web/src/i18n.jsx b/web/src/i18n.jsx
index 7b55a8a..be9f1c3 100644
--- a/web/src/i18n.jsx
+++ b/web/src/i18n.jsx
@@ -33,11 +33,11 @@ const LOCALES = {
     "landing.feature_4_title": "Self Learning",
     "landing.feature_4_desc": "Every fix enriches the knowledge base. The model gets smarter with each resolved fault.",
     "landing.feature_5_title": "Works With Your Setup",
-    "landing.feature_5_desc": "Report faults from the dashboard, connect machines that send digital alerts, or bridge older equipment — no special hardware required.",
+    "landing.feature_5_desc": "Report faults from the dashboard — select a machine, enter the code, describe what you see. No sensors, no PLCs, no hardware required.",
     "landing.how_title": "How it works",
     "landing.how_subtitle": "Three steps from alarm to resolution.",
     "landing.step_1_title": "A fault comes in",
-    "landing.step_1_desc": "A technician reports it from the dashboard, a connected machine sends an alert, or a bridge picks it up from older controllers. TORQ starts immediately, no matter how the fault arrives.",
+    "landing.step_1_desc": "A floor operator reports it from the dashboard — select the machine, enter the fault code, describe what you see. TORQ starts immediately. No sensors, no PLCs, no hardware required.",
     "landing.step_2_title": "AI diagnoses against manuals + history",
     "landing.step_2_desc": "Hybrid search (dense + BM25 + reranker) retrieves relevant documentation. A reasoning LLM produces a grounded diagnosis with citations.",
     "landing.step_3_title": "Supervisor approves → technician routed",
@@ -98,7 +98,7 @@ const LOCALES = {
     "faq.q3": "What machines are supported?",
     "faq.a3": "Any machine. If your equipment sends digital alerts, TORQ can pick them up. If your machines are fully offline, operators can submit faults directly through the dashboard form or from any connected device.",
     "faq.q4": "How do I integrate TORQ with my plant?",
-    "faq.a4": "Four ways: (1) Use the dashboard form to report a fault manually. (2) Send fault data from your existing maintenance or ERP system. (3) Connect machines that already produce digital fault signals. (4) Run a small bridge on a device like a Raspberry Pi to connect older controllers \u2014 no special hardware required.",
+    "faq.a4": "Three tiers, no hardware needed for Tier 1: (1) Use the dashboard form to report a fault manually \u2014 select a machine, enter the code, describe what you see. (2) Connect machines that publish MQTT fault events (a USD 20 ESP32 bridge adapts legacy equipment). (3) Use the REST API to integrate with your existing CMMS, ERP, or custom maintenance tool.",
     "faq.q5": "Is my data secure?",
     "faq.a5": "TORQ runs on your infrastructure. LLM calls go to your endpoint. Vector DB can be self-hosted. No data leaves your network.",
     "faq.q6": "What languages are supported?",
@@ -130,12 +130,14 @@ const LOCALES = {
     "dashboard.close": "close",
     "dashboard.download_pdf": "Download PDF (EN/FR/AR)",
     "dashboard.grounded_in": "Grounded in",
-    "dashboard.simulate": "Simulate fault (E-471, CM-350 Line 2)",
     "dashboard.report_fault": "Report a fault",
-    "dashboard.machine_placeholder": "Machine (e.g. CM-350 Line 2)",
+    "dashboard.manual_form_hint": "Select a machine, enter the fault code, and describe what you see or hear.",
+    "dashboard.machine_placeholder": "Select machine…",
     "dashboard.fault_code_placeholder": "Fault code (e.g. E-471)",
     "dashboard.context_placeholder": "Context / observations (optional)",
     "dashboard.submit_fault": "Submit fault",
+    "dashboard.operator_link": "Mobile report",
+    "dashboard.operator_link_hint": "Open on any phone →",
     "dashboard.no_trend_data": "No trend data yet",
     "dashboard.no_machine_data": "No machine data yet",
     "dashboard.no_recent_faults": "No recent faults detected",
@@ -179,7 +181,7 @@ const LOCALES = {
     "dashboard.toast_dispatched": "Dispatched to",
     "dashboard.toast_rejected": "Rejected",
     "dashboard.toast_fixed": "Marked as fixed",
-    "dashboard.toast_simulated": "Fault simulated",
+    "dashboard.toast_fault_reported": "Fault reported",
     "dashboard.stage_fault_received": "Fault detected",
     "dashboard.stage_diagnosing": "Diagnosing",
     "dashboard.stage_work_order_created": "Work order ready",
@@ -337,12 +339,14 @@ const LOCALES = {
     "dashboard.close": "fermer",
     "dashboard.download_pdf": "Télécharger PDF (EN/FR/AR)",
     "dashboard.grounded_in": "Basé sur",
-    "dashboard.simulate": "Simuler défaut (E-471, CM-350 Line 2)",
     "dashboard.report_fault": "Signaler un défaut",
-    "dashboard.machine_placeholder": "Machine (ex. CM-350 Line 2)",
+    "dashboard.manual_form_hint": "Sélectionnez une machine, saisissez le code défaut, et décrivez ce que vous voyez ou entendez.",
+    "dashboard.machine_placeholder": "Sélectionner une machine…",
     "dashboard.fault_code_placeholder": "Code défaut (ex. E-471)",
     "dashboard.context_placeholder": "Contexte / observations (optionnel)",
     "dashboard.submit_fault": "Soumettre le défaut",
+    "dashboard.operator_link": "Signalement mobile",
+    "dashboard.operator_link_hint": "Ouvrir sur un téléphone →",
     "dashboard.no_trend_data": "Aucune donnée de tendance",
     "dashboard.no_machine_data": "Aucune donnée machine",
     "dashboard.no_recent_faults": "Aucun défaut récent détecté",
@@ -386,7 +390,7 @@ const LOCALES = {
     "dashboard.toast_dispatched": "Envoyé à",
     "dashboard.toast_rejected": "Rejeté",
     "dashboard.toast_fixed": "Marqué comme réparé",
-    "dashboard.toast_simulated": "Défaut simulé",
+    "dashboard.toast_fault_reported": "Défaut signalé",
     "dashboard.stage_fault_received": "Défaut détecté",
     "dashboard.stage_diagnosing": "Diagnostic en cours",
     "dashboard.stage_work_order_created": "Ordre de travail prêt",
@@ -544,12 +548,14 @@ const LOCALES = {
     "dashboard.close": "إغلاق",
     "dashboard.download_pdf": "تنزيل PDF (EN/FR/AR)",
     "dashboard.grounded_in": "مستند على",
-    "dashboard.simulate": "محاكاة خلل (E-471, CM-350 Line 2)",
     "dashboard.report_fault": "الإبلاغ عن خلل",
-    "dashboard.machine_placeholder": "الآلة (مثل CM-350 Line 2)",
+    "dashboard.manual_form_hint": "اختر آلة، أدخل رمز الخلل، وصف ما تراه أو تسمعه.",
+    "dashboard.machine_placeholder": "اختر آلة…",
     "dashboard.fault_code_placeholder": "رمز الخلل (مثل E-471)",
     "dashboard.context_placeholder": "السياق / الملاحظات (اختياري)",
     "dashboard.submit_fault": "إرسال الخلل",
+    "dashboard.operator_link": "إبلاغ من الهاتف",
+    "dashboard.operator_link_hint": "فتح على أي هاتف →",
     "dashboard.no_trend_data": "لا توجد بيانات اتجاه بعد",
     "dashboard.no_machine_data": "لا توجد بيانات آلة بعد",
     "dashboard.no_recent_faults": "لم يتم اكتشاف أعطال حديثة",
@@ -593,7 +599,7 @@ const LOCALES = {
     "dashboard.toast_dispatched": "تم الإرسال إلى",
     "dashboard.toast_rejected": "مرفوض",
     "dashboard.toast_fixed": "تم الإصلاح",
-    "dashboard.toast_simulated": "تم محاكاة الخلل",
+    "dashboard.toast_fault_reported": "تم الإبلاغ عن الخلل",
     "dashboard.stage_fault_received": "تم اكتشاف العطل",
     "dashboard.stage_diagnosing": "جارٍ التشخيص",
     "dashboard.stage_work_order_created": "أمر العمل جاهز",
diff --git a/web/src/pages/Dashboard.jsx b/web/src/pages/Dashboard.jsx
index 4eb3312..291f655 100644
--- a/web/src/pages/Dashboard.jsx
+++ b/web/src/pages/Dashboard.jsx
@@ -19,18 +19,6 @@ const FIX = {
   time_to_fix_min: 30,
 };
 
-// Varied demo faults across skills (E=electromechanical, J=packaging, C/P/A=general)
-// so repeated clicks exercise different machines and route to different techs.
-const SIM_FAULTS = [
-  { fault_code: "E-471", machine: "CM-350 Line 2", context: "Motor tripped after hours running." },
-  { fault_code: "E-201", machine: "CM-350 Line 1", context: "Overcurrent on start, grinding noise." },
-  { fault_code: "J-108", machine: "PK-9 Line 3", context: "Film feed jammed at the roller nip." },
-  { fault_code: "J-233", machine: "PK-9 Line 3", context: "Seal temperature low, weak seals." },
-  { fault_code: "C-207", machine: "Chiller 6", context: "Condenser water flow dropping, efficiency down." },
-  { fault_code: "P-410", machine: "Pump 3", context: "High vibration and bearing noise." },
-  { fault_code: "A-120", machine: "AHU 2", context: "Filter differential pressure over setpoint." },
-];
-
 function Tile({ label, value }) {
   return (
     <div className={styles.tile}>
@@ -44,6 +32,12 @@ function Badge({ status }) {
   return <span className={`${styles.badge} ${styles[status] || ""}`}>{status}</span>;
 }
 
+function SourceBadge({ source }) {
+  if (!source) return null;
+  const icon = source === "manual" ? "👤" : "📡";
+  return <span className={`${styles.sourceBadge} ${styles[`source_${source}`] || ""}`}>{icon} {source}</span>;
+}
+
 // A work order is "open" until it reaches a terminal state.
 const OPEN_STATUS = new Set(["pending", "approved", "dispatched"]);
 const fmtDate = (iso) => (iso ? new Date(iso).toLocaleString() : "-");
@@ -548,35 +542,39 @@ function StatusFilter({ value, onChange, t }) {
 }
 
 function ManualFaultForm({ onReport, busy, t }) {
-  const [open, setOpen] = useState(false);
   const [machine, setMachine] = useState("");
   const [faultCode, setFaultCode] = useState("");
   const [context, setContext] = useState("");
+  const [machines, setMachines] = useState([]);
+
+  useEffect(() => {
+    api.getMachines().then(setMachines).catch(() => {});
+  }, []);
 
   const handleSubmit = (e) => {
     e.preventDefault();
     if (!machine || !faultCode) return;
-    onReport({ machine, fault_code: faultCode, context });
+    onReport({ machine, fault_code: faultCode, context, source: "manual" });
     setMachine("");
     setFaultCode("");
     setContext("");
-    setOpen(false);
   };
 
   return (
     <div className={styles.manualForm}>
-      <button className={styles.manualFormToggle} onClick={() => setOpen(!open)}>
-        {open ? "−" : "+"} {t("dashboard.report_fault")}
-      </button>
-      {open && (
-        <form className={styles.manualFormBody} onSubmit={handleSubmit}>
-          <input
+      <form className={styles.manualFormBody} onSubmit={handleSubmit}>
+        <div className={styles.manualFormRow}>
+          <select
             className={styles.manualFormInput}
-            placeholder={t("dashboard.machine_placeholder")}
             value={machine}
             onChange={(e) => setMachine(e.target.value)}
             required
-          />
+          >
+            <option value="">{t("dashboard.machine_placeholder")}</option>
+            {machines.map((m) => (
+              <option key={m.id} value={m.id}>{m.id}</option>
+            ))}
+          </select>
           <input
             className={styles.manualFormInput}
             placeholder={t("dashboard.fault_code_placeholder")}
@@ -584,18 +582,17 @@ function ManualFaultForm({ onReport, busy, t }) {
             onChange={(e) => setFaultCode(e.target.value)}
             required
           />
-          <textarea
+          <input
             className={styles.manualFormInput}
             placeholder={t("dashboard.context_placeholder")}
             value={context}
             onChange={(e) => setContext(e.target.value)}
-            rows={2}
           />
           <button className={styles.approveBtn} type="submit" disabled={busy}>
             {t("dashboard.submit_fault")}
           </button>
-        </form>
-      )}
+        </div>
+      </form>
     </div>
   );
 }
@@ -675,12 +672,6 @@ export default function Dashboard() {
     }
   };
 
-  const simulate = () =>
-    act(
-      () => api.reportFault(SIM_FAULTS[Math.floor(Math.random() * SIM_FAULTS.length)]),
-      t("dashboard.toast_simulated")
-    );
-
   const sortedFaults = useMemo(() => {
     return [...all]
       .filter((w) => w.created_at)
@@ -730,7 +721,7 @@ export default function Dashboard() {
               &nbsp;Knowledge Base: <span className={health.integrations?.qdrant?.connected ? styles.textGreen : styles.textRed}>●</span>
               &nbsp;AI Diagnostics: <span className={health.integrations?.llm?.connected ? styles.textGreen : styles.textRed}>●</span>
               &nbsp;WhatsApp Gateway: <span className={health.integrations?.twilio_whatsapp?.connected ? styles.textGreen : styles.textRed}>●</span>
-              &nbsp;Telemetry Feed: <span className={health.integrations?.mqtt_broker?.connected ? styles.textGreen : styles.textRed}>●</span>
+              &nbsp;Telemetry Feed: <span className={health.integrations?.mqtt_broker?.configured ? (health.integrations?.mqtt_broker?.connected ? styles.textGreen : styles.textRed) : styles.textMuted}>●</span>
             </span>
           </div>
         )}
@@ -785,11 +776,17 @@ export default function Dashboard() {
           </div>
         )}
 
-        <div className={styles.actionRow}>
-          <button className={styles.simBtn} disabled={busy || loading} onClick={simulate}>
-            {t("dashboard.simulate")}
-          </button>
-          <ManualFaultForm onReport={(msg) => act(() => api.reportFault(msg), t("dashboard.toast_simulated"))} busy={busy} t={t} />
+        <div className={styles.manualFormSection}>
+          <div className={styles.manualFormLabel}>{t("dashboard.report_fault")}</div>
+          <p className={styles.manualFormHint}>{t("dashboard.manual_form_hint")}</p>
+          <div className={styles.manualFormQuickWrap}>
+            <ManualFaultForm onReport={(msg) => act(() => api.reportFault(msg), t("dashboard.toast_fault_reported"))} busy={busy} t={t} />
+            <a href="/operator/report" className={styles.operatorLink} target="_blank" rel="noreferrer">
+              <span className={styles.operatorLinkIcon}>📱</span>
+              <span className={styles.operatorLinkText}>{t("dashboard.operator_link")}</span>
+              <span className={styles.operatorLinkHint}>{t("dashboard.operator_link_hint")}</span>
+            </a>
+          </div>
         </div>
 
         <h2 className={styles.sectionTitle}>{t("dashboard.pending")}</h2>
@@ -824,7 +821,7 @@ export default function Dashboard() {
                   <tr key={w.id}>
                     <td><a className={styles.link} onClick={() => setSelected(w)}>{w.id}</a></td>
                     <td>{w.machine ? <a className={styles.link} onClick={() => setMachineDetail(w.machine)}>{w.machine}</a> : "-"}</td>
-                    <td>{w.fault_code} <ConfidenceBadge confidence={w.confidence} t={t} /></td>
+                    <td>{w.fault_code} <SourceBadge source={w.source} /> <ConfidenceBadge confidence={w.confidence} t={t} /></td>
                     <td className={styles.cause}>{w.root_cause}</td>
                     <td className={styles.actions}>
                       <button className={styles.approveBtn} disabled={busy} onClick={() => act(() => api.approve(w.id), `${t("dashboard.toast_approved")} — ${w.id}`)}>
@@ -895,7 +892,7 @@ export default function Dashboard() {
                   <tr key={w.id}>
                     <td><a className={styles.link} onClick={() => setSelected(w)}>{w.id}</a></td>
                     <td>{w.machine ? <a className={styles.link} onClick={() => setMachineDetail(w.machine)}>{w.machine}</a> : "-"}</td>
-                    <td>{w.fault_code}</td>
+                    <td>{w.fault_code} <SourceBadge source={w.source} /></td>
                     <td><Badge status={w.status} /></td>
                     <td>{w.assigned_to || "-"}</td>
                     <td>
diff --git a/web/src/pages/Dashboard.module.css b/web/src/pages/Dashboard.module.css
index 12a13ab..b8f5ad8 100644
--- a/web/src/pages/Dashboard.module.css
+++ b/web/src/pages/Dashboard.module.css
@@ -407,14 +407,6 @@
 
 /* ── Buttons ── */
 
-.actionRow {
-  display: flex;
-  align-items: flex-start;
-  gap: 12px;
-  margin: 4px 0 8px;
-  flex-wrap: wrap;
-}
-
 .simBtn {
   background: var(--text-primary);
   color: var(--bg-primary);
@@ -438,47 +430,99 @@
   opacity: 0.85;
 }
 
-/* ── Manual fault form ── */
+.manualFormSection {
+  background: var(--surface);
+  border: 1px solid var(--border-color);
+  border-radius: 12px;
+  padding: 20px 24px;
+  margin: 4px 0 16px;
+  transition: background 0.35s, border-color 0.35s;
+}
 
-.manualForm {
-  position: relative;
+.manualFormQuickWrap {
+  display: flex;
+  gap: 16px;
+  flex-wrap: wrap;
+  align-items: flex-start;
+}
+
+.operatorLink {
+  display: flex;
+  flex-direction: column;
+  gap: 2px;
+  padding: 12px 18px;
+  background: var(--bg-secondary);
+  border: 1px dashed var(--border-color);
+  border-radius: 10px;
+  text-decoration: none;
+  transition: background 0.2s, border-color 0.2s;
+  min-width: 160px;
 }
 
-.manualFormToggle {
+.operatorLink:hover {
+  background: var(--surface);
+  border-color: var(--text-muted);
+}
+
+.operatorLinkIcon {
+  font-size: 20px;
+  line-height: 1;
+}
+
+.operatorLinkText {
   font-family: "ALTGumbo", system-ui, sans-serif;
   font-weight: 700;
   font-size: 13px;
-  letter-spacing: 0.01em;
   color: var(--text-primary);
-  background: transparent;
-  border: 1px solid var(--border-color);
-  border-radius: 8px;
-  padding: 10px 22px;
-  cursor: pointer;
-  transition: background 0.2s, border-color 0.2s, color 0.35s;
+  transition: color 0.35s;
 }
 
-.manualFormToggle:hover {
-  background: var(--surface);
-  border-color: var(--text-primary);
+.operatorLinkHint {
+  font-family: "ALTGumbo", system-ui, sans-serif;
+  font-weight: 400;
+  font-size: 11px;
+  color: var(--text-muted);
+  transition: color 0.35s;
+}
+
+.manualFormLabel {
+  font-family: "ALTGumbo", system-ui, sans-serif;
+  font-weight: 700;
+  font-size: 12px;
+  color: var(--text-muted);
+  text-transform: uppercase;
+  letter-spacing: 0.06em;
+  margin-bottom: 4px;
+  transition: color 0.35s;
+}
+
+.manualFormHint {
+  font-family: "ALTGumbo", system-ui, sans-serif;
+  font-weight: 400;
+  font-size: 13px;
+  color: var(--text-muted);
+  margin: 0 0 12px;
+  line-height: 1.5;
+  transition: color 0.35s;
+}
+
+.manualFormRow {
+  display: flex;
+  gap: 10px;
+  flex-wrap: wrap;
+}
+
+/* ── Manual fault form ── */
+
+.manualForm {
+  position: relative;
 }
 
 .manualFormBody {
-  position: absolute;
-  top: 100%;
-  inset-inline-start: 0;
-  margin-top: 8px;
-  background: var(--surface);
-  border: 1px solid var(--border-color);
-  border-radius: 10px;
-  padding: 16px;
   display: flex;
   flex-direction: column;
   gap: 10px;
   min-width: 300px;
-  box-shadow: var(--shadow-lg);
-  z-index: 50;
-  transition: background 0.35s, border-color 0.35s;
 }
 
 .manualFormInput {
@@ -888,6 +932,36 @@
 
 /* ── Confidence badge ── */
 
+/* ── Source badge ── */
+
+.sourceBadge {
+  display: inline-block;
+  padding: 2px 8px;
+  border-radius: 4px;
+  font-family: "SF Mono", "Cascadia Code", "Consolas", monospace;
+  font-size: 10px;
+  font-weight: 600;
+  text-transform: uppercase;
+  letter-spacing: 0.04em;
+  margin-inline-start: 6px;
+  vertical-align: middle;
+}
+
+.source_manual {
+  background: rgba(227, 179, 65, 0.12);
+  color: #b8860b;
+}
+
+.source_mqtt {
+  background: rgba(121, 192, 255, 0.12);
+  color: #1a73e8;
+}
+
+.source_rest {
+  background: rgba(227, 179, 65, 0.12);
+  color: #b8860b;
+}
+
 .lowConfidence {
   background: rgba(248, 81, 73, 0.12);
   color: #dc3545;
@@ -1233,6 +1307,11 @@
   color: #cf222e;
 }
 
+.textMuted {
+  color: var(--text-muted);
+  opacity: 0.4;
+}
+
 /* ── Tab Group inside Drawer ── */
 .tabGroup {
   display: flex;