feat: alert rules and active alerts UI
This commit is contained in:
@@ -0,0 +1,104 @@
|
|||||||
|
from __future__ import annotations
|
||||||
|
from datetime import datetime, timezone
|
||||||
|
from quart import Blueprint, render_template, request, redirect, url_for, current_app, session
|
||||||
|
from sqlalchemy import select
|
||||||
|
from fablednetmon.auth.middleware import require_role
|
||||||
|
from fablednetmon.models.alerts import AlertRule, AlertState, AlertStateEnum, AlertOperator
|
||||||
|
from fablednetmon.models.users import UserRole
|
||||||
|
|
||||||
|
alerts_bp = Blueprint("alerts", __name__, url_prefix="/alerts")
|
||||||
|
|
||||||
|
_OPERATORS = [(op.value, op.value) for op in AlertOperator]
|
||||||
|
|
||||||
|
|
||||||
|
@alerts_bp.get("/")
|
||||||
|
@require_role(UserRole.viewer)
|
||||||
|
async def list_alerts():
|
||||||
|
async with current_app.db_sessionmaker() as db:
|
||||||
|
result = await db.execute(
|
||||||
|
select(AlertState, AlertRule)
|
||||||
|
.join(AlertRule, AlertState.rule_id == AlertRule.id)
|
||||||
|
.where(AlertState.state.in_([
|
||||||
|
AlertStateEnum.firing, AlertStateEnum.acknowledged, AlertStateEnum.pending
|
||||||
|
]))
|
||||||
|
.order_by(AlertState.last_transition_at.desc())
|
||||||
|
)
|
||||||
|
active = result.all()
|
||||||
|
|
||||||
|
rules_result = await db.execute(
|
||||||
|
select(AlertRule).order_by(AlertRule.name)
|
||||||
|
)
|
||||||
|
rules = rules_result.scalars().all()
|
||||||
|
|
||||||
|
return await render_template("alerts/list.html", active=active, rules=rules, operators=_OPERATORS)
|
||||||
|
|
||||||
|
|
||||||
|
@alerts_bp.get("/rules/new")
|
||||||
|
@require_role(UserRole.operator)
|
||||||
|
async def new_rule():
|
||||||
|
return await render_template("alerts/rules_form.html", rule=None, operators=_OPERATORS)
|
||||||
|
|
||||||
|
|
||||||
|
@alerts_bp.post("/rules")
|
||||||
|
@require_role(UserRole.operator)
|
||||||
|
async def create_rule():
|
||||||
|
form = await request.form
|
||||||
|
user_id = session.get("user_id")
|
||||||
|
now = datetime.now(timezone.utc)
|
||||||
|
rule = AlertRule(
|
||||||
|
name=form["name"].strip(),
|
||||||
|
source_module=form["source_module"].strip(),
|
||||||
|
resource_name=form["resource_name"].strip(),
|
||||||
|
metric_name=form["metric_name"].strip(),
|
||||||
|
operator=AlertOperator(form["operator"]),
|
||||||
|
threshold=float(form["threshold"]),
|
||||||
|
consecutive_failures_required=int(form.get("consecutive_failures_required") or 1),
|
||||||
|
enabled=True,
|
||||||
|
created_by=user_id,
|
||||||
|
)
|
||||||
|
state = AlertState(
|
||||||
|
rule_id=rule.id,
|
||||||
|
state=AlertStateEnum.inactive,
|
||||||
|
last_transition_at=now,
|
||||||
|
)
|
||||||
|
async with current_app.db_sessionmaker() as db:
|
||||||
|
async with db.begin():
|
||||||
|
db.add(rule)
|
||||||
|
await db.flush()
|
||||||
|
state.rule_id = rule.id
|
||||||
|
db.add(state)
|
||||||
|
return redirect(url_for("alerts.list_alerts"))
|
||||||
|
|
||||||
|
|
||||||
|
@alerts_bp.post("/rules/<rule_id>/delete")
|
||||||
|
@require_role(UserRole.admin)
|
||||||
|
async def delete_rule(rule_id: str):
|
||||||
|
async with current_app.db_sessionmaker() as db:
|
||||||
|
async with db.begin():
|
||||||
|
result = await db.execute(select(AlertRule).where(AlertRule.id == rule_id))
|
||||||
|
rule = result.scalar_one_or_none()
|
||||||
|
if rule:
|
||||||
|
await db.delete(rule)
|
||||||
|
return redirect(url_for("alerts.list_alerts"))
|
||||||
|
|
||||||
|
|
||||||
|
@alerts_bp.post("/<rule_id>/acknowledge")
|
||||||
|
@require_role(UserRole.operator)
|
||||||
|
async def acknowledge(rule_id: str):
|
||||||
|
user_id = session.get("user_id")
|
||||||
|
now = datetime.now(timezone.utc)
|
||||||
|
async with current_app.db_sessionmaker() as db:
|
||||||
|
async with db.begin():
|
||||||
|
result = await db.execute(
|
||||||
|
select(AlertState).where(AlertState.rule_id == rule_id)
|
||||||
|
)
|
||||||
|
state = result.scalar_one_or_none()
|
||||||
|
if state is None:
|
||||||
|
return "Not found", 404
|
||||||
|
if state.state != AlertStateEnum.firing:
|
||||||
|
return "Conflict: alert is not in FIRING state", 409
|
||||||
|
state.state = AlertStateEnum.acknowledged
|
||||||
|
state.acknowledged_by = user_id
|
||||||
|
state.acknowledged_at = now
|
||||||
|
state.last_transition_at = now
|
||||||
|
return redirect(url_for("alerts.list_alerts"))
|
||||||
@@ -0,0 +1,92 @@
|
|||||||
|
{% extends "base.html" %}
|
||||||
|
{% block title %}Alerts — FabledNetMon{% endblock %}
|
||||||
|
{% block content %}
|
||||||
|
<h1 style="color:#c0c0ff;margin-bottom:1.5rem;">Alerts</h1>
|
||||||
|
|
||||||
|
{% if active %}
|
||||||
|
<h2 style="color:#8080ff;margin-bottom:1rem;font-size:1rem;">Active</h2>
|
||||||
|
<div class="card" style="padding:0;margin-bottom:2rem;">
|
||||||
|
<table style="width:100%;border-collapse:collapse;">
|
||||||
|
<thead>
|
||||||
|
<tr style="border-bottom:1px solid #2a2a4a;">
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">State</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Rule</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Resource</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Metric</th>
|
||||||
|
<th style="padding:0.75rem 1rem;"></th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
<tbody>
|
||||||
|
{% for state, rule in active %}
|
||||||
|
<tr style="border-bottom:1px solid #1a1a3a;">
|
||||||
|
<td style="padding:0.75rem 1rem;">
|
||||||
|
{% if state.state.value == 'firing' %}
|
||||||
|
<span style="color:#ff6060;font-weight:bold;">FIRING</span>
|
||||||
|
{% elif state.state.value == 'acknowledged' %}
|
||||||
|
<span style="color:#ffa040;">ACK</span>
|
||||||
|
{% else %}
|
||||||
|
<span style="color:#a0a0a0;">PENDING</span>
|
||||||
|
{% endif %}
|
||||||
|
</td>
|
||||||
|
<td style="padding:0.75rem 1rem;">{{ rule.name }}</td>
|
||||||
|
<td style="padding:0.75rem 1rem;color:#a0a0c0;">{{ rule.resource_name }}</td>
|
||||||
|
<td style="padding:0.75rem 1rem;color:#a0a0c0;">{{ rule.metric_name }} {{ rule.operator.value }} {{ rule.threshold }}</td>
|
||||||
|
<td style="padding:0.75rem 1rem;text-align:right;">
|
||||||
|
{% if state.state.value == 'firing' %}
|
||||||
|
<form method="post" action="/alerts/{{ rule.id }}/acknowledge" style="display:inline;">
|
||||||
|
<button type="submit" class="btn" style="background:#605010;">Acknowledge</button>
|
||||||
|
</form>
|
||||||
|
{% endif %}
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
{% endfor %}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
{% else %}
|
||||||
|
<p style="color:#606080;margin-bottom:2rem;">No active alerts.</p>
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
|
<div style="display:flex;align-items:center;justify-content:space-between;margin-bottom:1rem;">
|
||||||
|
<h2 style="color:#8080ff;font-size:1rem;">Rules</h2>
|
||||||
|
<a class="btn" href="/alerts/rules/new">New Rule</a>
|
||||||
|
</div>
|
||||||
|
{% if rules %}
|
||||||
|
<div class="card" style="padding:0;">
|
||||||
|
<table style="width:100%;border-collapse:collapse;">
|
||||||
|
<thead>
|
||||||
|
<tr style="border-bottom:1px solid #2a2a4a;">
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Name</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Condition</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Consec.</th>
|
||||||
|
<th style="text-align:left;padding:0.75rem 1rem;color:#8080a0;font-weight:normal;">Enabled</th>
|
||||||
|
<th style="padding:0.75rem 1rem;"></th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
<tbody>
|
||||||
|
{% for rule in rules %}
|
||||||
|
<tr style="border-bottom:1px solid #1a1a3a;">
|
||||||
|
<td style="padding:0.75rem 1rem;">{{ rule.name }}</td>
|
||||||
|
<td style="padding:0.75rem 1rem;color:#a0a0c0;">
|
||||||
|
{{ rule.source_module }}/{{ rule.resource_name }}:{{ rule.metric_name }}
|
||||||
|
{{ rule.operator.value }} {{ rule.threshold }}
|
||||||
|
</td>
|
||||||
|
<td style="padding:0.75rem 1rem;color:#a0a0c0;">{{ rule.consecutive_failures_required }}</td>
|
||||||
|
<td style="padding:0.75rem 1rem;">
|
||||||
|
{% if rule.enabled %}<span style="color:#60c060;">yes</span>{% else %}<span style="color:#606060;">no</span>{% endif %}
|
||||||
|
</td>
|
||||||
|
<td style="padding:0.75rem 1rem;text-align:right;">
|
||||||
|
<form method="post" action="/alerts/rules/{{ rule.id }}/delete" style="display:inline;">
|
||||||
|
<button type="submit" style="background:none;border:none;color:#ff6060;cursor:pointer;"
|
||||||
|
onclick="return confirm('Delete rule {{ rule.name }}?')">Delete</button>
|
||||||
|
</form>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
{% endfor %}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
{% else %}
|
||||||
|
<p style="color:#606080;">No alert rules configured.</p>
|
||||||
|
{% endif %}
|
||||||
|
{% endblock %}
|
||||||
@@ -0,0 +1,49 @@
|
|||||||
|
{% extends "base.html" %}
|
||||||
|
{% block title %}New Alert Rule — FabledNetMon{% endblock %}
|
||||||
|
{% block content %}
|
||||||
|
<div style="max-width:560px;margin:2rem auto;">
|
||||||
|
<h1 style="color:#c0c0ff;margin-bottom:1.5rem;">New Alert Rule</h1>
|
||||||
|
<div class="card">
|
||||||
|
<form method="post" action="/alerts/rules">
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Rule Name</label>
|
||||||
|
<input type="text" name="name" required autofocus placeholder="e.g. Home server down">
|
||||||
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Source Module</label>
|
||||||
|
<input type="text" name="source_module" required placeholder="ping, dns, traefik, ...">
|
||||||
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Resource Name</label>
|
||||||
|
<input type="text" name="resource_name" required placeholder="host name, router name, ...">
|
||||||
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Metric Name</label>
|
||||||
|
<input type="text" name="metric_name" required placeholder="up, response_time_ms, ...">
|
||||||
|
</div>
|
||||||
|
<div style="display:grid;grid-template-columns:1fr 1fr;gap:1rem;">
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Operator</label>
|
||||||
|
<select name="operator" style="width:100%;padding:0.5rem 0.75rem;background:#0f0f1e;border:1px solid #3a3a5a;border-radius:4px;color:#e0e0e0;">
|
||||||
|
{% for val, label in operators %}
|
||||||
|
<option value="{{ val }}">{{ label }}</option>
|
||||||
|
{% endfor %}
|
||||||
|
</select>
|
||||||
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Threshold</label>
|
||||||
|
<input type="number" name="threshold" step="any" required placeholder="0.5">
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>Consecutive failures required before FIRING (default: 1)</label>
|
||||||
|
<input type="number" name="consecutive_failures_required" value="1" min="1">
|
||||||
|
</div>
|
||||||
|
<div style="display:flex;gap:1rem;margin-top:1.5rem;">
|
||||||
|
<button type="submit">Create Rule</button>
|
||||||
|
<a href="/alerts/" style="padding:0.5rem 1rem;color:#a0a0c0;text-decoration:none;">Cancel</a>
|
||||||
|
</div>
|
||||||
|
</form>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{% endblock %}
|
||||||
Reference in New Issue
Block a user