mirror of
https://github.com/jhd3197/ServerKit.git
synced 2026-10-28 07:37:56 +09:00
Juan Denis
b9456d1a9a
Uptime columns defaulted to 100.0 and the pages formatted a missing value as 100.00%, so a new monitor showed a perfect month. The average also used 'uptime || 100', turning a fully down component (0%) into 100%. Missing data now reads as a dash and 0 stays 0; both status pages share one helper.
237 lines
10 KiB
Python
237 lines
10 KiB
Python
from datetime import datetime, timedelta
|
|
from app import db
|
|
from app.models.mixins import TimestampMixin, SerializableMixin
|
|
import json
|
|
|
|
|
|
class StatusPage(TimestampMixin, db.Model):
|
|
"""Public-facing status page configuration."""
|
|
__tablename__ = 'status_pages'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
name = db.Column(db.String(128), nullable=False)
|
|
slug = db.Column(db.String(128), nullable=False, unique=True)
|
|
description = db.Column(db.Text)
|
|
|
|
# Branding
|
|
logo_url = db.Column(db.String(512))
|
|
primary_color = db.Column(db.String(7), default='#4f46e5')
|
|
custom_domain = db.Column(db.String(256))
|
|
|
|
# Settings
|
|
is_public = db.Column(db.Boolean, default=True)
|
|
show_uptime = db.Column(db.Boolean, default=True)
|
|
show_history = db.Column(db.Boolean, default=True)
|
|
|
|
|
|
components = db.relationship('StatusComponent', backref='status_page', lazy='dynamic',
|
|
order_by='StatusComponent.sort_order', cascade='all, delete-orphan')
|
|
incidents = db.relationship('StatusIncident', backref='status_page', lazy='dynamic',
|
|
order_by='StatusIncident.created_at.desc()', cascade='all, delete-orphan')
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'id': self.id,
|
|
'name': self.name,
|
|
'slug': self.slug,
|
|
'description': self.description,
|
|
'logo_url': self.logo_url,
|
|
'primary_color': self.primary_color,
|
|
'custom_domain': self.custom_domain,
|
|
'is_public': self.is_public,
|
|
'show_uptime': self.show_uptime,
|
|
'show_history': self.show_history,
|
|
'component_count': self.components.count(),
|
|
'created_at': self.created_at.isoformat() if self.created_at else None,
|
|
}
|
|
|
|
|
|
class StatusComponent(db.Model):
|
|
"""A monitor: one synthetic check against a URL, host or managed site.
|
|
|
|
Despite the table name this is the panel's *monitor* primitive — /monitoring
|
|
lists these directly. ``page_id`` is optional: a monitor exists on its own,
|
|
and a status page merely publishes a subset of them.
|
|
"""
|
|
__tablename__ = 'status_components'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
# Nullable: a monitor can exist with no status page attached (migration 081).
|
|
page_id = db.Column(db.Integer, db.ForeignKey('status_pages.id'), nullable=True, index=True)
|
|
name = db.Column(db.String(128), nullable=False)
|
|
description = db.Column(db.Text)
|
|
group = db.Column(db.String(64)) # e.g., "Web Services", "APIs"
|
|
sort_order = db.Column(db.Integer, default=0)
|
|
|
|
# Health check config
|
|
CHECK_TYPES = ('http', 'keyword', 'tcp', 'dns', 'smtp', 'ping')
|
|
check_type = db.Column(db.String(16), default='http')
|
|
check_target = db.Column(db.String(512)) # URL, host:port, etc.
|
|
check_interval = db.Column(db.Integer, default=60) # seconds
|
|
check_timeout = db.Column(db.Integer, default=10)
|
|
|
|
# Probe options (migration 081). Each backs one control on the monitor's
|
|
# Configuration section.
|
|
check_method = db.Column(db.String(8), default='GET')
|
|
expected_status = db.Column(db.String(32), default='200-299')
|
|
keyword = db.Column(db.String(256)) # body substring for check_type='keyword'
|
|
follow_redirects = db.Column(db.Boolean, default=True)
|
|
verify_tls = db.Column(db.Boolean, default=True)
|
|
# Failed checks tolerated before an incident opens, and the running counter
|
|
# that drives it. Reset to 0 on any successful check.
|
|
retries = db.Column(db.Integer, default=2)
|
|
consecutive_failures = db.Column(db.Integer, default=0)
|
|
|
|
# Paused monitors keep their history and last known status but are skipped
|
|
# by the scheduler. Kept separate from `status` so pausing never looks like
|
|
# an outage on a status page.
|
|
is_paused = db.Column(db.Boolean, default=False, nullable=False)
|
|
|
|
# TLS certificate observed on the last https probe. `cert_checked_at` is not
|
|
# the same as `last_check_at`: reading the certificate opens a second
|
|
# connection, so it is throttled independently of the probe itself.
|
|
cert_issuer = db.Column(db.String(256))
|
|
cert_expires_at = db.Column(db.DateTime)
|
|
cert_checked_at = db.Column(db.DateTime)
|
|
|
|
# Optional binding to a managed WordPress site. When set, the component's
|
|
# status is driven from the site's health checks (#26) rather than a network
|
|
# probe, and a real uptime % accrues from the recorded HealthCheck rows.
|
|
wordpress_site_id = db.Column(db.Integer, db.ForeignKey('wordpress_sites.id'), nullable=True, index=True)
|
|
|
|
# Status
|
|
STATUS_OPERATIONAL = 'operational'
|
|
STATUS_DEGRADED = 'degraded'
|
|
STATUS_PARTIAL = 'partial_outage'
|
|
STATUS_MAJOR = 'major_outage'
|
|
STATUS_MAINTENANCE = 'maintenance'
|
|
status = db.Column(db.String(32), default=STATUS_OPERATIONAL)
|
|
|
|
last_check_at = db.Column(db.DateTime)
|
|
last_response_time = db.Column(db.Integer) # ms
|
|
|
|
# Uptime per window, filled from recorded checks. None until a window
|
|
# has a sample: a new monitor has no record, not a perfect one.
|
|
uptime_24h = db.Column(db.Float)
|
|
uptime_7d = db.Column(db.Float)
|
|
uptime_30d = db.Column(db.Float)
|
|
uptime_90d = db.Column(db.Float)
|
|
|
|
created_at = db.Column(db.DateTime, default=datetime.utcnow)
|
|
|
|
checks = db.relationship('HealthCheck', backref='component', lazy='dynamic',
|
|
order_by='HealthCheck.checked_at.desc()', cascade='all, delete-orphan')
|
|
|
|
@property
|
|
def next_check_at(self):
|
|
"""When the scheduler will next poll this monitor, or None if paused or
|
|
never checked. Derived rather than stored so changing the interval takes
|
|
effect immediately."""
|
|
if self.is_paused or not self.last_check_at:
|
|
return None
|
|
return self.last_check_at + timedelta(seconds=self.check_interval or 60)
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'id': self.id,
|
|
'page_id': self.page_id,
|
|
'name': self.name,
|
|
'description': self.description,
|
|
'group': self.group,
|
|
'sort_order': self.sort_order,
|
|
'check_type': self.check_type,
|
|
'check_target': self.check_target,
|
|
'check_interval': self.check_interval,
|
|
'check_timeout': self.check_timeout,
|
|
'check_method': self.check_method,
|
|
'expected_status': self.expected_status,
|
|
'keyword': self.keyword,
|
|
'follow_redirects': self.follow_redirects,
|
|
'verify_tls': self.verify_tls,
|
|
'retries': self.retries,
|
|
'consecutive_failures': self.consecutive_failures,
|
|
'is_paused': bool(self.is_paused),
|
|
'cert_issuer': self.cert_issuer,
|
|
'cert_expires_at': self.cert_expires_at.isoformat() if self.cert_expires_at else None,
|
|
'cert_checked_at': self.cert_checked_at.isoformat() if self.cert_checked_at else None,
|
|
'wordpress_site_id': self.wordpress_site_id,
|
|
'status': self.status,
|
|
'last_check_at': self.last_check_at.isoformat() if self.last_check_at else None,
|
|
'last_response_time': self.last_response_time,
|
|
'next_check_at': self.next_check_at.isoformat() if self.next_check_at else None,
|
|
'uptime_24h': self.uptime_24h,
|
|
'uptime_7d': self.uptime_7d,
|
|
'uptime_30d': self.uptime_30d,
|
|
'uptime_90d': self.uptime_90d,
|
|
}
|
|
|
|
|
|
class HealthCheck(SerializableMixin, db.Model):
|
|
"""Individual health check result."""
|
|
__tablename__ = 'health_checks'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
component_id = db.Column(db.Integer, db.ForeignKey('status_components.id'), nullable=False, index=True)
|
|
status = db.Column(db.String(16)) # up, down, degraded
|
|
response_time = db.Column(db.Integer) # ms
|
|
status_code = db.Column(db.Integer)
|
|
error = db.Column(db.Text)
|
|
checked_at = db.Column(db.DateTime, default=datetime.utcnow)
|
|
|
|
|
|
|
|
class StatusIncident(TimestampMixin, db.Model):
|
|
"""An incident on the status page."""
|
|
__tablename__ = 'status_incidents'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
# Nullable: an incident auto-opened for a monitor that belongs to no status
|
|
# page has no page either (migration 081).
|
|
page_id = db.Column(db.Integer, db.ForeignKey('status_pages.id'), nullable=True, index=True)
|
|
# Optional link to the component this incident is about. Set when an incident
|
|
# is auto-opened from a health check, so it can be auto-resolved on recovery (#26).
|
|
component_id = db.Column(db.Integer, db.ForeignKey('status_components.id'), nullable=True, index=True)
|
|
title = db.Column(db.String(256), nullable=False)
|
|
status = db.Column(db.String(32), default='investigating') # investigating, identified, monitoring, resolved
|
|
impact = db.Column(db.String(32), default='minor') # none, minor, major, critical
|
|
body = db.Column(db.Text)
|
|
|
|
# Maintenance window
|
|
is_maintenance = db.Column(db.Boolean, default=False)
|
|
scheduled_start = db.Column(db.DateTime)
|
|
scheduled_end = db.Column(db.DateTime)
|
|
|
|
resolved_at = db.Column(db.DateTime)
|
|
|
|
updates = db.relationship('StatusIncidentUpdate', backref='incident', lazy='dynamic',
|
|
order_by='StatusIncidentUpdate.created_at.desc()', cascade='all, delete-orphan')
|
|
|
|
def to_dict(self):
|
|
return {
|
|
'id': self.id,
|
|
'page_id': self.page_id,
|
|
'component_id': self.component_id,
|
|
'title': self.title,
|
|
'status': self.status,
|
|
'impact': self.impact,
|
|
'body': self.body,
|
|
'is_maintenance': self.is_maintenance,
|
|
'scheduled_start': self.scheduled_start.isoformat() if self.scheduled_start else None,
|
|
'scheduled_end': self.scheduled_end.isoformat() if self.scheduled_end else None,
|
|
'resolved_at': self.resolved_at.isoformat() if self.resolved_at else None,
|
|
'created_at': self.created_at.isoformat() if self.created_at else None,
|
|
'updates': [u.to_dict() for u in self.updates.limit(20).all()],
|
|
}
|
|
|
|
|
|
class StatusIncidentUpdate(SerializableMixin, db.Model):
|
|
"""Timeline update for an incident."""
|
|
__tablename__ = 'status_incident_updates'
|
|
|
|
id = db.Column(db.Integer, primary_key=True)
|
|
incident_id = db.Column(db.Integer, db.ForeignKey('status_incidents.id'), nullable=False, index=True)
|
|
status = db.Column(db.String(32))
|
|
body = db.Column(db.Text, nullable=False)
|
|
created_at = db.Column(db.DateTime, default=datetime.utcnow)
|
|
|