check retention

app/main.py

@@ -141,7 +141,7 @@ def report(service_id):
     status_filter = request.args.get("status")
     search = request.args.get("search", "").strip() or None
     page = max(1, int(request.args.get("page", 1)))
-    per_page = min(100, max(10, int(request.args.get("per_page", 25))))
+    per_page = min(100, max(10, int(request.args.get("per_page", 10))))
     stats = models.get_report_stats(service_id, from_ts=from_ts, to_ts=to_ts)
     checks_total = models.get_checks_count(service_id, from_ts=from_ts, to_ts=to_ts, status_filter=status_filter, search=search)
     checks = models.get_checks(

app/models.py

@@ -2,12 +2,16 @@
 import os
 import sqlite3
 from contextlib import contextmanager
-from datetime import datetime
+from datetime import datetime, timedelta, timezone
 from pathlib import Path
 
 DATA_PATH = os.environ.get("DATA_PATH", "/app/data")
 DB_PATH = Path(DATA_PATH) / "monitor.db"
 
+# Retention: keep last N checks per service, and optionally drop checks older than N days
+CHECK_RETENTION_COUNT = int(os.environ.get("CHECK_RETENTION_COUNT", "5000"))
+CHECK_RETENTION_DAYS = int(os.environ.get("CHECK_RETENTION_DAYS", "0")) or None
+
 
 def _ensure_data_dir():
     Path(DATA_PATH).mkdir(parents=True, exist_ok=True)
@@ -232,3 +236,38 @@ def get_all_services_for_scheduler():
     with get_db() as conn:
         rows = conn.execute("SELECT id, target, protocol, interval_seconds FROM services").fetchall()
         return [dict(r) for r in rows]
+
+
+def prune_checks_retention() -> int:
+    """
+    Remove old checks to limit storage. Keeps last CHECK_RETENTION_COUNT per service.
+    If CHECK_RETENTION_DAYS is set, also deletes checks older than that.
+    Returns number of rows deleted.
+    """
+    with get_db() as conn:
+        deleted = 0
+        # Delete checks older than N days (if configured)
+        if CHECK_RETENTION_DAYS:
+            cutoff = (datetime.now(timezone.utc) - timedelta(days=CHECK_RETENTION_DAYS)).isoformat()
+            cur = conn.execute("DELETE FROM checks WHERE timestamp < ?", (cutoff,))
+            deleted += cur.rowcount
+
+        # Keep only last N checks per service
+        service_ids = [r[0] for r in conn.execute("SELECT id FROM services").fetchall()]
+        for sid in service_ids:
+            # Get ids of checks to keep (most recent N)
+            keep_ids = conn.execute(
+                "SELECT id FROM checks WHERE service_id = ? ORDER BY timestamp DESC LIMIT ?",
+                (sid, CHECK_RETENTION_COUNT),
+            ).fetchall()
+            keep_ids = [r[0] for r in keep_ids]
+            if not keep_ids:
+                continue
+            placeholders = ",".join("?" * len(keep_ids))
+            cur = conn.execute(
+                f"DELETE FROM checks WHERE service_id = ? AND id NOT IN ({placeholders})",
+                [sid] + keep_ids,
+            )
+            deleted += cur.rowcount
+
+        return deleted

app/scheduler.py

@@ -2,7 +2,7 @@
 from apscheduler.schedulers.background import BackgroundScheduler
 
 from app.checker import run_check
-from app.models import get_all_services_for_scheduler
+from app.models import get_all_services_for_scheduler, prune_checks_retention
 
 
 def _run_all_checks():
@@ -54,4 +54,7 @@ def start_scheduler():
     # Sync job list every 60 seconds (only adds/removes when services change)
     scheduler.add_job(sync_jobs, "interval", seconds=60, id="sync_jobs")
 
+    # Prune old checks every 15 minutes (retention/compression)
+    scheduler.add_job(prune_checks_retention, "interval", minutes=15, id="prune_checks")
+
     scheduler.start()