Add collector alert notifications in navbar

Show a bell icon with badge count when any collector has errors
(expired session, invalid token, etc). Clicking an alert navigates
to the Settings page and highlights the relevant credential section.
Alerts only appear after an actual collection failure, not preemptively.

Author: GeiserX

app/collectors/bytelixir.py

@@ -1,25 +1,27 @@
 """Bytelixir earnings collector.
 
-Uses session cookie from the browser to fetch balance. Bytelixir is a
-Laravel app with hCaptcha on login, so automated email/password login
+Uses session cookie from the browser to fetch balance via /api/v1/user.
+Bytelixir is a Laravel app with hCaptcha on login, so automated login
 is not possible. Users must extract session cookies from their browser.
 
 To get the cookie: open dash.bytelixir.com, log in (tick "Remember Me"),
 press F12 > Application > Cookies, and copy the `bytelixir_session` value.
+
+Note: session expires after ~3.5 hours. When expired, the collector
+returns an error that surfaces as a notification in the CashPilot UI.
 """
 
 from __future__ import annotations
 
 import logging
-import re
 
 import httpx
 
 from app.collectors.base import BaseCollector, EarningsResult
 
 logger = logging.getLogger(__name__)
 
-DASH_BASE = "https://dash.bytelixir.com"
+API_BASE = "https://dash.bytelixir.com"
 
 
 class BytelixirCollector(BaseCollector):
@@ -33,61 +35,42 @@ def __init__(self, session_cookie: str) -> None:
     async def collect(self) -> EarningsResult:
         """Fetch current Bytelixir balance."""
         try:
-            cookies = {"bytelixir_session": self.session_cookie}
+            cookies = httpx.Cookies()
+            cookies.set("bytelixir_session", self.session_cookie, domain="dash.bytelixir.com")
+
             headers = {
-                "User-Agent": "Mozilla/5.0",
-                "Accept": "application/json, text/html",
+                "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36",
+                "Accept": "application/json, text/plain, */*",
                 "X-Requested-With": "XMLHttpRequest",
-                "Referer": f"{DASH_BASE}/",
+                "Referer": f"{API_BASE}/en",
+                "Origin": API_BASE,
             }
 
-            async with httpx.AsyncClient(timeout=30, follow_redirects=True, cookies=cookies) as client:
-                # Try the JSON API first
+            async with httpx.AsyncClient(timeout=30, cookies=cookies) as client:
                 resp = await client.get(
-                    f"{DASH_BASE}/api/v1/user",
+                    f"{API_BASE}/api/v1/user",
                     headers=headers,
                 )
 
-                if resp.status_code == 200:
-                    try:
-                        data = resp.json()
-                        balance = _extract_balance(data)
-                        if balance is not None:
-                            return EarningsResult(
-                                platform=self.platform,
-                                balance=round(balance, 4),
-                                currency="USD",
-                            )
-                    except Exception:
-                        pass
-
-                # Fallback: scrape the dashboard HTML for data-balance
-                resp = await client.get(
-                    f"{DASH_BASE}/en",
-                    headers={**headers, "Accept": "text/html"},
-                )
-
-                if resp.status_code == 200:
-                    balance = _extract_balance_from_html(resp.text)
-                    if balance is not None:
-                        return EarningsResult(
-                            platform=self.platform,
-                            balance=round(balance, 4),
-                            currency="USD",
-                        )
-
-                # Check if session expired (redirected to login)
-                if "/sign-in" in str(resp.url):
+                if resp.status_code == 401:
                     return EarningsResult(
                         platform=self.platform,
                         balance=0.0,
-                        error="Session expired — get a new bytelixir_session cookie from your browser",
+                        error="Session expired — refresh bytelixir_session cookie in Settings",
                     )
 
+                resp.raise_for_status()
+                data = resp.json()
+
+                # Response shape: {"data": {"balance": "0.0000000000", ...}}
+                user_data = data.get("data", {})
+                balance_str = user_data.get("balance", "0")
+                balance = float(balance_str)
+
                 return EarningsResult(
                     platform=self.platform,
-                    balance=0.0,
-                    error="Could not extract balance from Bytelixir dashboard",
+                    balance=round(balance, 4),
+                    currency="USD",
                 )
         except Exception as exc:
             logger.error("Bytelixir collection failed: %s", exc)
@@ -96,47 +79,3 @@ async def collect(self) -> EarningsResult:
                 balance=0.0,
                 error=str(exc),
             )
-
-
-def _extract_balance(data: dict) -> float | None:
-    """Try to extract a USD balance from JSON response."""
-    for key in ("balance", "total_balance", "earnings", "total_earnings"):
-        val = data.get(key)
-        if val is not None:
-            try:
-                return float(val)
-            except (ValueError, TypeError):
-                continue
-
-    # Nested under 'data' or 'user'
-    for wrapper in ("data", "user"):
-        inner = data.get(wrapper, {})
-        if isinstance(inner, dict):
-            for key in ("balance", "total_balance", "earnings", "total_earnings"):
-                val = inner.get(key)
-                if val is not None:
-                    try:
-                        return float(val)
-                    except (ValueError, TypeError):
-                        continue
-    return None
-
-
-def _extract_balance_from_html(html: str) -> float | None:
-    """Extract balance from data-balance attribute in dashboard HTML."""
-    match = re.search(r'data-balance=["\']([^"\']+)["\']', html)
-    if match:
-        try:
-            return float(match.group(1))
-        except (ValueError, TypeError):
-            pass
-
-    # Also try matching a balance-like number near "balance" text
-    match = re.search(r"(?:balance|earnings)[^>]*>\s*\$?\s*([\d.]+)", html, re.IGNORECASE)
-    if match:
-        try:
-            return float(match.group(1))
-        except (ValueError, TypeError):
-            pass
-
-    return None

app/main.py

@@ -31,6 +31,9 @@
 
 scheduler = AsyncIOScheduler()
 
+# In-memory store for the latest collector alerts (errors from last run)
+_collector_alerts: list[dict[str, str]] = []
+
 
 # ---------------------------------------------------------------------------
 # Periodic collection job
@@ -54,23 +57,27 @@ async def _run_health_check() -> None:
 
 async def _run_collection() -> None:
     """Collect earnings from all deployed services that have collectors."""
+    global _collector_alerts
     try:
         deployments = await database.get_deployments()
         config = await database.get_config() or {}
         if not isinstance(config, dict):
             config = {}
         collectors = __import__("app.collectors", fromlist=["make_collectors"]).make_collectors(deployments, config)
+        alerts: list[dict[str, str]] = []
         for collector in collectors:
             result = await collector.collect()
             if result.error:
                 logger.warning("Collection error for %s: %s", result.platform, result.error)
+                alerts.append({"platform": result.platform, "error": result.error})
             else:
                 await database.upsert_earnings(
                     platform=result.platform,
                     balance=result.balance,
                     currency=result.currency,
                 )
                 logger.info("Collected %s: %.4f %s", result.platform, result.balance, result.currency)
+        _collector_alerts = alerts
     except Exception as exc:
         logger.error("Collection run failed: %s", exc)
 
@@ -788,6 +795,13 @@ async def api_collect(request: Request) -> dict[str, str]:
     return {"status": "collection_started"}
 
 
+@app.get("/api/collector-alerts")
+async def api_collector_alerts(request: Request) -> list[dict[str, str]]:
+    """Return collector errors from the last collection run."""
+    _require_auth_api(request)
+    return _collector_alerts
+
+
 # ---------------------------------------------------------------------------
 # API: User Preferences (onboarding state)
 # ---------------------------------------------------------------------------

app/static/css/style.css

@@ -305,6 +305,112 @@ img { max-width: 100%; }
 :root[data-theme="light"] #theme-toggle .icon-sun { display: none; }
 :root[data-theme="light"] #theme-toggle .icon-moon { display: block; }
 
+/* Notification bell */
+.topbar-notifications {
+  position: relative;
+}
+.topbar-notify-btn {
+  position: relative;
+}
+.notify-badge {
+  position: absolute;
+  top: -2px;
+  right: -4px;
+  min-width: 16px;
+  height: 16px;
+  line-height: 16px;
+  font-size: 0.65rem;
+  font-weight: 700;
+  text-align: center;
+  background: var(--error);
+  color: #fff;
+  border-radius: 8px;
+  padding: 0 4px;
+  pointer-events: none;
+}
+.notify-dropdown {
+  display: none;
+  position: absolute;
+  top: calc(100% + 8px);
+  right: 0;
+  width: 320px;
+  background: var(--bg-secondary);
+  border: 1px solid var(--border-light);
+  border-radius: var(--radius);
+  box-shadow: var(--shadow-card-hover);
+  z-index: 200;
+  overflow: hidden;
+}
+.notify-dropdown.open {
+  display: block;
+}
+.notify-header {
+  padding: 10px 14px;
+  font-size: 0.8rem;
+  font-weight: 600;
+  color: var(--text-secondary);
+  border-bottom: 1px solid var(--border-color);
+  text-transform: uppercase;
+  letter-spacing: 0.04em;
+}
+.notify-list {
+  max-height: 280px;
+  overflow-y: auto;
+}
+.notify-item {
+  display: flex;
+  align-items: flex-start;
+  gap: 10px;
+  padding: 10px 14px;
+  cursor: pointer;
+  transition: background var(--transition);
+  border-bottom: 1px solid var(--border-color);
+}
+.notify-item:last-child {
+  border-bottom: none;
+}
+.notify-item:hover {
+  background: var(--bg-hover);
+}
+.notify-item-icon {
+  flex-shrink: 0;
+  width: 28px;
+  height: 28px;
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  background: var(--error-soft);
+  color: var(--error);
+  border-radius: var(--radius-sm);
+}
+.notify-item-body {
+  flex: 1;
+  min-width: 0;
+}
+.notify-item-platform {
+  font-weight: 600;
+  font-size: 0.85rem;
+  text-transform: capitalize;
+}
+.notify-item-msg {
+  font-size: 0.78rem;
+  color: var(--text-muted);
+  margin-top: 2px;
+  white-space: nowrap;
+  overflow: hidden;
+  text-overflow: ellipsis;
+}
+
+/* Collector section highlight flash */
+.collector-section.highlight-flash {
+  animation: flash-highlight 2s ease;
+}
+@keyframes flash-highlight {
+  0%, 100% { background: transparent; }
+  20% { background: var(--warning-soft); }
+  50% { background: var(--warning-soft); }
+}
+
 .topbar-earnings {
   display: flex;
   align-items: center;