mirror of
https://github.com/jhd3197/ServerKit.git
synced 2026-11-09 05:24:49 +09:00
Juan DenisandClaude Fable 5
5417c39100
An audit found 102 FK columns with no index — every join, per-parent listing, and the delete cascades from _delete_cascade_policy scanned whole tables on them (deployments.app_id, audit_logs.user_id, dns_records.zone_id, webhook_logs.webhook_id, ...). All FK columns now declare index=True; migration 096 creates the same indexes on existing installs, deriving the list from the live schema at upgrade time (so it is idempotent and cannot drift from what an install actually has). Ratchet: test_every_fk_column_is_indexed pins the rule with no allowlist — a new FK column is born indexed or the build fails. Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
236 lines
10 KiB
Python
236 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 data
|
|
uptime_24h = db.Column(db.Float, default=100.0)
|
|
uptime_7d = db.Column(db.Float, default=100.0)
|
|
uptime_30d = db.Column(db.Float, default=100.0)
|
|
uptime_90d = db.Column(db.Float, default=100.0)
|
|
|
|
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)
|
|
|