Version: {VERSION}
".encode() - ) - - def log_message(self, format, *args): - print(f"[{self.log_date_time_string()}] {format % args}") +from app.main import app +from app.models import init_db +from app.scheduler import start_scheduler if __name__ == "__main__": - server = HTTPServer(("", PORT), Handler) - print(f"Server running on port {PORT}") - server.serve_forever() + init_db() + start_scheduler() + port = int(os.environ.get("PORT", 8080)) + app.run(host="0.0.0.0", port=port, debug=False) diff --git a/app/__init__.py b/app/__init__.py new file mode 100644 index 0000000..ce64809 --- /dev/null +++ b/app/__init__.py @@ -0,0 +1 @@ +"""Statping clone - HTTP/HTTPS and TCP monitoring with history and reports.""" diff --git a/app/checker.py b/app/checker.py new file mode 100644 index 0000000..fc3be14 --- /dev/null +++ b/app/checker.py @@ -0,0 +1,64 @@ +"""HTTP/HTTPS and TCP check logic.""" +import socket +import time +from urllib.parse import urlparse + +import requests + +TIMEOUT = 10 + + +def check_http(url: str) -> tuple[bool, float | None, str | None]: + """ + Check HTTP/HTTPS endpoint. Returns (success, response_time_ms, error_message). + Success = 2xx status code. + """ + if not url.startswith(("http://", "https://")): + url = "https://" + url + try: + start = time.perf_counter() + r = requests.get(url, timeout=TIMEOUT) + elapsed_ms = (time.perf_counter() - start) * 1000 + success = 200 <= r.status_code < 300 + return success, elapsed_ms, None if success else f"HTTP {r.status_code}" + except requests.RequestException as e: + return False, None, str(e) + + +def check_tcp(host: str, port: int) -> tuple[bool, float | None, str | None]: + """ + Check TCP connectivity. Returns (success, response_time_ms, error_message). + """ + try: + start = time.perf_counter() + sock = socket.create_connection((host, port), timeout=TIMEOUT) + sock.close() + elapsed_ms = (time.perf_counter() - start) * 1000 + return True, elapsed_ms, None + except (socket.error, OSError) as e: + return False, None, str(e) + + +def run_check(service_id: int, target: str, protocol: str): + """Run a single check and store the result.""" + from app.models import add_check + + protocol = protocol.lower() + if protocol in ("http", "https"): + success, response_time_ms, error_message = check_http(target) + elif protocol == "tcp": + parts = target.split(":") + if len(parts) != 2: + add_check(service_id, False, None, "Invalid target: expected host:port") + return + try: + port = int(parts[1]) + except ValueError: + add_check(service_id, False, None, "Invalid port") + return + success, response_time_ms, error_message = check_tcp(parts[0].strip(), port) + else: + add_check(service_id, False, None, f"Unknown protocol: {protocol}") + return + + add_check(service_id, success, response_time_ms, error_message) diff --git a/app/main.py b/app/main.py new file mode 100644 index 0000000..3032080 --- /dev/null +++ b/app/main.py @@ -0,0 +1,203 @@ +"""Flask app and routes.""" +import os +from datetime import datetime, timedelta, timezone + +from flask import Flask, redirect, render_template, request, url_for + +from app import models + + +def _parse_report_dates(from_ts, to_ts, preset): + """Parse from/to dates, applying preset if given. Returns (from_ts, to_ts, from_display, to_display).""" + now = datetime.now(timezone.utc) + if preset == "24h": + to_ts = now.isoformat() + from_ts = (now - timedelta(hours=24)).isoformat() + elif preset == "7d": + to_ts = now.isoformat() + from_ts = (now - timedelta(days=7)).isoformat() + elif preset == "30d": + to_ts = now.isoformat() + from_ts = (now - timedelta(days=30)).isoformat() + if from_ts and len(from_ts) == 10: + from_ts = from_ts + "T00:00:00" + if to_ts and len(to_ts) == 10: + to_ts = to_ts + "T23:59:59.999999" + from_display = from_ts[:16] if from_ts else "" + to_display = to_ts[:16] if to_ts else "" + return from_ts, to_ts, from_display, to_display + +ROOT = os.path.dirname(os.path.dirname(os.path.abspath(__file__))) +app = Flask( + __name__, + template_folder=os.path.join(ROOT, "templates"), + static_folder=os.path.join(ROOT, "static"), +) +VERSION = os.environ.get("VERSION", "dev") + + +@app.route("/") +def dashboard(): + services = models.list_services() + return render_template("dashboard.html", services=services, version=VERSION) + + +@app.route("/api/services", methods=["GET"]) +def api_list_services(): + services = models.list_services() + return {"services": services} + + +@app.route("/api/services", methods=["POST"]) +def api_add_service(): + data = request.get_json(silent=True) + if data is None and request.form: + data = request.form.to_dict() + if not data: + return {"error": "Request body must be valid JSON (Content-Type: application/json) or form data"}, 415 + name = data.get("name", "").strip() + target = data.get("target", "").strip() + protocol = (data.get("protocol") or "https").lower().strip() + if not name or not target: + return {"error": "name and target are required"}, 400 + if protocol not in ("http", "https", "tcp"): + return {"error": "protocol must be http, https, or tcp"}, 400 + interval = int(data.get("interval_seconds", 60)) + interval = max(10, min(3600, interval)) + try: + sid = models.add_service(name, target, protocol, interval) + if request.accept_mimetypes.best == "application/json" or request.is_json: + return {"id": sid, "name": name, "target": target, "protocol": protocol} + return redirect(url_for("dashboard")) + except Exception as e: + return {"error": str(e)}, 500 + + +@app.route("/api/services/| Name | +Target | +Protocol | +Status | +Uptime | +Last Check | +Response | +Report | ++ |
|---|---|---|---|---|---|---|---|---|
| {{ s.name }} | +{{ s.target }} |
+ {{ s.protocol | upper }} | ++ {% if s.last_success is none %} + Pending + {% elif s.last_success %} + Up + {% else %} + Down + {% endif %} + | ++ {% if s.uptime_pct is not none %} + {{ s.uptime_pct }}% + {% else %} + - + {% endif %} + | +{{ s.last_check[:19] if s.last_check else '-' }} | ++ {% if s.last_response_ms is not none %} + {{ (s.last_response_ms | round(0) | int) }} ms + {% else %} + - + {% endif %} + | ++ Report + Edit + | ++ + | +
| No services yet. Add one above. | +||||||||
← Back to Dashboard | View Report
+ + +{% endblock %} diff --git a/templates/report.html b/templates/report.html new file mode 100644 index 0000000..dee2e44 --- /dev/null +++ b/templates/report.html @@ -0,0 +1,177 @@ +{% extends "base.html" %} + +{% block title %}{{ service.name }} - Report{% endblock %} + +{% block content %} +
+ {{ service.protocol | upper }}: {{ service.target }}
+ Edit
+
Showing: {{ period_label }}
+ {% endif %} + +No check data yet. Checks will appear after the first run.
+ {% endif %} +| Timestamp | +Status | +Response (ms) | +Error / Reason | +
|---|---|---|---|
| {{ c.timestamp[:19] }} | ++ {% if c.success %} + OK + {% else %} + ERROR + {% endif %} + | +{{ (c.response_time_ms | round(0) | int) if c.response_time_ms is not none else '-' }} | +{{ c.error_message or '-' }} | +
| No checks yet.{% if status_filter or search %} No matches for filter.{% endif %} | +|||
+ ← Back to Dashboard + + + +
+{% if chart_checks %} + + +{% endif %} + +{% endblock %}