Upload 6 files

Dockerfile.txt

@@ -0,0 +1,26 @@
+FROM python:3.11-slim
+
+ENV PYTHONDONTWRITEBYTECODE=1 \
+    PYTHONUNBUFFERED=1 \
+    PIP_NO_CACHE_DIR=1 \
+    HF_HUB_DISABLE_TELEMETRY=1
+
+WORKDIR /code
+
+# System deps
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    ca-certificates curl && rm -rf /var/lib/apt/lists/*
+
+# App deps
+COPY requirements.txt .
+RUN pip install -r requirements.txt
+
+# App
+COPY app.py ./app.py
+COPY static ./static
+
+# Create persistent data dir (HF Spaces persists /data)
+RUN mkdir -p /data
+
+EXPOSE 7860
+CMD ["python", "-u", "app.py"]

app.py

@@ -0,0 +1,298 @@
+import os, json, sqlite3, asyncio, time
+from datetime import datetime, timedelta, timezone
+from threading import Lock
+
+import httpx
+from fastapi import FastAPI, HTTPException, Request
+from fastapi.responses import FileResponse, JSONResponse
+from fastapi.middleware.cors import CORSMiddleware
+from starlette.staticfiles import StaticFiles
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+from pydantic import BaseModel, HttpUrl
+
+# --------------------------
+# Config & Paths
+# --------------------------
+PORT = int(os.getenv("PORT", "7860"))
+DATA_DIR = "/data" if os.path.isdir("/data") else "."
+DB_PATH = os.path.join(DATA_DIR, "uptime.db")
+DEFAULT_SITES = [
+    {"url": "https://huggingface.co", "name": "Hugging Face"},
+    {"url": "https://www.google.com", "name": "Google"},
+    {"url": "https://www.bbc.com", "name": "BBC"},
+]
+CHECK_INTERVAL_SECONDS = 300  # 5 minutes
+HTTP_TIMEOUT_SECONDS = 10
+
+# --------------------------
+# DB setup
+# --------------------------
+os.makedirs(DATA_DIR, exist_ok=True)
+conn = sqlite3.connect(DB_PATH, check_same_thread=False)
+conn.row_factory = sqlite3.Row
+db_lock = Lock()
+
+def init_db():
+    with db_lock:
+        c = conn.cursor()
+        c.execute("""
+            CREATE TABLE IF NOT EXISTS sites (
+              url TEXT PRIMARY KEY,
+              name TEXT NOT NULL,
+              method TEXT DEFAULT 'GET',
+              expected_min INT DEFAULT 200,
+              expected_max INT DEFAULT 399,
+              created_at TEXT DEFAULT (datetime('now'))
+            );
+        """)
+        c.execute("""
+            CREATE TABLE IF NOT EXISTS checks (
+              id INTEGER PRIMARY KEY AUTOINCREMENT,
+              ts TEXT NOT NULL,
+              url TEXT NOT NULL,
+              ok INT NOT NULL,
+              status_code INT,
+              ms REAL,
+              FOREIGN KEY (url) REFERENCES sites(url)
+            );
+        """)
+        c.execute("""
+            CREATE TABLE IF NOT EXISTS incidents (
+              id INTEGER PRIMARY KEY AUTOINCREMENT,
+              url TEXT NOT NULL,
+              start_ts TEXT NOT NULL,
+              end_ts TEXT,
+              FOREIGN KEY (url) REFERENCES sites(url)
+            );
+        """)
+        conn.commit()
+
+        # Seed a few demo sites if empty
+        existing = c.execute("SELECT COUNT(*) AS n FROM sites").fetchone()["n"]
+        if existing == 0:
+            for s in DEFAULT_SITES:
+                try:
+                    c.execute("INSERT OR IGNORE INTO sites(url, name) VALUES (?, ?)", (s["url"], s["name"]))
+                except sqlite3.Error:
+                    pass
+            conn.commit()
+
+def list_sites():
+    with db_lock:
+        rows = conn.execute("SELECT url, name, method, expected_min, expected_max FROM sites ORDER BY url").fetchall()
+    return [dict(r) for r in rows]
+
+def get_last_check(url: str):
+    with db_lock:
+        r = conn.execute(
+            "SELECT ts, ok, status_code, ms FROM checks WHERE url=? ORDER BY id DESC LIMIT 1", (url,)
+        ).fetchone()
+    return dict(r) if r else None
+
+def get_prev_check(url: str):
+    with db_lock:
+        r = conn.execute(
+            "SELECT ts, ok, status_code, ms FROM checks WHERE url=? ORDER BY id DESC LIMIT 1 OFFSET 1", (url,)
+        ).fetchone()
+    return dict(r) if r else None
+
+def record_check(url: str, ok: int, status_code: int | None, ms: float | None, ts_iso: str):
+    with db_lock:
+        conn.execute("INSERT INTO checks(ts, url, ok, status_code, ms) VALUES (?,?,?,?,?)",
+                     (ts_iso, url, ok, status_code, ms))
+        conn.commit()
+
+def open_incident_if_needed(url: str, now_iso: str, prev_ok: int | None, current_ok: int):
+    with db_lock:
+        # If transitioning from UP->DOWN, open a new incident
+        if (prev_ok == 1 or prev_ok is None) and current_ok == 0:
+            conn.execute("INSERT INTO incidents(url, start_ts) VALUES (?,?)", (url, now_iso))
+            conn.commit()
+        # If transitioning from DOWN->UP, close the latest open incident
+        elif prev_ok == 0 and current_ok == 1:
+            conn.execute(
+                "UPDATE incidents SET end_ts=? WHERE url=? AND end_ts IS NULL",
+                (now_iso, url)
+            )
+            conn.commit()
+
+def incidents_for(url: str, limit: int = 50):
+    with db_lock:
+        rows = conn.execute(
+            "SELECT id, url, start_ts, end_ts FROM incidents WHERE url=? ORDER BY id DESC LIMIT ?",
+            (url, limit)
+        ).fetchall()
+    return [dict(r) for r in rows]
+
+def uptime_ratio(url: str, since: datetime):
+    with db_lock:
+        rows = conn.execute(
+            "SELECT ok FROM checks WHERE url=? AND ts >= ?",
+            (url, since.replace(tzinfo=timezone.utc).isoformat())
+        ).fetchall()
+    if not rows:
+        return None
+    total = len(rows)
+    ups = sum(1 for r in rows if r["ok"] == 1)
+    return round(100.0 * ups / total, 2)
+
+# --------------------------
+# HTTP checker
+# --------------------------
+async def check_one(client: httpx.AsyncClient, site: dict):
+    url = site["url"]
+    expected_min = int(site.get("expected_min", 200))
+    expected_max = int(site.get("expected_max", 399))
+
+    t0 = time.perf_counter()
+    code = None
+    ok = 0
+    try:
+        # Use GET with follow_redirects to treat 3xx as success if within range
+        resp = await client.get(url, follow_redirects=True, timeout=HTTP_TIMEOUT_SECONDS)
+        code = resp.status_code
+        ok = 1 if (expected_min <= code <= expected_max) else 0
+    except Exception:
+        ok = 0
+    ms = round((time.perf_counter() - t0) * 1000.0, 2)
+    now_iso = datetime.now(timezone.utc).isoformat()
+
+    prev = get_last_check(url)
+    prev_ok = prev["ok"] if prev else None
+
+    record_check(url, ok, code, ms, now_iso)
+    open_incident_if_needed(url, now_iso, prev_ok, ok)
+
+    return {
+        "url": url,
+        "ok": ok,
+        "status_code": code,
+        "ms": ms,
+        "ts": now_iso
+    }
+
+async def run_checks():
+    sites = list_sites()
+    if not sites:
+        return []
+    limits = httpx.Limits(max_connections=20, max_keepalive_connections=10)
+    async with httpx.AsyncClient(limits=limits) as client:
+        tasks = [check_one(client, s) for s in sites]
+        return await asyncio.gather(*tasks)
+
+# --------------------------
+# API & Scheduler
+# --------------------------
+app = FastAPI(title="HF Uptime Monitor", version="1.0.0")
+
+# Simple CORS for same-origin front-end
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"], allow_methods=["*"], allow_headers=["*"]
+)
+
+class SiteIn(BaseModel):
+    url: HttpUrl
+    name: str
+
+@app.on_event("startup")
+async def on_startup():
+    init_db()
+    # Kick an immediate check on boot (don't await, run in background)
+    asyncio.create_task(run_checks())
+
+    # Start APScheduler
+    scheduler = AsyncIOScheduler()
+    scheduler.add_job(run_checks, "interval", seconds=CHECK_INTERVAL_SECONDS, next_run_time=datetime.now(timezone.utc))
+    scheduler.start()
+    app.state.scheduler = scheduler
+
+@app.on_event("shutdown")
+async def on_shutdown():
+    sched = getattr(app.state, "scheduler", None)
+    if sched:
+        sched.shutdown(wait=False)
+
+# Static files
+app.mount("/static", StaticFiles(directory="static"), name="static")
+
+@app.get("/")
+def root():
+    return FileResponse("static/index.html")
+
+@app.get("/api/sites")
+def api_sites():
+    return JSONResponse(list_sites())
+
+@app.post("/api/sites")
+def api_add_site(site: SiteIn):
+    url_s = str(site.url)              # <- cast from HttpUrl to str
+    name_s = (site.name or "").strip() or url_s
+    with db_lock:
+        try:
+            conn.execute(
+                "INSERT OR IGNORE INTO sites(url, name) VALUES (?, ?)",
+                (url_s, name_s)
+            )
+            conn.commit()
+        except sqlite3.Error as e:
+            # bubble up the real DB message so the UI can show it
+            raise HTTPException(400, f"DB error: {e}")
+    return {"ok": True}
+
+
+@app.delete("/api/sites")
+def api_delete_site(url: str):
+    with db_lock:
+        conn.execute("DELETE FROM sites WHERE url=?", (url,))
+        conn.execute("DELETE FROM checks WHERE url=?", (url,))
+        conn.execute("DELETE FROM incidents WHERE url=?", (url,))
+        conn.commit()
+    return {"ok": True}
+
+@app.post("/api/check-now")
+async def api_check_now():
+    results = await run_checks()
+    return results
+
+@app.get("/api/status")
+def api_status():
+    sites = list_sites()
+    now = datetime.now(timezone.utc)
+    since_24h = now - timedelta(hours=24)
+    since_7d = now - timedelta(days=7)
+
+    out = []
+    for s in sites:
+        last = get_last_check(s["url"])
+        u24 = uptime_ratio(s["url"], since_24h)
+        u7 = uptime_ratio(s["url"], since_7d)
+        open_incident = False
+        with db_lock:
+            open_inc = conn.execute(
+                "SELECT 1 FROM incidents WHERE url=? AND end_ts IS NULL LIMIT 1",
+                (s["url"],)
+            ).fetchone()
+            open_incident = bool(open_inc)
+
+        out.append({
+            "url": s["url"],
+            "name": s["name"],
+            "last": last,            # {ts, ok, status_code, ms} or None
+            "uptime24h": u24,        # float or None
+            "uptime7d": u7,          # float or None
+            "open_incident": open_incident
+        })
+    return out
+
+@app.get("/api/incidents")
+def api_incidents(url: str):
+    return incidents_for(url, limit=100)
+
+@app.get("/api/ping")
+def api_ping():
+    return {"message": "pong"}
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=PORT)

requirements.txt

@@ -0,0 +1,4 @@
+fastapi==0.112.2
+uvicorn[standard]==0.30.6
+httpx==0.27.2
+apscheduler==3.10.4

static/app.js

@@ -0,0 +1,143 @@
+const tbody = document.getElementById("statusTbody");
+const lastRefresh = document.getElementById("lastRefresh");
+const checkNowBtn = document.getElementById("checkNowBtn");
+const addSiteBtn = document.getElementById("addSiteBtn");
+const addDialog = document.getElementById("addDialog");
+const addForm = document.getElementById("addForm");
+const cancelAdd = document.getElementById("cancelAdd");
+const siteName = document.getElementById("siteName");
+const siteUrl = document.getElementById("siteUrl");
+
+const incidentPane = document.getElementById("incidentPane");
+const incidentTitle = document.getElementById("incidentTitle");
+const incidentsList = document.getElementById("incidentsList");
+const closeIncidents = document.getElementById("closeIncidents");
+
+function fmtTs(s){
+  if(!s) return "—";
+  const d = new Date(s);
+  return d.toLocaleString();
+}
+function fmtPct(v){
+  if(v === null || v === undefined) return "—";
+  return `${v.toFixed ? v.toFixed(2) : v}%`;
+}
+function dot(ok){
+  return `<span class="dot ${ok ? 'green':'red'}" title="${ok?'UP':'DOWN'}"></span>`;
+}
+
+async function fetchStatus(){
+  const res = await fetch("/api/status");
+  const data = await res.json();
+  tbody.innerHTML = "";
+  data.forEach(item => {
+    const last = item.last || {};
+    const tr = document.createElement("tr");
+    tr.innerHTML = `
+      <td>${dot(last.ok)}</td>
+      <td>${item.name}</td>
+      <td><a class="url" href="${item.url}" target="_blank" rel="noopener">${item.url}</a></td>
+      <td>${fmtTs(last.ts)}</td>
+      <td>${last.ms ?? "—"}</td>
+      <td>${last.status_code ?? "—"}</td>
+      <td><span class="badge">${fmtPct(item.uptime24h)}</span></td>
+      <td><span class="badge">${fmtPct(item.uptime7d)}</span></td>
+      <td class="row-actions">
+        <button class="ghost" data-action="incidents" data-url="${item.url}" data-name="${item.name}">Incidents</button>
+        <button class="ghost" data-action="delete" data-url="${item.url}">Delete</button>
+      </td>
+    `;
+    tbody.appendChild(tr);
+  });
+  lastRefresh.textContent = `Last refresh: ${new Date().toLocaleTimeString()}`;
+}
+
+async function checkNow(){
+  checkNowBtn.disabled = true;
+  try{
+    await fetch("/api/check-now", {method:"POST"});
+    await fetchStatus();
+  } finally {
+    checkNowBtn.disabled = false;
+  }
+}
+
+function openAdd(){
+  siteName.value = "";
+  siteUrl.value = "";
+  addDialog.showModal();
+}
+function closeAdd(){
+  addDialog.close();
+}
+
+addForm.addEventListener("submit", async (e) => {
+  e.preventDefault();
+  const body = { name: siteName.value || siteUrl.value, url: siteUrl.value };
+  if(!body.url) return;
+  const res = await fetch("/api/sites", {
+    method:"POST",
+    headers: { "Content-Type":"application/json" },
+    body: JSON.stringify(body)
+  });
+  if (res.ok){
+    closeAdd();
+    await fetchStatus();
+  } else {
+    const msg = await res.text();              // <-- show backend detail
+    alert("Failed to add site:\n" + msg);
+  }
+});
+
+
+cancelAdd.addEventListener("click", (e)=>{ e.preventDefault(); closeAdd(); });
+
+tbody.addEventListener("click", async (e) => {
+  const btn = e.target.closest("button");
+  if(!btn) return;
+  const action = btn.dataset.action;
+  const url = btn.dataset.url;
+  if(action === "delete"){
+    if(confirm(`Delete monitor for:\n${url}?`)){
+      await fetch(`/api/sites?url=${encodeURIComponent(url)}`, { method: "DELETE" });
+      await fetchStatus();
+    }
+  }
+  if(action === "incidents"){
+    await loadIncidents(url, btn.dataset.name || url);
+  }
+});
+
+async function loadIncidents(url, name){
+  const res = await fetch(`/api/incidents?url=${encodeURIComponent(url)}`);
+  const data = await res.json();
+  incidentPane.classList.remove("hidden");
+  incidentTitle.textContent = `Incidents — ${name}`;
+  if(!data.length){
+    incidentsList.innerHTML = `<div class="muted" style="padding:8px 2px">No incidents recorded.</div>`;
+    return;
+  }
+  incidentsList.innerHTML = "";
+  data.forEach(x => {
+    const end = x.end_ts ? new Date(x.end_ts) : null;
+    const start = new Date(x.start_ts);
+    const durationMin = end ? Math.max(0, Math.round((end - start)/60000)) : null;
+    const div = document.createElement("div");
+    div.className = "incident";
+    div.innerHTML = `
+      <div>
+        <div><strong class="down">DOWN</strong> ${start.toLocaleString()}</div>
+        ${end ? `<div><strong class="ok">UP</strong> ${end.toLocaleString()}</div>` : `<div class="muted">ongoing...</div>`}
+      </div>
+      <div class="muted">${durationMin !== null ? durationMin + " min" : ""}</div>
+    `;
+    incidentsList.appendChild(div);
+  });
+}
+closeIncidents.addEventListener("click", ()=> incidentPane.classList.add("hidden"));
+
+checkNowBtn.addEventListener("click", checkNow);
+addSiteBtn.addEventListener("click", openAdd);
+
+fetchStatus();
+setInterval(fetchStatus, 30000);

static/index.html

@@ -0,0 +1,75 @@
+<!doctype html>
+<html lang="en">
+<head>
+  <meta charset="utf-8"/>
+  <meta name="viewport" content="width=device-width,initial-scale=1"/>
+  <title>Uptime Monitor</title>
+  <link rel="stylesheet" href="/static/style.css"/>
+</head>
+<body>
+  <header>
+    <div class="brand">
+      <div class="logo-dot"></div>
+      <div class="title">Uptime Monitor</div>
+    </div>
+    <div class="actions">
+      <button id="checkNowBtn">Check Now</button>
+      <button id="addSiteBtn">+ Add Site</button>
+    </div>
+  </header>
+
+  <main>
+    <section class="card">
+      <div class="card-head">
+        <h2>Monitors</h2>
+        <span id="lastRefresh" class="muted"></span>
+      </div>
+      <div class="table-wrap">
+        <table id="statusTable">
+          <thead>
+            <tr>
+              <th>Status</th>
+              <th>Name</th>
+              <th>URL</th>
+              <th>Last Check</th>
+              <th>Resp (ms)</th>
+              <th>Code</th>
+              <th>Uptime 24h</th>
+              <th>Uptime 7d</th>
+              <th></th>
+            </tr>
+          </thead>
+          <tbody id="statusTbody"></tbody>
+        </table>
+      </div>
+    </section>
+
+    <section id="incidentPane" class="card hidden">
+      <div class="card-head">
+        <h2 id="incidentTitle">Incidents</h2>
+        <button id="closeIncidents" class="ghost">Close</button>
+      </div>
+      <div id="incidentsList" class="incidents"></div>
+    </section>
+  </main>
+
+  <!-- Add site modal -->
+  <dialog id="addDialog">
+    <form method="dialog" id="addForm" class="dialog-card">
+      <h3>Add Site</h3>
+      <label>Display Name
+        <input type="text" id="siteName" placeholder="e.g., My API"/>
+      </label>
+      <label>URL
+        <input type="url" id="siteUrl" placeholder="https://example.com" required/>
+      </label>
+      <div class="row">
+        <button type="submit" id="saveSite">Save</button>
+        <button id="cancelAdd" class="ghost">Cancel</button>
+      </div>
+    </form>
+  </dialog>
+
+  <script src="/static/app.js"></script>
+</body>
+</html>

static/style.css

@@ -0,0 +1,82 @@
+:root{
+  --bg:#0b1220; --panel:#121a2e; --card:#0f1730; --text:#e6edf7; --muted:#9fb0cf;
+  --green:#18c37e; --red:#ff6363; --accent:#3a8dde; --ring: rgba(58,141,222,.35);
+  --radius:16px; --shadow: 0 10px 28px rgba(2,8,23,.35);
+}
+
+*{box-sizing:border-box}
+html,body{height:100%}
+body{
+  margin:0; font: 15px/1.45 ui-sans-serif, system-ui, -apple-system, Segoe UI, Roboto, Arial;
+  color:var(--text); background:linear-gradient(180deg,#0b1220,#0b1220 60%, #0d1530);
+}
+
+header{
+  display:flex; align-items:center; justify-content:space-between;
+  padding:16px 22px; position:sticky; top:0; background:#0b1220cc; backdrop-filter:saturate(120%) blur(6px);
+  border-bottom:1px solid #1b2542;
+}
+.brand{display:flex; align-items:center; gap:12px;}
+.logo-dot{width:14px; height:14px; border-radius:50%; background:linear-gradient(135deg,var(--accent),#6ea8ff); box-shadow:0 0 20px #2e6fd6;}
+.title{font-weight:700; letter-spacing:.3px}
+
+.actions button{
+  background:var(--accent); color:white; border:none; padding:10px 14px; border-radius:12px; cursor:pointer;
+  box-shadow:var(--shadow); margin-left:8px; font-weight:600;
+}
+.actions button#addSiteBtn{background:#243254; border:1px solid #2d3c63}
+
+main{max-width:1100px; margin:26px auto; padding:0 16px; display:grid; gap:18px}
+.card{
+  background:var(--panel); border-radius:var(--radius); box-shadow:var(--shadow); border:1px solid #1b2542;
+}
+.card-head{display:flex; align-items:center; justify-content:space-between; padding:16px 18px; border-bottom:1px solid #1b2542}
+.muted{color:var(--muted); font-size:13px}
+.table-wrap{overflow:auto}
+table{width:100%; border-collapse:collapse}
+th, td{padding:12px 14px; border-bottom:1px solid #1b2542; text-align:left}
+th{color:var(--muted); font-weight:600; background: #0f1730}
+tbody tr:hover{background:#0f1730}
+
+.dot{
+  width:12px; height:12px; border-radius:50%;
+  box-shadow:0 0 0 3px #0b1220, 0 0 16px rgba(0,0,0,.25);
+  display:inline-block;
+}
+.dot.green{background:var(--green)}
+.dot.red{background:var(--red)}
+
+a.url{color:#a9c6ff; text-decoration:none}
+a.url:hover{text-decoration:underline}
+
+.badge{padding:4px 8px; border-radius:999px; font-size:12px; border:1px solid #263257; color:#c9d7ff; background:#102143}
+
+td .row-actions{display:flex; gap:8px}
+button.ghost{
+  background:transparent; border:1px solid #27355f; color:#c9d7ff; padding:8px 12px; border-radius:12px; cursor:pointer;
+}
+
+.hidden{display:none}
+
+.incidents{padding:10px 16px}
+.incident{
+  display:flex; align-items:center; justify-content:space-between;
+  background:#0f1730; border:1px solid #1b2542; border-radius:12px; padding:10px 12px; margin-bottom:10px;
+}
+.incident .down{color:#ff9f9f}
+.incident .ok{color:#9fffc7}
+
+dialog{
+  border:none; border-radius:18px; padding:0; background:#111a31; color:var(--text); box-shadow: var(--shadow);
+}
+.dialog-card{padding:18px; width:360px}
+.dialog-card h3{margin:0 0 10px}
+.dialog-card label{display:block; margin:10px 0}
+.dialog-card input{
+  width:100%; padding:10px 12px; border-radius:12px; border:1px solid #283663; background:#0f1730; color:var(--text);
+}
+.dialog-card .row{display:flex; gap:10px; margin-top:14px}
+.dialog-card button{
+  background:var(--accent); color:white; border:none; padding:10px 14px; border-radius:12px; cursor:pointer; font-weight:600;
+}
+.dialog-card button.ghost{background:transparent; border:1px solid #27355f; color:#c9d7ff}