| Падений туннеля не зафиксировано |
';
+
// По дням (свежие сверху)
var daily = (d.daily||[]).slice().reverse();
document.getElementById('t-daily').innerHTML = daily.length ? daily.map(function(x){
@@ -3693,6 +3722,33 @@ async def api_alert(payload: dict):
return {"ok": True}
+@app.post("/api/tunnel-event")
+async def api_tunnel_event(payload: dict):
+ """Событие падения туннеля -51 с vds178 (health-check) → журнал для админки.
+ Пишется на КАЖДЫЙ авто-рестарт (в отличие от Telegram-алерта). Авторизация — ALERT_TOKEN."""
+ if not ALERT_TOKEN:
+ raise HTTPException(status_code=503, detail="alerts not configured")
+ tok = str((payload or {}).get("token") or "")
+ if not hmac.compare_digest(tok, ALERT_TOKEN):
+ raise HTTPException(status_code=401, detail="unauthorized")
+
+ def _int(k):
+ try:
+ return int((payload or {}).get(k) or 0)
+ except (TypeError, ValueError):
+ return 0
+ bad, bad2 = _int("bad"), _int("bad2")
+
+ def _ins():
+ with sqlite3.connect(DB_PATH, timeout=10) as con:
+ con.execute(
+ "INSERT INTO WEB_TUNNEL_EVENTS (ts, bad, bad2, recovered) VALUES (?,?,?,?)",
+ (time.time(), bad, bad2, 1 if bad2 < 2 else 0))
+ con.commit()
+ await asyncio.to_thread(_ins)
+ return {"ok": True}
+
+
def _require_admin(request: Request) -> bool:
if not ADMIN_TOKEN:
return False
@@ -3804,6 +3860,19 @@ def _admin_collect_stats() -> dict:
"FROM WEB_PAYWALL_EVENTS ORDER BY ts DESC LIMIT 100")]
except Exception:
out["paywall_events"] = []
+ # Падения туннеля -51 (журнал health-check vds178)
+ try:
+ tun = [dict(r) for r in con.execute(
+ "SELECT ts, bad, bad2, recovered FROM WEB_TUNNEL_EVENTS ORDER BY ts DESC LIMIT 100")]
+ t24 = con.execute("SELECT COUNT(*) c FROM WEB_TUNNEL_EVENTS WHERE ts >= ?",
+ (now - 86400,)).fetchone()["c"]
+ t7 = con.execute("SELECT COUNT(*) c FROM WEB_TUNNEL_EVENTS WHERE ts >= ?",
+ (now - 7 * 86400,)).fetchone()["c"]
+ tfail7 = con.execute("SELECT COUNT(*) c FROM WEB_TUNNEL_EVENTS WHERE recovered=0 AND ts >= ?",
+ (now - 7 * 86400,)).fetchone()["c"]
+ out["tunnel"] = {"recent": tun, "count_24h": t24, "count_7d": t7, "failed_7d": tfail7}
+ except Exception:
+ out["tunnel"] = {"recent": [], "count_24h": 0, "count_7d": 0, "failed_7d": 0}
# Документы
cols = {r[1] for r in con.execute("PRAGMA table_info(FILES)")}
pages_expr = "COALESCE(NULLIF(pages_total,0), num_pages, 0)" if "pages_total" in cols else "COALESCE(num_pages,0)"