feat: add resource-bound tag + network throughput to progress lines

Progress lines now include:
  [CPU] or [IO] tag indicating the limiting resource
  down=XXXKB/s (network receive throughput, delta-sampled)

Example output:
  [Transcriber] Progress: 1154s ... 65 segments so far  [CPU] (cpu=99% mem=68% down=120KB/s)
  [Images 616503] [####] 30/94 (10.4 pic/s)  [IO] (cpu=12% mem=68% down=8500KB/s)
  [OCR 616503] [####] 20/88 (0.53 page/s)  [CPU] (cpu=100% mem=68% down=5KB/s)

Author: LeafCreeper

src/ai/transcriber.py

@@ -38,11 +38,31 @@
 SILENCE_GAP_THRESHOLD_SEC = 30 * 60  # 30 min of no speech → suspected cutoff
 
 
-def _resource_meter() -> str:
-    """Short CPU + memory suffix for progress lines."""
+# ── Shared resource meter state (network delta tracking) ──────────────────
+_rm_net_last: tuple[float, int, int] | None = None
+
+
+def _resource_meter(bound: str = "") -> str:
+    """CPU + memory + network throughput suffix for progress lines.
+    ``bound`` indicates the limiting resource (e.g. "cpu", "io").
+    """
+    global _rm_net_last
     try:
         import psutil
-        return f"  (cpu={psutil.cpu_percent():.0f}% mem={psutil.virtual_memory().percent:.0f}%)"
+        cpu = psutil.cpu_percent()
+        mem = psutil.virtual_memory().percent
+        now = time.time()
+        net = psutil.net_io_counters()
+        if _rm_net_last is not None:
+            dt = now - _rm_net_last[0]
+            up = (net.bytes_sent - _rm_net_last[1]) / max(dt, 0.1) / 1024
+            down = (net.bytes_recv - _rm_net_last[2]) / max(dt, 0.1) / 1024
+            ns = f" down={down:.0f}KB/s"
+        else:
+            ns = ""
+        _rm_net_last = (now, net.bytes_sent, net.bytes_recv)
+        tag = f"[{bound.upper()}] " if bound else ""
+        return f"  {tag}(cpu={cpu:.0f}% mem={mem:.0f}%{ns})"
     except Exception:
         return ""
 
@@ -344,7 +364,7 @@ def _consume_pcm_stream(
                     f"[Transcriber] Progress: {audio_pos:.0f}s audio,"
                     f" {total_bytes / 1024 / 1024:.1f} MB consumed,"
                     f" {speed_kbps:.1f} KB/s,"
-                    f" {len(segments)} segments so far{_resource_meter()}",
+                    f" {len(segments)} segments so far{_resource_meter("cpu")}",
                     flush=True,
                 )
                 last_report = now

src/runtime/reporter.py

@@ -18,13 +18,36 @@
 import time
 
 
-def _resource_meter() -> str:
-    """Return a short CPU + memory suffix for progress lines."""
+# ── Resource state for _resource_meter (kept across calls) ────────────────
+_net_last: tuple[float, int, int] | None = None  # (time, sent, recv)
+
+
+def _resource_meter(bound: str = "") -> str:
+    """Return CPU + memory + network suffix for progress lines.
+
+    ``bound`` indicates the limiting resource: "cpu" (ASR/OCR) or "io"
+    (download).  Network throughput is computed as a delta since the
+    previous call using module-level state.
+    """
+    global _net_last
     try:
         import psutil
         cpu = psutil.cpu_percent()
         mem = psutil.virtual_memory().percent
-        return f"  (cpu={cpu:.0f}% mem={mem:.0f}%)"
+        now = time.time()
+
+        net = psutil.net_io_counters()
+        if _net_last is not None:
+            dt = now - _net_last[0]
+            up = (net.bytes_sent - _net_last[1]) / max(dt, 0.1) / 1024
+            down = (net.bytes_recv - _net_last[2]) / max(dt, 0.1) / 1024
+            net_str = f" down={down:.0f}KB/s"
+        else:
+            net_str = ""
+        _net_last = (now, net.bytes_sent, net.bytes_recv)
+
+        tag = f"[{bound.upper()}] " if bound else ""
+        return f"  {tag}(cpu={cpu:.0f}% mem={mem:.0f}%{net_str})"
     except Exception:
         return ""
 
@@ -165,7 +188,7 @@ def image_progress_tick(self, sub_id: str):
             elapsed = max(time.time() - st["t0"], 0.001)
             rate = done / elapsed
             bar = self._bar(done, total)
-            _rm = _resource_meter()
+            _rm = _resource_meter("io")
             print(f"    [Images {sub_id}] {bar} {done}/{total} "
                   f"({rate:.1f} pic/s){_rm}", flush=True)
             if is_final:
@@ -219,7 +242,7 @@ def ocr_progress_tick(self, sub_id: str):
             elapsed = max(time.time() - st["t0"], 0.001)
             rate = done / elapsed
             bar = self._bar(done, total)
-            _rm = _resource_meter()
+            _rm = _resource_meter("cpu")
             print(f"    [OCR {sub_id}] {bar} {done}/{total} "
                   f"({rate:.2f} page/s){_rm}", flush=True)
             if is_final: