Compare commits

...
3 Commits
46 changed files with 1037 additions and 310 deletions

No files matched your search

+1 -1
View File
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
[project]
name = "tesm"
version = "2.4.1"
version = "2.5.2"
description = "TESM -- Verwaltung und Ueberwachung von PoE-Endgeraeten und Aruba-Switchen"
requires-python = ">=3.11"
dependencies = [
+4 -4
View File
@@ -13,7 +13,7 @@ from tesm_core.licensing_client import LicenseError
from ..services import transfer
bp = Blueprint("backup", __name__, url_prefix="/sicherung")
bp = Blueprint("backup", __name__, url_prefix="/administration/backup")
MAX_IMPORT_BYTES = 64 * 1024 * 1024
PREVIEW_SESSION_KEY = "_import_token"
@@ -129,7 +129,7 @@ def export():
)
@bp.post("/import/vorschau")
@bp.post("/import/preview")
@permission_required("backup.execute")
@reauth_required
def import_preview():
@@ -161,7 +161,7 @@ def import_preview():
return redirect(url_for("backup.overview"))
@bp.post("/import/uebernehmen")
@bp.post("/import/apply")
@permission_required("backup.execute")
@reauth_required
def import_apply():
@@ -225,7 +225,7 @@ def import_apply():
return redirect(url_for("backup.overview"))
@bp.post("/import/verwerfen")
@bp.post("/import/discard")
@permission_required("backup.execute")
def import_discard():
token = session.pop(PREVIEW_SESSION_KEY, "")
+4 -4
View File
@@ -12,7 +12,7 @@ from tesm_core.extension import core, db, transaction
from ..services import inventory
bp = Blueprint("credentials", __name__, url_prefix="/zugangsdaten")
bp = Blueprint("credentials", __name__, url_prefix="/monitoring/credentials")
def _audit(conn: Any, action: str, target: str, detail: str = "", severity: str = "info") -> None:
@@ -39,7 +39,7 @@ def overview():
)
@bp.post("/neu")
@bp.post("/new")
@permission_required("credentials.create")
def create():
try:
@@ -91,7 +91,7 @@ def update(credential_id: int):
return redirect(url_for("credentials.overview"))
@bp.post("/<int:credential_id>/loeschen")
@bp.post("/<int:credential_id>/delete")
@permission_required("credentials.delete")
def delete(credential_id: int):
try:
@@ -109,7 +109,7 @@ def delete(credential_id: int):
return redirect(url_for("credentials.overview"))
@bp.post("/<int:credential_id>/anzeigen")
@bp.post("/<int:credential_id>/reveal")
@permission_required("credentials.secrets")
# Die frische Bestaetigung verlangt das Recht selbst (SENSITIVE_ACTIONS).
def reveal(credential_id: int):
+2 -2
View File
@@ -121,7 +121,7 @@ def _tiles(*, authenticated: bool) -> dict[str, Any]:
}
@bp.get("/uebersicht")
@bp.get("/overview")
def index():
from tesm_core.auth.models import current_user
@@ -138,7 +138,7 @@ def index_view():
return index()
@bp.get("/uebersicht/kacheln")
@bp.get("/overview/tiles")
@fragment
def tiles():
"""Teilbereich fuer die automatische Aktualisierung -- liefert nur HTML-Fragment."""
+9 -9
View File
@@ -20,7 +20,7 @@ from tesm_core.extension import core, db, transaction
from ..services import inventory, monitor, restart, ssh
bp = Blueprint("devices", __name__, url_prefix="/clients")
bp = Blueprint("devices", __name__, url_prefix="/monitoring/clients")
def _audit(conn: Any, action: str, target: str, detail: str = "", severity: str = "info") -> None:
@@ -113,7 +113,7 @@ def _credential_from_form(conn: Any) -> int | None:
)
@bp.post("/neu")
@bp.post("/new")
@permission_required("devices.create")
def create():
try:
@@ -161,7 +161,7 @@ def update(device_id: int):
return redirect(url_for("devices.overview"))
@bp.post("/<int:device_id>/aktiv")
@bp.post("/<int:device_id>/active")
@permission_required("devices.edit")
def toggle_active(device_id: int):
active = request.form.get("active") == "1"
@@ -180,7 +180,7 @@ def toggle_active(device_id: int):
return redirect(request.referrer or url_for("devices.overview"))
@bp.post("/<int:device_id>/loeschen")
@bp.post("/<int:device_id>/delete")
@permission_required("devices.delete")
def delete(device_id: int):
with transaction() as conn:
@@ -193,7 +193,7 @@ def delete(device_id: int):
return redirect(url_for("devices.overview"))
@bp.post("/<int:device_id>/neustart")
@bp.post("/<int:device_id>/restart")
@permission_required("devices.execute")
def restart_device(device_id: int):
"""Startet ein Geraet neu -- ueber den Weg, der dafuer gewaehlt wurde.
@@ -351,7 +351,7 @@ def detail(device_id: int):
categories=inventory.DEVICE_CATEGORIES,
host_keys=host_keys,
method_labels=monitor.METHOD_LABELS,
terminal_enabled=bool(extension.settings.get(conn, "terminal_enabled")),
terminal_enabled=bool(extension.settings.get(conn, "terminal_clients_enabled")),
)
@@ -360,7 +360,7 @@ def detail(device_id: int):
# --------------------------------------------------------------------------- #
@bp.post("/<int:device_id>/hostkey/pruefen")
@bp.post("/<int:device_id>/host-key/probe")
@permission_required("devices.edit")
def probe_host_key(device_id: int):
"""Liest den Host-Schluessel des Clients, ohne sich anzumelden.
@@ -390,7 +390,7 @@ def probe_host_key(device_id: int):
)
@bp.post("/<int:device_id>/hostkey/freigeben")
@bp.post("/<int:device_id>/host-key/trust")
@permission_required("devices.edit")
@reauth_required
def trust_host_key(device_id: int):
@@ -424,7 +424,7 @@ def trust_host_key(device_id: int):
return redirect(url_for("devices.detail", device_id=device_id))
@bp.post("/<int:device_id>/hostkey/verwerfen")
@bp.post("/<int:device_id>/host-key/forget")
@permission_required("devices.edit")
def forget_host_key(device_id: int):
conn = db()
+12 -12
View File
@@ -105,7 +105,7 @@ def overview():
# --------------------------------------------------------------------------- #
@bp.post("/einstellungen")
@bp.post("/settings")
@permission_required("dhcp.edit")
def save_settings():
extension = core()
@@ -122,7 +122,7 @@ def save_settings():
return _write_and_redirect()
@bp.post("/subnetz")
@bp.post("/subnet")
@permission_required("dhcp.edit")
def add_subnet():
extension = core()
@@ -158,7 +158,7 @@ def add_subnet():
return _write_and_redirect()
@bp.post("/subnetz/<int:subnet_id>")
@bp.post("/subnet/<int:subnet_id>")
@permission_required("dhcp.edit")
def update_subnet(subnet_id: int):
extension = core()
@@ -194,7 +194,7 @@ def update_subnet(subnet_id: int):
return _write_and_redirect()
@bp.post("/subnetz/<int:subnet_id>/loeschen")
@bp.post("/subnet/<int:subnet_id>/delete")
@permission_required("dhcp.edit")
def delete_subnet(subnet_id: int):
with transaction() as conn:
@@ -209,7 +209,7 @@ def delete_subnet(subnet_id: int):
# --------------------------------------------------------------------------- #
@bp.post("/option/wert")
@bp.post("/option/value")
@permission_required("dhcp.edit")
def set_option_value():
conn = db()
@@ -248,7 +248,7 @@ def _device_option_values(conn) -> dict[int, list[dict[str, Any]]]: # type: ign
return gruppen
@bp.post("/option/geraet")
@bp.post("/option/device")
@permission_required("dhcp.edit")
def set_device_option_value():
"""Setzt eine Option fuer ein einzelnes Geraet.
@@ -296,7 +296,7 @@ def set_device_option_value():
return _write_and_redirect()
@bp.post("/option/neu")
@bp.post("/option/new")
@permission_required("dhcp.edit")
def add_custom_option():
conn = db()
@@ -327,7 +327,7 @@ def add_custom_option():
return redirect(url_for("dhcp.overview"))
@bp.post("/option/<int:option_id>/loeschen")
@bp.post("/option/<int:option_id>/delete")
@permission_required("dhcp.edit")
def delete_custom_option(option_id: int):
conn = db()
@@ -352,7 +352,7 @@ def delete_custom_option(option_id: int):
# --------------------------------------------------------------------------- #
@bp.post("/reservierung")
@bp.post("/reservation")
@permission_required("dhcp.edit")
def add_reservation():
conn = db()
@@ -412,7 +412,7 @@ def add_reservation():
return _write_and_redirect()
@bp.post("/reservierung/<int:reservation_id>/loeschen")
@bp.post("/reservation/<int:reservation_id>/delete")
@permission_required("dhcp.edit")
def delete_reservation(reservation_id: int):
with transaction() as conn:
@@ -480,13 +480,13 @@ def _write_and_redirect():
return redirect(url_for("dhcp.overview"))
@bp.post("/schreiben")
@bp.post("/write")
@permission_required("dhcp.edit")
def write_config():
return _write_and_redirect()
@bp.post("/dienst/<action>")
@bp.post("/service/<action>")
@permission_required("dhcp.execute")
def service_action(action: str):
allowed = {"install", "start", "stop"}
+63 -34
View File
@@ -23,7 +23,7 @@ from tesm_core.extension import core, db, transaction
from ..services import fileshare as service
bp = Blueprint("fileshare", __name__, url_prefix="/dateifreigaben")
bp = Blueprint("fileshare", __name__, url_prefix="/fileshares")
@bp.before_request
@@ -60,8 +60,8 @@ def _mount_or_404(token: str) -> service.Mount:
def browse():
conn = db()
mounts = service.active_mounts(conn, current_user.id)
token = request.args.get("freigabe") or (mounts[0].token if mounts else "")
relative = request.args.get("pfad") or ""
token = request.args.get("share") or (mounts[0].token if mounts else "")
relative = request.args.get("path") or ""
listing = None
error = ""
if token:
@@ -85,14 +85,14 @@ def browse():
)
@bp.get("/<token>/herunterladen")
@bp.get("/<token>/download")
# Herunterladen traegt Daten aus dem System heraus -- in der Rechtematrix ist
# das "Exportieren", nicht "Ansehen". Eine Vorschau bleibt im Haus, eine
# heruntergeladene Datei nicht.
@permission_required("fileshare.export")
def download(token: str):
mount = _mount_or_404(token)
relative = request.args.get("pfad") or ""
relative = request.args.get("path") or ""
try:
path = service.resolve_path(mount, relative)
except service.FileshareError as exc:
@@ -113,11 +113,11 @@ def download(token: str):
)
@bp.get("/<token>/vorschau")
@bp.get("/<token>/preview")
@permission_required("fileshare.view")
def preview(token: str):
mount = _mount_or_404(token)
relative = request.args.get("pfad") or ""
relative = request.args.get("path") or ""
try:
path = service.resolve_path(mount, relative)
mimetype = service.preview_mime(path.name)
@@ -152,15 +152,15 @@ def preview(token: str):
)
@bp.post("/<token>/hochladen")
@bp.post("/<token>/upload")
@permission_required("fileshare.create")
def upload(token: str):
mount = _mount_or_404(token)
relative = request.form.get("pfad") or ""
relative = request.form.get("path") or ""
files = request.files.getlist("files")
if not files:
flash("Keine Datei ausgewaehlt.", "danger")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=relative))
return redirect(url_for("fileshare.browse", share=token, path=relative))
limit = uploads.limit_bytes(db())
stored = 0
@@ -178,15 +178,15 @@ def upload(token: str):
stored += 1
except service.FileshareError as exc:
flash(str(exc), "danger")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=relative))
return redirect(url_for("fileshare.browse", share=token, path=relative))
if stored:
_audit("fileshare.uploaded", f"{mount.label}:{relative}", f"{stored} Datei(en)")
flash(f"{stored} Datei(en) hochgeladen.", "success")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=relative))
return redirect(url_for("fileshare.browse", share=token, path=relative))
@bp.post("/<token>/formular")
@bp.post("/<token>/form")
@permission_required("fileshare_pdf.create")
def save_form(token: str):
"""Nimmt ein in der Vorschau ausgefuelltes PDF und legt es daneben ab.
@@ -196,7 +196,7 @@ def save_form(token: str):
die alte Datei danach loeschen -- das ist eine bewusste Handlung.
"""
mount = _mount_or_404(token)
relative = request.form.get("pfad") or ""
relative = request.form.get("path") or ""
upload_file = request.files.get("datei")
if upload_file is None or not upload_file.filename:
return {"error": "Es kam keine Datei an."}, 400
@@ -259,47 +259,47 @@ def save_form(token: str):
wohin = ziel.relative_to(mount.path.resolve()).as_posix()
_audit("fileshare.form_saved", f"{mount.label}:{relative}", wohin, severity="notice")
return {"message": f"Gespeichert als {wohin}.", "pfad": wohin}
return {"message": f"Gespeichert als {wohin}.", "path": wohin}
@bp.post("/<token>/ordner")
@bp.post("/<token>/folder")
@permission_required("fileshare.create")
def make_directory(token: str):
mount = _mount_or_404(token)
relative = request.form.get("pfad") or ""
relative = request.form.get("path") or ""
try:
service.make_directory(mount, relative, request.form.get("name", ""))
except (service.FileshareError, OSError) as exc:
flash(str(exc), "danger")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=relative))
return redirect(url_for("fileshare.browse", share=token, path=relative))
_audit("fileshare.directory_created", f"{mount.label}:{relative}/{request.form.get('name')}")
flash("Ordner angelegt.", "success")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=relative))
return redirect(url_for("fileshare.browse", share=token, path=relative))
@bp.post("/<token>/umbenennen")
@bp.post("/<token>/rename")
@permission_required("fileshare.edit")
def rename(token: str):
mount = _mount_or_404(token)
relative = request.form.get("pfad") or ""
relative = request.form.get("path") or ""
parent = request.form.get("parent") or ""
try:
service.rename_entry(mount, relative, request.form.get("name", ""))
except (service.FileshareError, OSError) as exc:
flash(str(exc), "danger")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=parent))
return redirect(url_for("fileshare.browse", share=token, path=parent))
_audit("fileshare.renamed", f"{mount.label}:{relative}")
flash("Umbenannt.", "success")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=parent))
return redirect(url_for("fileshare.browse", share=token, path=parent))
@bp.post("/<token>/loeschen")
@bp.post("/<token>/delete")
@permission_required("fileshare.delete")
def delete(token: str):
mount = _mount_or_404(token)
parent = request.form.get("parent") or ""
removed = 0
for relative in request.form.getlist("pfade"):
for relative in request.form.getlist("paths"):
try:
kind = service.delete_entry(mount, relative)
_audit("fileshare.deleted", f"{mount.label}:{relative}", kind, severity="warning")
@@ -308,10 +308,10 @@ def delete(token: str):
flash(str(exc), "danger")
if removed:
flash(f"{removed} Eintrag/Eintraege geloescht.", "success")
return redirect(url_for("fileshare.browse", freigabe=token, pfad=parent))
return redirect(url_for("fileshare.browse", share=token, path=parent))
@bp.post("/<token>/freigeben")
@bp.post("/<token>/release")
@permission_required("fileshare.view")
def release(token: str):
mount = _mount_or_404(token)
@@ -327,7 +327,7 @@ def release(token: str):
# --------------------------------------------------------------------------- #
@bp.get("/zuordnungen")
@bp.get("/mappings")
@permission_required("fileshare.edit")
def mappings():
from tesm_core.auth import directory
@@ -341,7 +341,7 @@ def mappings():
)
@bp.post("/zuordnungen")
@bp.post("/mappings")
@permission_required("fileshare.edit")
def mapping_add():
try:
@@ -353,18 +353,33 @@ def mapping_add():
label=request.form.get("label", ""),
unc=request.form.get("unc", ""),
)
_audit("fileshare.mapping_added", request.form.get("label", ""), severity="notice")
_audit(
"fileshare.mapping_added",
request.form.get("label", ""),
service.describe_mapping(
{
"unc": request.form.get("unc", ""),
"ad_group_name": request.form.get("ad_group_name", ""),
"ad_group_dn": request.form.get("ad_group_dn", ""),
}
),
severity="notice",
)
flash("Zuordnung gespeichert.", "success")
except service.FileshareError as exc:
flash(str(exc), "danger")
return redirect(url_for("fileshare.mappings"))
@bp.post("/zuordnungen/<int:mapping_id>")
@bp.post("/mappings/<int:mapping_id>")
@permission_required("fileshare.edit")
def mapping_update(mapping_id: int):
try:
with transaction() as conn:
# Den Stand vor der Aenderung merken -- danach ist er weg, und
# "geaendert" ohne "was" beantwortet keine einzige Frage, die man
# spaeter an ein Protokoll stellt.
vorher = service.get_mapping(conn, mapping_id)
service.update_mapping(
conn,
mapping_id,
@@ -373,18 +388,32 @@ def mapping_update(mapping_id: int):
label=request.form.get("label", ""),
unc=request.form.get("unc", ""),
)
_audit("fileshare.mapping_updated", request.form.get("label", ""), severity="notice")
nachher = service.get_mapping(conn, mapping_id)
_audit(
"fileshare.mapping_updated",
str((nachher or {}).get("label") or request.form.get("label", "")),
service.mapping_changes(vorher, nachher) or "keine inhaltliche Aenderung",
severity="notice",
)
flash("Zuordnung geaendert.", "success")
except service.FileshareError as exc:
flash(str(exc), "danger")
return redirect(url_for("fileshare.mappings"))
@bp.post("/zuordnungen/<int:mapping_id>/loeschen")
@bp.post("/mappings/<int:mapping_id>/delete")
@permission_required("fileshare.edit")
def mapping_delete(mapping_id: int):
with transaction() as conn:
entfernt = service.get_mapping(conn, mapping_id)
service.delete_mapping(conn, mapping_id)
_audit("fileshare.mapping_deleted", str(mapping_id), severity="notice")
# Eine entfernte Zuordnung nimmt allen Mitgliedern der Gruppe den Zugang
# zu dieser Freigabe -- das ist keine Notiz am Rande, sondern eine Warnung.
_audit(
"fileshare.mapping_deleted",
str((entfernt or {}).get("label") or mapping_id),
service.describe_mapping(entfernt),
severity="warning",
)
flash("Zuordnung entfernt.", "success")
return redirect(url_for("fileshare.mappings"))
+5 -5
View File
@@ -31,7 +31,7 @@ from tesm_core.extension import core, db, transaction
from ..services import inventory, ssh
bp = Blueprint("hostkeys", __name__, url_prefix="/hostschluessel")
bp = Blueprint("hostkeys", __name__, url_prefix="/monitoring/host-keys")
KIND_DEVICE = "client"
KIND_SWITCH = "switch"
@@ -142,7 +142,7 @@ def _require(kind: str) -> None:
abort(403)
@bp.post("/<kind>/<int:target_id>/pruefen")
@bp.post("/<kind>/<int:target_id>/probe")
@permission_required("devices.view", "switches.view", mode="any")
def probe(kind: str, target_id: int):
conn = db()
@@ -169,7 +169,7 @@ def probe(kind: str, target_id: int):
)
@bp.post("/<kind>/<int:target_id>/freigeben")
@bp.post("/<kind>/<int:target_id>/trust")
@permission_required("devices.view", "switches.view", mode="any")
@reauth_required
def trust(kind: str, target_id: int):
@@ -203,7 +203,7 @@ def trust(kind: str, target_id: int):
return redirect(url_for("hostkeys.overview"))
@bp.post("/<kind>/<int:target_id>/verwerfen")
@bp.post("/<kind>/<int:target_id>/forget")
@permission_required("devices.view", "switches.view", mode="any")
def forget(kind: str, target_id: int):
conn = db()
@@ -222,7 +222,7 @@ def forget(kind: str, target_id: int):
return redirect(url_for("hostkeys.overview"))
@bp.post("/verwaist/verwerfen")
@bp.post("/orphaned/forget")
@permission_required("devices.edit", "switches.edit", mode="any")
def forget_orphan():
"""Entfernt eine Freigabe, zu der es kein Ziel mehr gibt."""
+7 -7
View File
@@ -23,7 +23,7 @@ from tesm_core.licensing_client import LICENSED_FEATURES, LicenseError
import tesm_licensing as lic
bp = Blueprint("license", __name__, url_prefix="/lizenz")
bp = Blueprint("license", __name__, url_prefix="/administration/license")
MAX_UPLOAD_BYTES = 256 * 1024
@@ -69,7 +69,7 @@ def overview():
)
@bp.post("/einspielen")
@bp.post("/install")
@permission_required("settings_license.edit")
def upload():
extension = core()
@@ -110,13 +110,13 @@ def upload():
return redirect(url_for("license.overview"))
@bp.post("/aktivieren")
@bp.post("/activate")
@permission_required("settings_license.edit")
def activate():
return _handshake("activate")
@bp.post("/deaktivieren")
@bp.post("/deactivate")
@permission_required("settings_license.edit")
@reauth_required
def deactivate():
@@ -158,7 +158,7 @@ def _handshake(action: str):
return redirect(url_for("license.overview"))
@bp.post("/offline-antwort")
@bp.post("/offline-response")
@permission_required("settings_license.edit")
def offline_response():
extension = core()
@@ -177,7 +177,7 @@ def offline_response():
return redirect(url_for("license.overview"))
@bp.post("/serverzertifikat")
@bp.post("/server-certificate")
@permission_required("settings_license.edit")
def server_certificate():
"""Hinterlegt das Zertifikat des Lizenzservers.
@@ -222,7 +222,7 @@ def server_certificate():
return redirect(url_for("license.overview"))
@bp.post("/aussteller/<key_id>/entfernen")
@bp.post("/issuer/<key_id>/remove")
@admin_required
@reauth_required
def remove_trusted_key(key_id: str):
+4 -4
View File
@@ -13,12 +13,12 @@ from tesm_core.extension import core, db
from ..services import kea, monitor
bp = Blueprint("tesmlogs", __name__, url_prefix="/protokolle")
bp = Blueprint("tesmlogs", __name__, url_prefix="/logs")
MAX_TAIL_LINES = 2000
@bp.get("/kea")
@bp.get("/dhcp")
@permission_required("logs_dhcp.view")
def dhcp():
extension = core()
@@ -38,7 +38,7 @@ def dhcp():
return render_template("tesm/logs_kea.html", lines=lines, path=kea.LOG_PATH, error=error)
@bp.get("/neustarts")
@bp.get("/restarts")
@permission_required("devices.view")
def restarts():
"""Alle Neustarts -- ueber den PoE-Port und per Befehl aus der Wartung.
@@ -48,7 +48,7 @@ def restarts():
der Neustart-Historie vollstaendig -- obwohl genau dort jemand nachsieht,
der wissen will, warum ein Geraet weg war.
"""
method = (request.args.get("methode") or "").strip()
method = (request.args.get("method") or "").strip()
if method and method not in monitor.METHOD_LABELS:
method = ""
sql = (
+7 -7
View File
@@ -25,7 +25,7 @@ from tesm_core.extension import core, db, transaction
from ..services import inventory, maintenance as service, ssh, windowsops, monitor
bp = Blueprint("maintenance", __name__, url_prefix="/wartung")
bp = Blueprint("maintenance", __name__, url_prefix="/maintenance")
@bp.before_request
@@ -85,7 +85,7 @@ def overview():
category_labels=dict(inventory.CREDENTIAL_CATEGORIES),
category_effects=inventory.CATEGORY_EFFECTS,
update_category=inventory.MAINTENANCE_CATEGORY,
terminal_enabled=bool(core().settings.get(conn, "terminal_enabled")),
terminal_enabled=bool(core().settings.get(conn, "terminal_clients_enabled")),
windows_tool_missing=_windows_tool_missing(conn),
windows_package=windowsops.REQUIRED_PACKAGE,
)
@@ -105,7 +105,7 @@ def _windows_tool_missing(conn) -> bool: # type: ignore[no-untyped-def]
)
@bp.post("/paket-nachinstallieren")
@bp.post("/install-package")
@permission_required("maintenance.execute")
def install_windows_tool():
"""Installiert das Paket, das der Fehlermeldung nach fehlt.
@@ -165,7 +165,7 @@ def status():
)
@bp.get("/auftrag/<job_id>")
@bp.get("/job/<job_id>")
@permission_required("maintenance.view", "maintenance.execute", mode="any")
def job_detail(job_id: str):
conn = db()
@@ -175,7 +175,7 @@ def job_detail(job_id: str):
return render_template("tesm/maintenance_job.html", job=job)
@bp.get("/auftrag/<job_id>/ausgabe")
@bp.get("/job/<job_id>/output")
@permission_required("maintenance.view", "maintenance.execute", mode="any")
@fragment
def job_output(job_id: str):
@@ -276,14 +276,14 @@ def _start(kind: str) -> None:
flash(f"{started} Auftrag/Auftraege gestartet.", "success")
@bp.post("/aktualisieren")
@bp.post("/update")
@permission_required("maintenance.execute")
def start_update():
_start(service.JOB_KIND_UPDATE)
return redirect(url_for("maintenance.overview"))
@bp.post("/neustarten")
@bp.post("/restart")
@permission_required("maintenance.execute")
def start_reboot():
_start(service.JOB_KIND_REBOOT)
+12 -5
View File
@@ -18,7 +18,7 @@ from tesm_core.auth.service import client_ip
from tesm_core.extension import core, db, transaction
from tesm_core.licensing_client import LicenseError
bp = Blueprint("settings", __name__, url_prefix="/einstellungen")
bp = Blueprint("settings", __name__, url_prefix="/administration")
def _audit(action: str, target: str = "", detail: str = "", severity: str = "info") -> None:
@@ -79,9 +79,12 @@ def system():
"monitor_failures_before_restart",
"monitor_auto_restart",
"dashboard_public",
"terminal_enabled",
"terminal_switches_enabled",
"terminal_clients_enabled",
"terminal_idle_timeout",
"trash_retention_days",
"session_idle_minutes",
"session_absolute_hours",
"log_rotate_interval",
"log_rotate_keep",
],
@@ -92,6 +95,7 @@ def system():
timezones=_timezone_choices(),
nav_items=extension.nav.items,
nav_order=extension.settings.get(conn, "nav_order") or extension.nav.default_order(),
nav_child_order=extension.settings.get(conn, "nav_child_order") or {},
license_hint=_license_hint("monitor_interval"),
sysops_available=bool(sysops and sysops.available),
)
@@ -109,9 +113,12 @@ def system_save():
"monitor_failures_before_restart",
"monitor_auto_restart",
"dashboard_public",
"terminal_enabled",
"terminal_switches_enabled",
"terminal_clients_enabled",
"terminal_idle_timeout",
"trash_retention_days",
"session_idle_minutes",
"session_absolute_hours",
"log_rotate_interval",
"log_rotate_keep",
):
@@ -181,7 +188,7 @@ def set_hostname():
return redirect(url_for("settings.system"))
@bp.post("/system/zeitzone")
@bp.post("/system/timezone")
@permission_required("settings_system.execute")
def set_timezone():
extension = core()
@@ -210,7 +217,7 @@ def set_timezone():
return redirect(url_for("settings.system"))
@bp.post("/system/pruefung-jetzt")
@bp.post("/system/check-now")
@permission_required("settings_system.execute")
def run_check_now():
"""Startet einen Ueberwachungsdurchlauf sofort, im Hintergrund."""
+9 -9
View File
@@ -17,7 +17,7 @@ from tesm_core.extension import core, db, transaction
from ..services import inventory, ssh, switchcli
bp = Blueprint("switches", __name__, url_prefix="/switche")
bp = Blueprint("switches", __name__, url_prefix="/monitoring/switches")
def _audit(conn: Any, action: str, target: str, detail: str = "", severity: str = "info") -> None:
@@ -54,11 +54,11 @@ def overview():
"tesm/switches.html",
switches=inventory.list_switches(conn),
credentials=inventory.list_credentials(conn),
terminal_enabled=bool(core().settings.get(conn, "terminal_enabled")),
terminal_enabled=bool(core().settings.get(conn, "terminal_switches_enabled")),
)
@bp.post("/neu")
@bp.post("/new")
@permission_required("switches.create")
def create():
try:
@@ -98,7 +98,7 @@ def update(switch_id: int):
return redirect(request.referrer or url_for("switches.overview"))
@bp.post("/<int:switch_id>/loeschen")
@bp.post("/<int:switch_id>/delete")
@permission_required("switches.delete")
def delete(switch_id: int):
try:
@@ -142,7 +142,7 @@ def detail(switch_id: int):
devices=devices,
credentials=inventory.list_credentials(conn),
safe_commands=switchcli.SAFE_COMMANDS,
terminal_enabled=bool(core().settings.get(conn, "terminal_enabled")),
terminal_enabled=bool(core().settings.get(conn, "terminal_switches_enabled")),
)
@@ -151,7 +151,7 @@ def detail(switch_id: int):
# --------------------------------------------------------------------------- #
@bp.post("/<int:switch_id>/hostkey/pruefen")
@bp.post("/<int:switch_id>/host-key/probe")
@permission_required("switches.edit")
def probe_host_key(switch_id: int):
conn = db()
@@ -176,7 +176,7 @@ def probe_host_key(switch_id: int):
)
@bp.post("/<int:switch_id>/hostkey/freigeben")
@bp.post("/<int:switch_id>/host-key/trust")
@permission_required("switches.edit")
@reauth_required
def trust_host_key(switch_id: int):
@@ -215,7 +215,7 @@ def trust_host_key(switch_id: int):
return redirect(url_for("switches.detail", switch_id=switch_id))
@bp.post("/<int:switch_id>/hostkey/verwerfen")
@bp.post("/<int:switch_id>/host-key/forget")
@permission_required("switches.edit")
def forget_host_key(switch_id: int):
conn = db()
@@ -234,7 +234,7 @@ def forget_host_key(switch_id: int):
# --------------------------------------------------------------------------- #
@bp.post("/<int:switch_id>/kommando")
@bp.post("/<int:switch_id>/command")
@permission_required("switches.execute")
@reauth_required
def run_command(switch_id: int):
+20 -5
View File
@@ -24,7 +24,10 @@ Rechteausweitung, die dieses Projekt an anderer Stelle ausschliesst.
Gemeinsame Sicherheitsmerkmale:
* Frische Passwortbestaetigung, zusaetzlich zum Recht.
* Abschaltbar ueber die Einstellung ``terminal_enabled``.
* Abschaltbar -- getrennt fuer Switche (``terminal_switches_enabled``) und
Clients (``terminal_clients_enabled``). Das Freigeben von Host-Schluesseln
haengt an eigenen Routen und bleibt davon unberuehrt: es wird fuer den
PoE-Neustart gebraucht.
* Der Host-Schluessel muss vorher freigegeben sein -- die Konsole akzeptiert
keine unbekannten Schluessel (anders als der Vorgaenger, der sie hier
interaktiv uebernahm). Freigegeben wird auf der jeweiligen Detailseite.
@@ -128,6 +131,18 @@ def _load_target(conn: Any, kind: str, target_id: int) -> Target | None:
)
def _konsole_erlaubt(conn: Any, kind: str) -> bool:
"""Ist die Konsole fuer diese Art Ziel eingeschaltet?
Zwei Schalter, weil beides unabhaengig voneinander gebraucht wird: eine
Werkstatt will vielleicht auf Switche, aber nicht auf Clients.
"""
schluessel = (
"terminal_switches_enabled" if kind == KIND_SWITCH else "terminal_clients_enabled"
)
return bool(core().settings.get(conn, schluessel))
def _client_module_active() -> bool:
manager = core().license
return manager is None or manager.module_active("maintenance")
@@ -136,7 +151,7 @@ def _client_module_active() -> bool:
def _render_console(target: Target): # type: ignore[no-untyped-def]
extension = core()
conn = db()
if not extension.settings.get(conn, "terminal_enabled"):
if not _konsole_erlaubt(conn, target.kind):
abort(404)
if not target.credential_id:
abort(409, description="Fuer dieses Ziel sind keine Zugangsdaten hinterlegt.")
@@ -151,7 +166,7 @@ def _render_console(target: Target): # type: ignore[no-untyped-def]
)
@bp.get("/switche/<int:switch_id>/konsole")
@bp.get("/monitoring/switches/<int:switch_id>/console")
@permission_required("switches.execute")
@reauth_required
def switch_console(switch_id: int):
@@ -161,7 +176,7 @@ def switch_console(switch_id: int):
return _render_console(target)
@bp.get("/clients/<int:device_id>/konsole")
@bp.get("/monitoring/clients/<int:device_id>/console")
@permission_required("maintenance.execute")
@reauth_required
def device_console(device_id: int):
@@ -217,7 +232,7 @@ def _handle_socket(ws, kind: str, target_id: int) -> None: # type: ignore[no-un
if not reauth_is_fresh():
_send(ws, "error", "Die Passwortbestaetigung ist abgelaufen. Bitte Seite neu laden.")
return
if not extension.settings.get(conn, "terminal_enabled"):
if not _konsole_erlaubt(conn, kind):
_send(ws, "error", "Die Konsole ist in dieser Installation abgeschaltet.")
return
if kind == KIND_DEVICE and not _client_module_active():
+12 -12
View File
@@ -45,10 +45,10 @@ def _has_fileshare_mounts(user: Any) -> bool:
NAVIGATION = NavTree(
[
NavItem(key="index", label="Statusuebersicht", icon="grid", endpoint="dashboard.index"),
NavItem(key="index", label="Statusübersicht", icon="grid", endpoint="dashboard.index"),
NavItem(
key="monitoring",
label="Ueberwachung",
label="Überwachung",
icon="cpu",
children=(
NavItem(
@@ -74,21 +74,21 @@ NAVIGATION = NavTree(
),
NavItem(
key="hostkeys",
label="Host-Schluessel",
label="Host-Schlüssel",
icon="shield",
endpoint="hostkeys.overview",
permissions=("devices.view", "switches.view"),
),
NavItem(
key="maintenance",
label="Wartung",
icon="wrench",
endpoint="maintenance.overview",
permissions=("maintenance.view", "maintenance.execute"),
condition=_module("maintenance"),
),
),
),
NavItem(
key="maintenance",
label="Wartung",
icon="wrench",
endpoint="maintenance.overview",
permissions=("maintenance.view", "maintenance.execute"),
condition=_module("maintenance"),
),
NavItem(
key="dhcp",
label="DHCP-Server",
@@ -147,7 +147,7 @@ NAVIGATION = NavTree(
),
NavItem(
key="logs_dhcp",
label="Kea-DHCP",
label="DHCP",
icon="network",
endpoint="tesmlogs.dhcp",
permissions=("logs_dhcp.view",),
+22 -7
View File
@@ -31,7 +31,7 @@ DEVICES = Resource(
key="devices",
label="Clients",
actions=(A.VIEW, A.CREATE, A.EDIT, A.DELETE, A.EXECUTE),
hint="Ueberwachte PoE-Endgeraete",
hint="Überwachte PoE-Endgeräte",
action_hints={
A.EXECUTE: "PoE-Neustart eines Geraets manuell ausloesen. Der automatische "
"Neustart bei Ausfall ist davon unabhaengig und laeuft immer.",
@@ -65,7 +65,8 @@ CREDENTIALS = Resource(
MAINTENANCE = Resource(
key="maintenance",
label="Wartung",
# Nicht "Wartung": so heisst der Bereich. Die Zeile sagt, was sie erlaubt.
label="Aktualisierung und Neustart",
actions=(A.VIEW, A.EXECUTE),
hint="Paketaktualisierung und Neustart per SSH (lizenzpflichtiges Modul)",
action_hints={A.EXECUTE: "Aktualisierung oder Neustart auf ausgewaehlten Geraeten starten."},
@@ -75,7 +76,7 @@ DHCP = Resource(
key="dhcp",
label="DHCP-Server",
actions=(A.VIEW, A.EDIT, A.EXECUTE),
hint="Kea-DHCP: Subnetze, Optionen, Reservierungen (lizenzpflichtiges Modul)",
hint="DHCP: Subnetze, Optionen, Reservierungen (lizenzpflichtiges Modul)",
action_hints={
A.EDIT: "Konfiguration aendern und schreiben.",
A.EXECUTE: "Dienst installieren, starten oder stoppen.",
@@ -120,17 +121,30 @@ FILESHARE_PDF = Resource(
LOGS_DHCP = Resource(
key="logs_dhcp",
label="Kea-DHCP-Protokoll",
label="DHCP-Protokoll",
actions=(A.VIEW,),
)
MONITORING_AREA = Area(
key="monitoring",
label="Ueberwachung",
label="Überwachung",
icon="cpu",
hint="Geraete, Switche, Zugangsdaten und Wartung. Ohne diesen Zugang bleibt der "
hint="Geraete, Switche und Zugangsdaten. Ohne diesen Zugang bleibt der "
"gesamte Bereich verborgen.",
resources=(DEVICES, SWITCHES, CREDENTIALS, MAINTENANCE),
resources=(DEVICES, SWITCHES, CREDENTIALS),
)
#: Wartung ueberwacht nichts, sie greift ein -- und sie steht seit 2.5.0 als
#: eigener Punkt im Menue. Der Bereichsschluessel heisst ``servicing``, weil
#: ``maintenance`` schon die Ressource ist und Bereiche und Ressourcen sich
#: einen Namensraum teilen. Nach aussen heisst beides "Wartung".
MAINTENANCE_AREA = Area(
key="servicing",
label="Wartung",
icon="wrench",
hint="Paketpflege und Neustarts. Ohne diesen Zugang bleibt der Bereich "
"verborgen -- auch wenn einzelne Rechte darunter gesetzt sind.",
resources=(MAINTENANCE,),
)
NETWORK_AREA = Area(
@@ -150,6 +164,7 @@ FILES_AREA = Area(
PERMISSIONS = PermissionTree(
[
MONITORING_AREA,
MAINTENANCE_AREA,
NETWORK_AREA,
FILES_AREA,
observability_area(LOGS_DHCP),
+37
View File
@@ -273,9 +273,46 @@ INSERT OR IGNORE INTO group_permissions (group_id, permission)
"""
# Aus einem Schalter werden zwei. Wer die Konsole abgeschaltet hatte, soll sie
# nicht durch ein Update zurueckbekommen -- der alte Wert gilt deshalb fuer
# beide weiter. Fehlt er, greift die Vorgabe der Einstellung.
V5 = """
INSERT OR IGNORE INTO settings (key, value, updated_at, updated_by)
SELECT 'terminal_switches_enabled', value, datetime('now'), 'migration'
FROM settings WHERE key = 'terminal_enabled';
INSERT OR IGNORE INTO settings (key, value, updated_at, updated_by)
SELECT 'terminal_clients_enabled', value, datetime('now'), 'migration'
FROM settings WHERE key = 'terminal_enabled';
DELETE FROM settings WHERE key = 'terminal_enabled';
"""
# Wartung ist ein eigener Bereich geworden und hat damit einen eigenen
# Kill-Switch. Ohne diesen Schritt waere sie nach dem Update bei allen weg:
# das neue Bereichsrecht ist bei niemandem gesetzt, und ohne Bereichsrecht
# greift kein Recht darunter.
#
# Bewusst nicht "alle, die ein Wartungsrecht haben": wer den Bereich
# Ueberwachung nicht hatte, kam auch vorher nicht an die Wartung. Ein Update
# darf Zugang erhalten, aber keinen neuen schaffen.
V6 = """
INSERT OR IGNORE INTO group_permissions (group_id, permission)
SELECT DISTINCT group_id, 'servicing.view'
FROM group_permissions
WHERE permission IN ('maintenance.view', 'maintenance.execute')
AND group_id IN (
SELECT group_id FROM group_permissions WHERE permission = 'monitoring.view'
);
"""
TESM_MIGRATIONS: tuple[Migration, ...] = (
Migration(version=1, name="baseline", sql=V1),
Migration(version=2, name="seed-dhcp-options", fn=seed_dhcp_options),
Migration(version=3, name="restart-events", sql=V3),
Migration(version=4, name="fileshare-pdf-rechte", sql=V4),
Migration(version=5, name="terminal-getrennt", sql=V5),
Migration(version=6, name="wartung-eigener-bereich", sql=V6),
)
+87 -7
View File
@@ -33,7 +33,7 @@ import sqlite3
from dataclasses import dataclass
from datetime import datetime, timedelta, timezone
from pathlib import Path, PurePosixPath
from typing import Any, Iterable
from typing import Any, Iterable, Mapping
from tesm_core.db import Database
from tesm_core.extension import core
@@ -208,6 +208,50 @@ def list_mappings(conn: sqlite3.Connection) -> list[dict[str, Any]]:
)
#: Felder einer Zuordnung mit der Beschriftung, unter der sie in der
#: Oberflaeche stehen. Das Protokoll soll dieselben Woerter benutzen wie das
#: Formular -- sonst muss man beim Lesen uebersetzen.
MAPPING_FELDER: tuple[tuple[str, str], ...] = (
("label", "Anzeigename"),
("unc", "Pfad"),
("ad_group_name", "Gruppe"),
("ad_group_dn", "Gruppen-DN"),
)
def get_mapping(conn: sqlite3.Connection, mapping_id: int) -> dict[str, Any] | None:
return Database.one(conn, "SELECT * FROM fileshare_mappings WHERE id=?", (mapping_id,))
def describe_mapping(row: Mapping[str, Any] | None) -> str:
"""Eine Zuordnung in einer Zeile -- fuer das Protokoll.
Ohne sie stand beim Loeschen nur die Nummer der Zuordnung im Protokoll.
Die ist nach dem Loeschen nirgends mehr nachschlagbar; damit war der
Eintrag da, aber wertlos.
"""
if row is None:
return ""
teile = [str(row["unc"] or "")]
gruppe = str(row["ad_group_name"] or row["ad_group_dn"] or "")
if gruppe:
teile.append(f"Gruppe: {gruppe}")
return " -- ".join(teil for teil in teile if teil)
def mapping_changes(vorher: Mapping[str, Any] | None, nachher: Mapping[str, Any] | None) -> str:
"""Was sich geaendert hat, Feld fuer Feld: ``Anzeigename: alt -> neu``."""
if vorher is None or nachher is None:
return ""
geaendert = []
for feld, beschriftung in MAPPING_FELDER:
alt = str(vorher[feld] or "")
neu = str(nachher[feld] or "")
if alt != neu:
geaendert.append(f"{beschriftung}: {alt or '(leer)'} -> {neu or '(leer)'}")
return "; ".join(geaendert)
def add_mapping(
conn: sqlite3.Connection, *, ad_group_dn: str, ad_group_name: str, label: str, unc: str
) -> int:
@@ -389,7 +433,39 @@ def mount_for_login(
if not password:
return ["Kein Passwort fuer den Fileserver verfuegbar -- keine Einbindungen."]
# Was zuerst kommt: das Ende der Sitzung oder die eigene Obergrenze. Die
# Sitzung ist die eigentliche Klammer -- mit ihr endet die Einbindung; die
# Obergrenze sorgt dafuer, dass eine sehr lange Sitzung nicht beliebig
# lange auf fremden Zugangsdaten sitzt.
hours = int(extension.settings.get(conn, "fileshare_max_age_hours") or 12)
frist = _now() + timedelta(hours=hours)
# Die Sitzungszeile gibt es hier noch nicht: eingebunden wird waehrend der
# Anmeldung, geschrieben wird sie erst beim Speichern der Antwort. Die
# Dauer steht aber in derselben Einstellung, aus der die Sitzung sie
# gleich bekommt -- und falls die Zeile doch schon steht (erneutes
# Einbinden), gilt deren Ende.
zeile = (
Database.one(
conn, "SELECT absolute_expires_at FROM user_sessions WHERE id=?", (session_id,)
)
if session_id
else None
)
if zeile is not None and zeile["absolute_expires_at"]:
try:
sitzungsende = datetime.fromisoformat(str(zeile["absolute_expires_at"]))
if sitzungsende.tzinfo is None:
sitzungsende = sitzungsende.replace(tzinfo=timezone.utc)
frist = min(frist, sitzungsende)
except ValueError:
pass
else:
try:
dauer = int(extension.settings.get(conn, "session_absolute_hours") or 0)
except (TypeError, ValueError):
dauer = 0
if dauer > 0:
frist = min(frist, _now() + timedelta(hours=dauer))
root = Path(str(extension.settings.get(conn, "fileshare_mount_root") or "/mnt/tesm-shares"))
messages: list[str] = []
@@ -419,7 +495,7 @@ def mount_for_login(
str(share["unc"]),
str(target),
_iso(_now()),
_iso(_now() + timedelta(hours=hours)),
_iso(frist),
),
)
messages.append(f"{share['label']}: eingebunden")
@@ -474,7 +550,10 @@ def sweep_expired(database: Any) -> int:
released = 0
with database.session() as conn:
# Eine Einbindung lebt genau so lange wie die Sitzung, aus der sie
# entstanden ist. Vorher hing sie an einer eigenen Frist von zwoelf
# entstanden ist. Ohne Sitzungsangabe gilt allein die eigene Frist:
# "keine Sitzung eingetragen" ist etwas anderes als "Sitzung
# abgelaufen". Diese Verwechslung hat jede frische Einbindung binnen
# Minuten wieder geloest, weil die ID beim Anmelden noch nicht stand. Vorher hing sie an einer eigenen Frist von zwoelf
# Stunden: nach dem Abmelden -- oder nach der automatischen Abmeldung
# bei Leerlauf -- blieb die Freigabe mit den Zugangsdaten des Benutzers
# weiter eingebunden. Die eigene Frist bleibt als Obergrenze bestehen;
@@ -487,10 +566,11 @@ def sweep_expired(database: Any) -> int:
LEFT JOIN user_sessions s ON s.id = m.session_id
WHERE m.released_at IS NULL
AND (m.expires_at <= ?
OR s.id IS NULL
OR s.revoked_at IS NOT NULL
OR s.idle_expires_at <= ?
OR s.absolute_expires_at <= ?)
OR (COALESCE(m.session_id, '') <> ''
AND (s.id IS NULL
OR s.revoked_at IS NOT NULL
OR s.idle_expires_at <= ?
OR s.absolute_expires_at <= ?)))
""",
(_iso(_now()), _iso(_now()), _iso(_now())),
)
+14 -3
View File
@@ -100,12 +100,23 @@ TESM_SETTINGS: tuple[SettingSpec, ...] = (
),
# -- Terminal ----------------------------------------------------------- #
SettingSpec(
"terminal_enabled",
"terminal_switches_enabled",
True,
"bool",
"Browser-Terminal fuer Switche aktiv",
"Browser-Konsole fuer Switche zulassen",
hint="Auch wenn aktiv: erfordert das Recht 'Ausfuehren' auf Switche, eine frische "
"Passwortbestaetigung und wird vollstaendig protokolliert.",
"Passwortbestaetigung und wird vollstaendig protokolliert. Das Freigeben von "
"Host-Schluesseln bleibt davon unberuehrt -- es wird fuer den PoE-Neustart "
"gebraucht.",
section="monitoring",
),
SettingSpec(
"terminal_clients_enabled",
True,
"bool",
"Browser-Konsole fuer Clients zulassen",
hint="Braucht zusaetzlich das Modul Wartung und das Recht 'Ausfuehren' auf Wartung. "
"Das Freigeben von Host-Schluesseln bleibt davon unberuehrt.",
section="monitoring",
),
SettingSpec(
@@ -23,7 +23,7 @@
<div class="tabs">
{% for mount in mounts %}
<a class="tab {{ 'is-active' if mount.token == token else '' }}"
href="{{ url_for('fileshare.browse', freigabe=mount.token) }}">{{ mount.label }}</a>
href="{{ url_for('fileshare.browse', share=mount.token) }}">{{ mount.label }}</a>
{% endfor %}
</div>
@@ -33,9 +33,9 @@
<div class="card__header">
<div class="flex-1">
<nav class="breadcrumb">
<span><a href="{{ url_for('fileshare.browse', freigabe=token) }}">{{ current.label }}</a></span>
<span><a href="{{ url_for('fileshare.browse', share=token) }}">{{ current.label }}</a></span>
{% for crumb in listing.breadcrumb %}
<span><a href="{{ url_for('fileshare.browse', freigabe=token, pfad=crumb.relative) }}">{{ crumb.name }}</a></span>
<span><a href="{{ url_for('fileshare.browse', share=token, path=crumb.relative) }}">{{ crumb.name }}</a></span>
{% endfor %}
</nav>
<div class="card__sub mono fs-xs">{{ current.unc }}</div>
@@ -69,8 +69,8 @@
<tr>
{% if current_user.has('fileshare.delete') %}<td></td>{% endif %}
<td colspan="4">
<a class="link-icon" href="{{ url_for('fileshare.browse', freigabe=token,
pfad=(listing.breadcrumb[-2].relative if listing.breadcrumb | length > 1 else '')) }}">
<a class="link-icon" href="{{ url_for('fileshare.browse', share=token,
path=(listing.breadcrumb[-2].relative if listing.breadcrumb | length > 1 else '')) }}">
{{ icon('chevron-right', size=14) }} eine Ebene höher
</a>
</td>
@@ -79,11 +79,11 @@
{% for entry in listing.directories %}
<tr>
{% if current_user.has('fileshare.delete') %}
<td><label class="check"><input type="checkbox" name="pfade" value="{{ entry.relative }}"><span class="sr-only">auswählen</span></label></td>
<td><label class="check"><input type="checkbox" name="paths" value="{{ entry.relative }}"><span class="sr-only">auswählen</span></label></td>
{% endif %}
<td>
{{ icon('folder', size=15) }}
<a href="{{ url_for('fileshare.browse', freigabe=token, pfad=entry.relative) }}">{{ entry.name }}</a>
<a href="{{ url_for('fileshare.browse', share=token, path=entry.relative) }}">{{ entry.name }}</a>
</td>
<td class="numeric faint">&ndash;</td>
<td class="fs-sm">{{ entry.modified | dt }}</td>
@@ -93,7 +93,7 @@
{% for entry in listing.files %}
<tr>
{% if current_user.has('fileshare.delete') %}
<td><label class="check"><input type="checkbox" name="pfade" value="{{ entry.relative }}"><span class="sr-only">auswählen</span></label></td>
<td><label class="check"><input type="checkbox" name="paths" value="{{ entry.relative }}"><span class="sr-only">auswählen</span></label></td>
{% endif %}
{# Der Name ist die grösste Fläche der Zeile -- er soll auch
das Naheliegende tun. Was sich anzeigen lässt, öffnet die
@@ -102,17 +102,17 @@
{% if entry.previewable %}
<button class="link-icon file-name" type="button"
data-dialog-open="file-preview"
data-fill-Src="{{ url_for('fileshare.preview', token=token, pfad=entry.relative) }}"
data-fill-Src="{{ url_for('fileshare.preview', token=token, path=entry.relative) }}"
data-fill-Kind="{{ entry.preview_kind }}"
data-fill-Pfad="{{ entry.relative }}"
data-fill-Name="{{ entry.name }}"
{% if current_user.has('fileshare.export') %}data-fill-Download="{{ url_for('fileshare.download', token=token, pfad=entry.relative) }}"{% endif %}>
{% if current_user.has('fileshare.export') %}data-fill-Download="{{ url_for('fileshare.download', token=token, path=entry.relative) }}"{% endif %}>
{{ icon('file-text', size=15) }} {{ entry.name }}
</button>
{% else %}
{% if current_user.has('fileshare.export') %}
<a class="link-icon"
href="{{ url_for('fileshare.download', token=token, pfad=entry.relative) }}">
href="{{ url_for('fileshare.download', token=token, path=entry.relative) }}">
{{ icon('file-text', size=15) }} {{ entry.name }}
</a>
{% else %}
@@ -130,11 +130,11 @@
{% if entry.previewable %}
<button class="btn btn--sm btn--ghost" type="button"
data-dialog-open="file-preview"
data-fill-Src="{{ url_for('fileshare.preview', token=token, pfad=entry.relative) }}"
data-fill-Src="{{ url_for('fileshare.preview', token=token, path=entry.relative) }}"
data-fill-Kind="{{ entry.preview_kind }}"
data-fill-Pfad="{{ entry.relative }}"
data-fill-Name="{{ entry.name }}"
{% if current_user.has('fileshare.export') %}data-fill-Download="{{ url_for('fileshare.download', token=token, pfad=entry.relative) }}"{% endif %}
{% if current_user.has('fileshare.export') %}data-fill-Download="{{ url_for('fileshare.download', token=token, path=entry.relative) }}"{% endif %}
aria-label="Vorschau">{{ icon('eye', size=15) }}</button>
{% endif %}
{% if current_user.has('fileshare.edit') %}
@@ -147,7 +147,7 @@
{% endif %}
{% if current_user.has('fileshare.export') %}
<a class="btn btn--sm btn--ghost"
href="{{ url_for('fileshare.download', token=token, pfad=entry.relative) }}"
href="{{ url_for('fileshare.download', token=token, path=entry.relative) }}"
aria-label="Herunterladen">{{ icon('download', size=15) }}</a>
{% endif %}
</td>
@@ -182,7 +182,7 @@
<form method="post" enctype="multipart/form-data" data-no-guard
action="{{ url_for('fileshare.upload', token=token) }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<input type="hidden" name="pfad" value="{{ listing.relative }}">
<input type="hidden" name="path" value="{{ listing.relative }}">
<div class="card__body row">
<input class="input" type="file" name="files" multiple required style="flex:1">
<button class="btn btn--primary" type="submit" data-busy-label="Lädt ...">Hochladen</button>
@@ -199,7 +199,7 @@
{% call modal('folder-new', 'Ordner anlegen', listing.relative or 'Wurzelverzeichnis', 'narrow') %}
<form method="post" action="{{ url_for('fileshare.make_directory', token=token) }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<input type="hidden" name="pfad" value="{{ listing.relative }}">
<input type="hidden" name="path" value="{{ listing.relative }}">
<div class="modal__body">{{ field('name', 'Name', required=True) }}</div>
<div class="modal__footer">
<button class="btn" type="button" data-dialog-close>Abbrechen</button>
@@ -312,7 +312,7 @@
<form method="post" action="{{ url_for('fileshare.rename', token=token) }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<input type="hidden" name="parent" value="{{ listing.relative }}">
<input type="hidden" name="pfad" data-fill-target="Pfad" value="">
<input type="hidden" name="path" data-fill-target="Pfad" value="">
<div class="modal__body">
{{ field('name', 'Neuer Name (ohne Endung)', required=True,
attrs='data-fill-target="Name"') }}
@@ -1,6 +1,6 @@
{% extends "tesm_core/base.html" %}
{% from "tesm_core/macros.html" import alert %}
{% block page_title %}Kea-DHCP-Protokoll{% endblock %}
{% block page_title %}DHCP-Protokoll{% endblock %}
{% block page_sub %}{{ path }}{% endblock %}
{% block content %}
{% if error %}{{ alert(error, 'warning') }}{% endif %}
@@ -15,7 +15,7 @@ Der Vorgänger protokollierte Neustarts ausdrücklich nicht.', 'info') }}
<div class="card__sub">
{% for value, label in methods %}
<a class="btn btn--sm {{ 'btn--ghost' if method != value else '' }}"
href="{{ url_for('tesmlogs.restarts', methode=value) }}">{{ label }}</a>
href="{{ url_for('tesmlogs.restarts', method=value) }}">{{ label }}</a>
{% endfor %}
<a class="btn btn--sm {{ 'btn--ghost' if method else '' }}"
href="{{ url_for('tesmlogs.restarts') }}">Alle</a>
@@ -1,5 +1,5 @@
{% extends "tesm_core/base.html" %}
{% from "tesm_core/macros.html" import field, select_field, checkbox, alert, pill %}
{% from "tesm_core/macros.html" import field, select_field, checkbox, alert, pill, nav_order_card %}
{% block page_title %}Systemeinstellungen{% endblock %}
{% block page_sub %}Überwachung, Protokolle, Host, Navigation{% endblock %}
@@ -54,18 +54,23 @@
<section class="card">
<div class="card__header">
<div class="flex-1">
<div class="card__title">{{ icon('terminal', size=17) }} Switch-Konsole</div>
<div class="card__title">{{ icon('terminal', size=17) }} Terminal</div>
<div class="card__sub">
Auch bei aktiver Konsole gilt: eigenes Recht, frische Passwortbestätigung,
vollständige Mitschrift
vollständige Mitschrift. Abgeschaltet bleibt das Freigeben von
SSH-Host-Schlüsseln möglich – es wird für den PoE-Neustart gebraucht.
</div>
</div>
</div>
<form method="post" action="{{ url_for('settings.system_save') }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<div class="card__body stack">
{{ checkbox('terminal_enabled', 'Browser-Konsole für Switche zulassen',
checked=values.terminal_enabled) }}
{{ checkbox('terminal_switches_enabled', 'Browser-Konsole für Switche zulassen',
checked=values.terminal_switches_enabled,
hint_text=specs['terminal_switches_enabled'].hint) }}
{{ checkbox('terminal_clients_enabled', 'Browser-Konsole für Clients zulassen',
checked=values.terminal_clients_enabled,
hint_text=specs['terminal_clients_enabled'].hint) }}
{{ field('terminal_idle_timeout', 'Trennen bei Untätigkeit (Sekunden)',
value=values.terminal_idle_timeout, type='number') }}
</div>
@@ -73,6 +78,37 @@
</form>
</section>
{# Eigene Karte: die Abmeldung stand zwischen Protokollrotation und
Papierkorb -- drei Dinge ohne Zusammenhang. Wer die Sitzungsdauer sucht,
sucht sie nicht unter "Protokolle". #}
<section class="card">
<div class="card__header">
<div class="flex-1">
<div class="card__title">{{ icon('clock', size=17) }} Sitzungen</div>
<div class="card__sub">
Wie lange eine Anmeldung gilt. Beides bestimmt auch, wie lange eine
eingebundene Dateifreigabe bestehen bleibt -- sie endet mit der Sitzung.
</div>
</div>
</div>
<form method="post" action="{{ url_for('settings.system_save') }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<div class="card__body">
<div class="form-grid">
{{ field('session_idle_minutes', 'Automatische Abmeldung nach Leerlauf (Minuten)',
value=values.session_idle_minutes, type='number',
attrs='min="5" max="1440" step="1"',
hint_text=specs['session_idle_minutes'].hint) }}
{{ field('session_absolute_hours', 'Längstmögliche Sitzungsdauer (Stunden)',
value=values.session_absolute_hours, type='number',
attrs='min="1" max="168" step="1"',
hint_text=specs['session_absolute_hours'].hint) }}
</div>
</div>
<div class="card__footer"><button class="btn btn--primary" type="submit">Speichern</button></div>
</form>
</section>
<section class="card">
<div class="card__header">
<div class="flex-1">
@@ -87,9 +123,6 @@
specs['log_rotate_interval'].choices, selected=values.log_rotate_interval) }}
{{ field('log_rotate_keep', 'Aufbewahrte Rotationen', value=values.log_rotate_keep,
type='number') }}
{{ field('session_idle_minutes', 'Automatische Abmeldung (Minuten)',
value=values.session_idle_minutes, type='number',
hint_text=specs['session_idle_minutes'].hint) }}
{{ field('trash_retention_days', 'Papierkorb-Aufbewahrung (Tage)',
value=values.trash_retention_days, type='number',
hint_text=specs['trash_retention_days'].hint) }}
@@ -133,39 +166,8 @@
</section>
{% if current_user.is_admin %}
<section class="card">
<div class="card__header">
<div class="flex-1">
<div class="card__title">{{ icon('sliders', size=17) }} Navigationsreihenfolge</div>
<div class="card__sub">Gilt für alle Benutzer; jeder sieht weiter nur, was er darf</div>
</div>
</div>
<form method="post" action="{{ url_for('admin.nav_order') }}">
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
<div class="card__body">
<ol class="stack stack--tight">
{% for key in nav_order %}
{% set item = nav_items | selectattr('key', 'equalto', key) | list | first %}
{% if item %}
<li class="row row--tight">
<input class="input" type="number" name="position_{{ item.key }}" value="{{ loop.index }}"
min="1" style="width:70px" disabled>
<input type="hidden" name="order" value="{{ item.key }}">
<span class="flex-1">{{ icon(item.icon, size=15) }} {{ item.label }}</span>
</li>
{% endif %}
{% endfor %}
</ol>
<p class="fs-xs faint mt-3">
Die Reihenfolge folgt der Liste. Zum Umsortieren die Einträge in der gewünschten
Reihenfolge speichern (Drag-and-drop folgt in einer späteren Version).
</p>
</div>
<div class="card__footer">
<button class="btn btn--sm" type="submit">Reihenfolge speichern</button>
</div>
</form>
</section>
{{ nav_order_card(nav_items, nav_order, nav_child_order,
url_for('admin.nav_order'), csrf_field_name, csrf_token()) }}
{% endif %}
</div>
</div>
+1 -1
View File
@@ -620,7 +620,7 @@ for attempt in $(seq 1 20); do
# pruefen ging schon einmal schief -- auf einem gemeinsamen Port antwortete
# eine andere Instanz, und ein toter Dienst galt als gesund.
if systemctl is-active --quiet "$UNIT" &&
curl -fsS --max-time 3 "http://127.0.0.1:$PORT/gesundheit" >/dev/null 2>&1; then
curl -fsS --max-time 3 "http://127.0.0.1:$PORT/health" >/dev/null 2>&1; then
HEALTHY=1
info "Antwort nach ${attempt}x"
break
+1 -1
View File
@@ -446,7 +446,7 @@ Unverzichtbar:
**Die Anwendung antwortet nicht.**
```bash
journalctl -u tesm -n 200 --no-pager
curl -s http://127.0.0.1:5000/gesundheit
curl -s http://127.0.0.1:5000/health
```
Antwortet gunicorn, aber der Browser nicht, liegt es an nginx.
+1 -1
View File
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
[project]
name = "tesm-core"
version = "2.4.1"
version = "2.5.2"
description = "Gemeinsames Anwendungsgeruest (Auth, RBAC, Navigation, Design-System, Migrationen) fuer TESM und TESM-Lizenzserver"
requires-python = ">=3.11"
dependencies = [
@@ -13,10 +13,12 @@ import secrets
from datetime import datetime, timezone
from typing import Any, Sequence
from flask import Blueprint, Flask, g, render_template, request
from urllib.parse import urlencode
from flask import Blueprint, Flask, g, redirect, render_template, request
from werkzeug.exceptions import HTTPException
from . import audit, logging_setup, ui
from . import audit, legacy_urls, logging_setup, ui
from .config import CoreConfig
from .core_schema import CORE_MIGRATIONS
from .db import Database
@@ -62,6 +64,17 @@ CORE_SETTINGS: tuple[SettingSpec, ...] = (
minimum=1,
maximum=3650,
),
SettingSpec(
"session_absolute_hours",
12,
"int",
"Laengstmoegliche Sitzungsdauer (Stunden)",
hint="Danach ist Schluss, auch bei staendiger Arbeit -- eine Sitzung soll nicht "
"ewig leben. Die eingebundenen Dateifreigaben enden mit ihr.",
section="system",
minimum=1,
maximum=168,
),
SettingSpec(
"session_idle_minutes",
30,
@@ -135,7 +148,7 @@ def create_base_app(
#: Wortmarke, ohne Zeile darunter; die Marke selbst zeigen beide
#: Anwendungen.
auth_tagline: str = "",
app_version: str = "2.4.1",
app_version: str = "2.5.2",
built_in_trusted_keys: tuple[str, ...] = (),
enable_license: bool = True,
template_folder: str | None = None,
@@ -230,12 +243,21 @@ def create_base_app(
wert = 0
return wert if wert > 0 else config.security.session_idle_minutes
def _gesamtdauer(conn: Any) -> int:
"""Gesamtdauer aus den Einstellungen -- ueber dieselbe offene Verbindung."""
try:
wert = int(settings.get(conn, "session_absolute_hours") or 0)
except (TypeError, ValueError):
wert = 0
return wert if wert > 0 else config.security.session_absolute_hours
app.session_interface = SqliteSessionInterface(
database,
cookie_name=app.config["SESSION_COOKIE_NAME"],
idle_minutes=config.security.session_idle_minutes,
absolute_hours=config.security.session_absolute_hours,
idle_lookup=_leerlauf,
absolute_lookup=_gesamtdauer,
)
# -- Schema und Startzustand ------------------------------------------ #
@@ -336,6 +358,16 @@ def create_base_app(
# -- Fehlerseiten ------------------------------------------------------ #
@app.errorhandler(HTTPException)
def _http_error(error: HTTPException): # type: ignore[no-untyped-def]
if error.code == 404:
# Vor der Fehlerseite: war das eine Adresse aus der Zeit vor 2.5.0?
# Erst hier gefragt, damit die Tabelle nie eine bestehende Route
# verdeckt -- auf dem Lizenzserver ist /lizenz/<ticket> echt.
ziel = legacy_urls.neue_adresse(request.path)
if ziel is not None:
parameter = legacy_urls.neue_parameter(request.args.to_dict(flat=True))
if parameter:
ziel = ziel + "?" + urlencode(parameter)
return redirect(ziel)
if error.code == 413:
# "Request Entity Too Large" allein hilft niemandem weiter: die
# Zahl steht in einer Einstellung, und wer hochlaedt, soll sie
@@ -399,7 +431,7 @@ def create_base_app(
with app.app_context():
trash_views.register_core_providers()
app.add_url_rule("/gesundheit", "health", _health, methods=["GET"])
app.add_url_rule("/health", "health", _health, methods=["GET"])
return app
@@ -66,7 +66,7 @@ def login():
)
@bp.route("/login/zweiter-faktor", methods=["GET", "POST"])
@bp.route("/login/second-factor", methods=["GET", "POST"])
def second_factor():
conn = db()
user_row = service.pending_totp_user(conn)
@@ -116,7 +116,7 @@ def logout_get():
return redirect(url_for("auth.login"))
@bp.route("/bestaetigen", methods=["GET", "POST"])
@bp.route("/confirm", methods=["GET", "POST"])
@login_required
def reauth():
target = _safe_next(session.get("_after_reauth"))
@@ -257,6 +257,24 @@ def _verify_credentials(
return AuthOutcome("ok", user_row=user_row, group_dns=result.profile.group_dns)
def _ist_erstanmeldung(user_row: dict[str, Any]) -> bool:
"""Meldet sich dieses Konto zum ersten Mal ueberhaupt an?
Das Aenderungsprotokoll soll Aenderungen zeigen. Eine taegliche Anmeldung
ist keine -- sie erzeugte aber jedes Mal eine Zeile und schob damit echte
Eintraege aus dem Blickfeld. Interessant ist genau die erste: mit ihr
entsteht das Konto aus dem Verzeichnisdienst und betritt jemand die
Anwendung, der vorher nicht darin war.
Nicht betroffen: fehlgeschlagene Anmeldungen und Sperren. Die stehen
weiterhin **jedes Mal** im Protokoll -- dort liegt der sicherheitsrelevante
Teil, und Haeufung ist dort das Signal. Wer wann zuletzt angemeldet war,
steht ausserdem unveraendert am Konto und in der Sitzungsuebersicht.
"""
return not str(user_row.get("last_login_at") or "").strip()
def complete_login(
conn: sqlite3.Connection,
user_row: dict[str, Any],
@@ -275,21 +293,26 @@ def complete_login(
"""
from ..security import csrf
# Vor dem UPDATE lesen -- danach steht ueberall ein Zeitstempel.
erstanmeldung = _ist_erstanmeldung(user_row)
with core().database.transaction(conn):
session_store.rotate(conn, session, reason="login") # type: ignore[arg-type]
conn.execute(
"UPDATE users SET last_login_at=? WHERE id=?", (_iso(_now()), user_row["id"])
)
audit.log(
conn,
actor=str(user_row["username"]),
actor_id=int(user_row["id"]),
action="auth.login",
target=str(user_row["username"]),
detail=f"Quelle: {user_row.get('auth_source') or 'local'}",
ip=ip,
request_id=getattr(g, "request_id", ""),
)
if erstanmeldung:
audit.log(
conn,
actor=str(user_row["username"]),
actor_id=int(user_row["id"]),
action="auth.first_login",
target=str(user_row["username"]),
detail=f"Erste Anmeldung -- Quelle: {user_row.get('auth_source') or 'local'}",
ip=ip,
request_id=getattr(g, "request_id", ""),
severity="notice",
)
session.clear()
session[SESSION_USER_KEY] = int(user_row["id"])
@@ -0,0 +1,242 @@
"""Alte, deutsche Adressen auf die neuen englischen umlenken.
Mit 2.5.0 folgen die Adressen der Navigation und sind englisch:
``/monitoring/host-keys`` statt ``/hostschluessel``. Das ist eine gute
Aenderung und eine unangenehme zugleich -- Lesezeichen, offene Browsertabs und
ein Link in einer Mail zeigen weiter auf die alte Adresse. Ein offener Tab ist
dabei der unangenehmste Fall: die Statusuebersicht fragt alle 20 Sekunden ihre
Kacheln ab und bekam nach dem Update jedes Mal einen 404.
Deshalb diese Tabelle. Sie greift **nur, wenn sonst ein 404 herauskaeme** --
also nie vor einer bestehenden Route. Das ist keine Feinheit: auf dem
Lizenzserver ist ``/lizenz/<ticket>`` eine echte, weiterhin gueltige Adresse
(sie steht in verschickten Mails), waehrend dieselbe Wurzel in TESM zur
Lizenzseite fuehrte. Wer zuerst das Routing fragt, muss sich nicht zwischen
beidem entscheiden.
Die Tabelle ist bewusst vollstaendig und nicht nur auf Wurzeln gekuerzt: eine
Umleitung von ``/dateifreigaben/x/vorschau`` auf eine Uebersichtsseite waere
zwar kein 404 mehr, aber auch nicht das, was jemand angeklickt hat.
"""
from __future__ import annotations
from typing import Mapping
#: Alte Wurzel -> (neue Wurzel, Uebersetzung der Segmente darunter).
WURZELN: dict[str, tuple[str, Mapping[str, str]]] = {
"/dateifreigaben": (
"/fileshares",
{
"herunterladen": "download",
"vorschau": "preview",
"hochladen": "upload",
"formular": "form",
"ordner": "folder",
"umbenennen": "rename",
"loeschen": "delete",
"freigeben": "release",
"zuordnungen": "mappings",
},
),
"/hostschluessel": (
"/monitoring/host-keys",
{"pruefen": "probe", "freigeben": "trust", "verwerfen": "forget", "verwaist": "orphaned"},
),
"/zugangsdaten": (
"/monitoring/credentials",
{"neu": "new", "loeschen": "delete", "anzeigen": "reveal"},
),
"/switche": (
"/monitoring/switches",
{
"neu": "new",
"loeschen": "delete",
"hostkey": "host-key",
"pruefen": "probe",
"freigeben": "trust",
"verwerfen": "forget",
"kommando": "command",
"konsole": "console",
},
),
"/clients": (
"/monitoring/clients",
{
"neu": "new",
"aktiv": "active",
"loeschen": "delete",
"neustart": "restart",
"hostkey": "host-key",
"pruefen": "probe",
"freigeben": "trust",
"verwerfen": "forget",
"konsole": "console",
},
),
"/wartung": (
"/maintenance",
{
"paket-nachinstallieren": "install-package",
"auftrag": "job",
"ausgabe": "output",
"aktualisieren": "update",
"neustarten": "restart",
},
),
"/protokolle": (
"/logs",
{
"kea": "dhcp",
"neustarts": "restarts",
"laufend": "live",
"inhalt": "content",
"verlauf": "history",
"datei": "file",
"archiv": "archive",
"archiv-export": "archive-export",
"archiv-loeschen": "archive-delete",
"aenderungen": "audit",
},
),
"/verwaltung": (
"/administration",
{
"benutzer": "users",
"neu": "new",
"loeschen": "delete",
"sitzungen-beenden": "end-sessions",
"verzeichnis-suche": "directory-search",
"verzeichnis-uebernehmen": "directory-import",
"gruppen": "groups",
"vorlage-anwenden": "apply-preset",
"sitzungen": "sessions",
"beenden": "end",
},
),
"/einstellungen": (
"/administration",
{
"zeitzone": "timezone",
"pruefung-jetzt": "check-now",
"netzwerk": "network",
"bestaetigen": "confirm",
"webserver": "web",
"uebernehmen": "apply",
"zertifikat": "certificate",
"selbstsigniert": "self-signed",
"verzeichnisdienst": "directory",
"gruppensuche": "group-search",
"zuordnung": "mapping",
"loeschen": "delete",
"anbieter": "vendor",
"logo-entfernen": "remove-logo",
},
),
"/sicherung": (
"/administration/backup",
{"vorschau": "preview", "uebernehmen": "apply", "verwerfen": "discard"},
),
"/papierkorb": (
"/administration/trash",
{"wiederherstellen": "restore", "endgueltig-loeschen": "purge", "leeren": "empty"},
),
"/diagnose": (
"/administration/diagnostics",
{"aufraeumen": "cleanup", "schluessel-rotieren": "rotate-keys"},
),
"/eigene-lizenz": (
"/own-license",
{
"einspielen": "install",
"aktivieren": "activate",
"deaktivieren": "deactivate",
"offline-antwort": "offline-response",
"signaturschluessel": "signing-key",
},
),
"/lizenzen": (
"/licenses",
{
"aus-ticket": "from-ticket",
"datei": "file",
"neu-signieren": "resign",
"widerrufen": "revoke",
"loeschen": "delete",
"versenden": "send",
"sub-lizenzserver": "sub-servers",
},
),
"/lizenz": (
"/administration/license",
{
"einspielen": "install",
"aktivieren": "activate",
"deaktivieren": "deactivate",
"offline-antwort": "offline-response",
"serverzertifikat": "server-certificate",
"aussteller": "issuer",
"entfernen": "remove",
},
),
"/kunden": ("/customers", {"neu": "new", "loeschen": "delete"}),
"/konto": (
"/account",
{
"stammdaten": "profile",
"profilbild": "avatar",
"sicherheit": "security",
"passwort": "password",
"zwei-faktor": "two-factor",
"starten": "start",
"bestaetigen": "confirm",
"deaktivieren": "disable",
"codes-erneuern": "recovery-codes",
"sitzungen": "sessions",
"beenden": "end",
"alle-beenden": "end-all",
},
),
"/uebersicht": ("/overview", {"kacheln": "tiles"}),
"/gesundheit": ("/health", {}),
"/bestaetigen": ("/confirm", {}),
}
#: Abfrageparameter, die mit umbenannt wurden.
PARAMETER = {
"freigabe": "share",
"pfad": "path",
"aktion": "action",
"benutzer": "actor",
"stufe": "severity",
"seite": "page",
"methode": "method",
"kunde": "customer",
"freischalten": "unlocked",
}
#: Wurzeln, unter denen eine unbekannte Unterseite **nicht** umgelenkt wird.
#: ``/lizenz/<ticket>`` ist auf dem Lizenzserver eine echte Adresse; ein
#: abgelaufenes oder falsches Ticket gehoert dort auf die Fehlerseite und nicht
#: in die Verwaltung.
STRENG = {"/lizenz"}
def neue_adresse(pfad: str) -> str | None:
"""Uebersetzt eine alte Adresse -- oder ``None``, wenn es keine ist."""
for alt, (neu, segmente) in WURZELN.items():
if pfad != alt and not pfad.startswith(alt + "/"):
continue
rest = pfad[len(alt) :]
teile = rest.split("/")
if alt in STRENG:
erstes = next((teil for teil in teile if teil), "")
if erstes and erstes not in segmente:
return None
return neu + "/".join(segmente.get(teil, teil) for teil in teile)
return None
def neue_parameter(args: Mapping[str, str]) -> dict[str, str]:
return {PARAMETER.get(name, name): wert for name, wert in args.items()}
@@ -77,7 +77,7 @@ SETTINGS_NETWORK = Resource(
BACKUP = Resource(
key="backup",
label="Sicherung und Uebertragung",
label="Sicherung und Übertragung",
actions=(A.VIEW, A.EXECUTE, A.EXPORT, A.SECRETS),
hint="Verschluesselter Export und Import",
action_hints={
@@ -121,7 +121,7 @@ LOGS_HISTORY = Resource(
LOGS_AUDIT = Resource(
key="logs_audit",
label="Aenderungsprotokoll",
label="Änderungsprotokoll",
actions=(A.VIEW, A.EXPORT),
hint="Wer hat wann was geaendert",
)
@@ -163,6 +163,7 @@ class SqliteSessionInterface(SessionInterface):
idle_minutes: int,
absolute_hours: int,
idle_lookup: Any = None,
absolute_lookup: Any = None,
) -> None:
self.database = database
self.cookie_name = cookie_name
@@ -172,6 +173,16 @@ class SqliteSessionInterface(SessionInterface):
#: Zeit zur Laufzeit einstellbar, ohne den Dienst neu zu starten -- und
#: ohne eine zweite Datenbankverbindung, denn sie bekommt die offene.
self._idle_lookup = idle_lookup
self._absolute_lookup = absolute_lookup
def _absolute(self, conn: Any) -> int:
"""Gesamtdauer in Stunden -- einstellbar wie die Leerlaufgrenze."""
if self._absolute_lookup is None:
return self.absolute_hours
try:
return int(self._absolute_lookup(conn)) or self.absolute_hours
except Exception: # pragma: no cover - Einstellung unlesbar
return self.absolute_hours
def _idle(self, conn: Any) -> int:
if self._idle_lookup is None:
@@ -280,7 +291,10 @@ class SqliteSessionInterface(SessionInterface):
payload = json.dumps(dict(session), separators=(",", ":"), sort_keys=True)
with self.database.session() as conn, self.database.transaction(conn):
if session.new or not session.sid:
session.sid = secrets.token_urlsafe(SESSION_ID_BYTES)
# Eine vorhandene ID nicht wegwerfen: nach einem Wechsel beim
# Anmelden steht sie schon, und andere haben sie sich gemerkt.
if not session.sid:
session.sid = secrets.token_urlsafe(SESSION_ID_BYTES)
conn.execute(
"INSERT INTO user_sessions "
"(id, user_id, created_at, last_seen_at, idle_expires_at, "
@@ -292,7 +306,7 @@ class SqliteSessionInterface(SessionInterface):
_iso(now),
_iso(now),
_iso(now + timedelta(minutes=self._idle(conn))),
_iso(now + timedelta(hours=self.absolute_hours)),
_iso(now + timedelta(hours=self._absolute(conn))),
session.get("_ip", ""),
session.get("_ua", ""),
payload,
@@ -371,7 +385,12 @@ def rotate(conn: sqlite3.Connection, session: ServerSession, *, reason: str = "p
"UPDATE user_sessions SET revoked_at=?, revoked_reason=? WHERE id=?",
(_iso(_now()), reason, old_sid),
)
session.sid = ""
# Die neue ID entsteht **jetzt** und nicht erst beim Speichern der Antwort.
# Zwischen beidem laufen die Anmeldehaken, und einer davon bindet die
# Dateifreigaben ein und schreibt sich die Sitzung dazu. Mit einer leeren
# Sitzung hielt der Aufraeumer diese Einbindungen fuer verwaist und loeste
# sie binnen Minuten wieder.
session.sid = secrets.token_urlsafe(SESSION_ID_BYTES)
session.new = True
session.modified = True
return old_sid
@@ -1315,3 +1315,72 @@
.hide-sm { display: none !important; }
}
}
/* -- Sortierbare Liste (Navigationsreihenfolge) --------------------------- */
/* Symbol und Beschriftung stehen in einer Zeile -- so wie im Menue selbst.
Vorher brach die Beschriftung unter das Symbol, und die Liste sah aus wie
etwas anderes als das, was sie sortiert. */
.reorder {
list-style: none;
margin: 0;
padding: 0;
display: flex;
flex-direction: column;
gap: 4px;
}
.reorder__row {
display: flex;
align-items: center;
gap: 10px;
padding: 6px 10px;
border: 1px solid var(--border);
border-radius: var(--r-sm);
background: var(--surface-2);
cursor: grab;
}
.reorder__row > .flex-1 {
display: flex;
align-items: center;
gap: 8px;
white-space: nowrap;
overflow: hidden;
text-overflow: ellipsis;
}
.reorder__row.is-dragging {
opacity: 0.5;
}
.reorder__grip {
color: var(--text-muted);
display: inline-flex;
}
.reorder__pos {
min-width: 1.6em;
text-align: right;
font-variant-numeric: tabular-nums;
color: var(--text-muted);
font-size: var(--fs-xs);
}
.reorder__moves {
display: inline-flex;
gap: 2px;
}
.reorder__group {
list-style: none;
}
.reorder--child {
margin: 4px 0 4px 28px;
}
.reorder--child .reorder__row {
background: transparent;
border-style: dashed;
}
@@ -856,6 +856,81 @@ function initTileFilters() {
});
}
/* -- Reihenfolge aendern -------------------------------------------------- */
/**
* Eine Liste, deren Reihenfolge man aendern kann -- ohne Bibliothek.
*
* Die Reihenfolge steckt in der Reihenfolge der versteckten Felder: das
* Formular schickt sie als wiederholtes Feld, und der Server liest sie als
* Liste. Verschiebt man einen Eintrag, verschiebt sich das Feld mit ihm.
*
* Zwei Wege, weil es zwei Arten von Geraeten gibt: Ziehen mit der Maus und
* zwei Knoepfe je Zeile. Die Knoepfe sind nicht die Notloesung -- auf einem
* Tablet sind sie der einzige Weg, der zuverlaessig funktioniert, und mit der
* Tastatur ebenso.
*/
function initReorder() {
$$('[data-behavior="reorder"]').forEach((liste) => {
// Nur die eigenen Zeilen: Gruppen enthalten wiederum eine sortierbare
// Liste, und deren Zeilen gehoeren der inneren Liste, nicht dieser.
const zeilen = () => Array.from(liste.querySelectorAll(":scope > [data-reorder-item]"));
const nummerieren = () => {
zeilen().forEach((zeile, index) => {
const nummer = zeile.querySelector("[data-reorder-position-text]");
if (nummer) nummer.textContent = String(index + 1);
const hoch = zeile.querySelector('[data-reorder-move="up"]');
const runter = zeile.querySelector('[data-reorder-move="down"]');
if (hoch) hoch.disabled = index === 0;
if (runter) runter.disabled = index === zeilen().length - 1;
});
};
liste.addEventListener("click", (event) => {
const knopf = event.target.closest("[data-reorder-move]");
if (!knopf) return;
const zeile = knopf.closest("[data-reorder-item]");
if (!zeile || zeile.parentElement !== liste) return;
event.preventDefault();
if (knopf.dataset.reorderMove === "up") {
const davor = zeile.previousElementSibling;
if (davor) liste.insertBefore(zeile, davor);
} else {
const danach = zeile.nextElementSibling;
if (danach) liste.insertBefore(danach, zeile);
}
nummerieren();
zeile.querySelector(`[data-reorder-move="${knopf.dataset.reorderMove}"]`)?.focus();
});
let gezogen = null;
liste.addEventListener("dragstart", (event) => {
const zeile = event.target.closest("[data-reorder-item]");
if (!zeile || zeile.parentElement !== liste) return;
gezogen = zeile;
gezogen.classList.add("is-dragging");
if (event.dataTransfer) event.dataTransfer.effectAllowed = "move";
});
liste.addEventListener("dragend", () => {
if (gezogen) gezogen.classList.remove("is-dragging");
gezogen = null;
nummerieren();
});
liste.addEventListener("dragover", (event) => {
if (!gezogen) return;
event.preventDefault();
const ziel = event.target.closest("[data-reorder-item]");
if (!ziel || ziel === gezogen || ziel.parentElement !== liste) return;
const kasten = ziel.getBoundingClientRect();
const obereHaelfte = event.clientY < kasten.top + kasten.height / 2;
liste.insertBefore(gezogen, obereHaelfte ? ziel : ziel.nextElementSibling);
});
nummerieren();
});
}
/* -- Start ---------------------------------------------------------------- */
/**
@@ -893,6 +968,7 @@ function boot() {
initPalette();
initSubmitGuards();
initTileFilters();
initReorder();
initLogTails();
unsavedGuard.init();
initViewer();
@@ -651,7 +651,7 @@ export function initFilePreview(wurzel = document) {
abschliessen: modusFeld?.value === "fertig",
});
const daten = new FormData();
daten.append("pfad", aktuell.pfad);
daten.append("path", aktuell.pfad);
daten.append("ordner", ordnerFeld.value.trim());
daten.append("name", nameFeld.value.trim());
if (ersetzenFeld.checked) daten.append("ersetzen", "1");
@@ -24,7 +24,7 @@
<strong>nicht</strong> bei jedem Neustart auf die Vorlage zurückgesetzt &ndash;
Anpassungen bleiben erhalten.
{% if current_user.has('groups.edit') %}
<a class="btn btn--sm mt-2" href="{{ url_for('admin.group_detail', group_id=group.id, freischalten=1) }}">
<a class="btn btn--sm mt-2" href="{{ url_for('admin.group_detail', group_id=group.id, unlocked=1) }}">
{{ icon('unlock', size=14) }} Rechte freischalten
</a>
{% endif %}
@@ -26,19 +26,19 @@
{{ icon('search', size=15) }}
<input class="input" type="search" name="q" value="{{ filters.q }}" placeholder="Ziel, Detail, Aktion ...">
</span>
<select class="select" name="aktion" style="width:auto;max-width:240px">
<select class="select" name="action" style="width:auto;max-width:240px">
<option value="">alle Aktionen</option>
{% for action in actions %}
<option value="{{ action }}" {% if action == filters.aktion %}selected{% endif %}>{{ action }}</option>
<option value="{{ action }}" {% if action == filters.action %}selected{% endif %}>{{ action }}</option>
{% endfor %}
</select>
<select class="select" name="stufe" style="width:auto">
<select class="select" name="severity" style="width:auto">
<option value="">alle Stufen</option>
{% for level in ['info', 'notice', 'warning', 'critical'] %}
<option value="{{ level }}" {% if level == filters.stufe %}selected{% endif %}>{{ level }}</option>
<option value="{{ level }}" {% if level == filters.severity %}selected{% endif %}>{{ level }}</option>
{% endfor %}
</select>
<input class="input" type="text" name="benutzer" value="{{ filters.benutzer }}"
<input class="input" type="text" name="actor" value="{{ filters.actor }}"
placeholder="Benutzer" style="width:150px">
<button class="btn btn--sm" type="submit">Filtern</button>
<a class="btn btn--sm btn--ghost" href="{{ url_for('logs.audit_view') }}">Zurücksetzen</a>
@@ -88,10 +88,10 @@
<span class="fs-sm muted">Seite {{ page }}</span>
<span class="row row--tight">
{% if page > 1 %}
<a class="btn btn--sm" href="{{ url_for('logs.audit_view', seite=page-1, **filters) }}">Zurück</a>
<a class="btn btn--sm" href="{{ url_for('logs.audit_view', page=page-1, **filters) }}">Zurück</a>
{% endif %}
{% if rows | length == per_page %}
<a class="btn btn--sm" href="{{ url_for('logs.audit_view', seite=page+1, **filters) }}">Weiter</a>
<a class="btn btn--sm" href="{{ url_for('logs.audit_view', page=page+1, **filters) }}">Weiter</a>
{% endif %}
</span>
</div>
@@ -235,3 +235,69 @@
die Spalte gehört zu einer anderen Zeile desselben Bereichs.</span>
</div>
{%- endmacro %}
{# --------------------------------------------------------------------------
Navigationsreihenfolge. Die Reihenfolge der versteckten Felder ist die
Reihenfolge -- verschiebt sich eine Zeile, verschiebt sich das Feld mit ihr.
Ziehen mit der Maus oder die zwei Knoepfe je Zeile; auf einem Tablet sind
die Knoepfe der verlaessliche Weg.
-------------------------------------------------------------------------- #}
{% macro _reorder_row(item, field_name, label) -%}
<li class="reorder__row" data-reorder-item draggable="true">
<span class="reorder__grip" aria-hidden="true">{{ icon('menu', size=14) }}</span>
<span class="reorder__pos" data-reorder-position-text>1</span>
<input type="hidden" name="{{ field_name }}" value="{{ item.key }}">
<span class="flex-1">{{ icon(item.icon, size=15) }} {{ item.label }}</span>
<span class="reorder__moves">
<button class="btn btn--icon btn--sm" type="button" data-reorder-move="up"
aria-label="{{ label }} nach oben">{{ icon('chevron-up', size=14) }}</button>
<button class="btn btn--icon btn--sm" type="button" data-reorder-move="down"
aria-label="{{ label }} nach unten">{{ icon('chevron-down', size=14) }}</button>
</span>
</li>
{%- endmacro %}
{% macro nav_order_card(items, order, child_order, action, csrf_field, csrf_value,
sub='Gilt für alle Benutzer; jeder sieht weiter nur, was er darf') -%}
<section class="card">
<div class="card__header">
<div class="flex-1">
<div class="card__title">{{ icon('sliders', size=17) }} Navigationsreihenfolge</div>
<div class="card__sub">{{ sub }}</div>
</div>
</div>
<form method="post" action="{{ action }}">
<input type="hidden" name="{{ csrf_field }}" value="{{ csrf_value }}">
<div class="card__body">
<ol class="reorder" data-behavior="reorder">
{% for key in order %}
{% set item = items | selectattr('key', 'equalto', key) | list | first %}
{% if item %}
{{ _reorder_row(item, 'order', item.label) }}
{% if item.children %}
<li class="reorder__group">
<ol class="reorder reorder--child" data-behavior="reorder">
{% set kinder = child_order.get(item.key) or (item.children | map(attribute='key') | list) %}
{% for child_key in kinder %}
{% set child = item.children | selectattr('key', 'equalto', child_key) | list | first %}
{% if child %}
{{ _reorder_row(child, 'child_order_' ~ item.key, item.label ~ ' / ' ~ child.label) }}
{% endif %}
{% endfor %}
</ol>
</li>
{% endif %}
{% endif %}
{% endfor %}
</ol>
<p class="fs-xs faint mt-3">
Zeilen ziehen oder mit den Pfeilen verschieben, dann speichern. Untergeordnete
Punkte werden innerhalb ihrer Gruppe sortiert.
</p>
</div>
<div class="card__footer">
<button class="btn btn--sm" type="submit">Reihenfolge speichern</button>
</div>
</form>
</section>
{%- endmacro %}
+1
View File
@@ -38,6 +38,7 @@ ICONS: dict[str, str] = {
"menu": '<path d="M4 6h16M4 12h16M4 18h16"/>',
"chevron-right": '<path d="m9 6 6 6-6 6"/>',
"chevron-down": '<path d="m6 9 6 6 6-6"/>',
"chevron-up": '<path d="m6 15 6-6 6 6"/>',
"sun": '<circle cx="12" cy="12" r="4"/><path d="M12 2v2M12 20v2M2 12h2M20 12h2M5 5l1.5 1.5M17.5 17.5 19 19M19 5l-1.5 1.5M6.5 17.5 5 19"/>',
"moon": '<path d="M20 14.5A8.5 8.5 0 1 1 9.5 4a7 7 0 0 0 10.5 10.5z"/>',
"monitor": '<rect x="2" y="4" width="20" height="13" rx="2"/><path d="M8 21h8M12 17v4"/>',
@@ -31,7 +31,7 @@ from ..extension import core, db, transaction
from ..rbac import service as rbac
from ..security import passwords, sessions as session_store, totp
bp = Blueprint("account", __name__, url_prefix="/konto")
bp = Blueprint("account", __name__, url_prefix="/account")
ALLOWED_AVATAR_SUFFIXES = {".png", ".jpg", ".jpeg", ".webp", ".gif"}
MAX_AVATAR_BYTES = 2 * 1024 * 1024
@@ -54,6 +54,19 @@ def _avatar_dir() -> Path:
def _audit(conn, action: str, detail: str = "", severity: str = "info") -> None:
"""Protokolliert eine Aenderung am **eigenen** Konto.
Bewusst sparsam benutzt. Das Aenderungsprotokoll beantwortet die Frage
"wer hat woran etwas geaendert" -- und wer sein eigenes Passwort setzt,
ein Profilbild tauscht oder seine Anschrift korrigiert, aendert nichts,
was jemand anderen betrifft. Solche Zeilen fuellten das Protokoll und
schoben die Eintraege aus dem Blick, um die es geht.
Was hier trotzdem stehen bleibt: alles rund um den zweiten Faktor. Ob ein
Konto mit oder ohne zweiten Faktor geschuetzt ist, aendert die Staerke der
Anmeldung -- das ist die eine Selbstbedienung, nach der man nach einem
Vorfall sucht.
"""
audit.log(
conn,
actor=current_user.username,
@@ -80,7 +93,7 @@ def overview():
)
@bp.post("/stammdaten")
@bp.post("/profile")
@login_required
def update_profile():
if current_user.is_directory_account:
@@ -101,12 +114,11 @@ def update_profile():
current_user.id,
),
)
_audit(conn, "account.profile_updated")
flash("Stammdaten gespeichert.", "success")
return redirect(url_for("account.overview"))
@bp.post("/profilbild")
@bp.post("/avatar")
@login_required
def upload_avatar():
upload = request.files.get("avatar")
@@ -142,14 +154,13 @@ def upload_avatar():
"UPDATE users SET avatar_filename=?, updated_at=? WHERE id=?",
(target.name, datetime.now(timezone.utc).isoformat(timespec="seconds"), current_user.id),
)
_audit(conn, "account.avatar_updated")
if previous:
(_avatar_dir() / str(previous)).unlink(missing_ok=True)
flash("Profilbild aktualisiert.", "success")
return redirect(url_for("account.overview"))
@bp.get("/profilbild/<path:filename>")
@bp.get("/avatar/<path:filename>")
@login_required
def avatar(filename: str):
safe = secure_filename(filename)
@@ -163,7 +174,7 @@ def avatar(filename: str):
# --------------------------------------------------------------------------- #
@bp.get("/sicherheit")
@bp.get("/security")
@login_required
def security():
conn = db()
@@ -199,7 +210,7 @@ def security():
)
@bp.post("/passwort")
@bp.post("/password")
@login_required
def change_password():
conn = db()
@@ -229,21 +240,15 @@ def change_password():
revoked = session_store.revoke_all_for_user(
conn, current_user.id, except_sid=getattr(session, "sid", ""), reason="password-change"
)
_audit(
conn,
"account.password_changed",
f"{revoked} weitere Sitzungen beendet",
severity="notice",
)
except rbac.ValidationError as exc:
flash(str(exc), "danger")
return redirect(url_for("account.security"))
flash("Passwort geaendert. Andere Sitzungen wurden beendet.", "success")
flash(f"Passwort geaendert. {revoked} weitere Sitzung(en) wurden beendet.", "success")
return redirect(url_for("account.security"))
@bp.post("/zwei-faktor/starten")
@bp.post("/two-factor/start")
@login_required
@reauth_required
def totp_start():
@@ -252,7 +257,7 @@ def totp_start():
return redirect(url_for("account.security"))
@bp.post("/zwei-faktor/bestaetigen")
@bp.post("/two-factor/confirm")
@login_required
@reauth_required
def totp_confirm():
@@ -295,7 +300,7 @@ def totp_confirm():
return redirect(url_for("account.security"))
@bp.post("/zwei-faktor/deaktivieren")
@bp.post("/two-factor/disable")
@login_required
@reauth_required
def totp_disable():
@@ -317,7 +322,7 @@ def totp_disable():
return redirect(url_for("account.security"))
@bp.post("/zwei-faktor/codes-erneuern")
@bp.post("/two-factor/recovery-codes")
@login_required
@reauth_required
def recovery_codes():
@@ -341,7 +346,7 @@ def recovery_codes():
return redirect(url_for("account.security"))
@bp.post("/sitzungen/<sid>/beenden")
@bp.post("/sessions/<sid>/end")
@login_required
def revoke_session(sid: str):
conn = db()
@@ -350,18 +355,16 @@ def revoke_session(sid: str):
abort(404)
with transaction():
session_store.revoke(conn, sid, reason="self")
_audit(conn, "account.session_revoked", sid[:12])
flash("Sitzung beendet.", "success")
return redirect(url_for("account.security"))
@bp.post("/sitzungen/alle-beenden")
@bp.post("/sessions/end-all")
@login_required
def revoke_other_sessions():
with transaction() as conn:
count = session_store.revoke_all_for_user(
conn, current_user.id, except_sid=getattr(session, "sid", ""), reason="self"
)
_audit(conn, "account.sessions_revoked", f"{count} Sitzungen")
flash(f"{count} weitere Sitzung(en) beendet.", "success")
return redirect(url_for("account.security"))
+17 -17
View File
@@ -16,7 +16,7 @@ from ..rbac import service as rbac
from ..rbac.model import ACTION_META, Action
from ..security import sessions as session_store
bp = Blueprint("admin", __name__, url_prefix="/verwaltung")
bp = Blueprint("admin", __name__, url_prefix="/administration")
def _audit(conn: Any, action: str, target: str = "", detail: str = "", severity: str = "info") -> None:
@@ -47,7 +47,7 @@ def _int_list(name: str) -> list[int]:
# --------------------------------------------------------------------------- #
@bp.get("/benutzer")
@bp.get("/users")
@permission_required("users.view")
def users():
conn = db()
@@ -60,7 +60,7 @@ def users():
)
@bp.post("/benutzer/neu")
@bp.post("/users/new")
@permission_required("users.create")
def user_create():
conn = db()
@@ -94,7 +94,7 @@ def user_create():
return redirect(url_for("admin.users"))
@bp.post("/benutzer/<int:user_id>")
@bp.post("/users/<int:user_id>")
@permission_required("users.edit")
def user_update(user_id: int):
conn = db()
@@ -137,7 +137,7 @@ def user_update(user_id: int):
return redirect(url_for("admin.users"))
@bp.post("/benutzer/<int:user_id>/loeschen")
@bp.post("/users/<int:user_id>/delete")
@permission_required("users.delete")
def user_delete(user_id: int):
conn = db()
@@ -163,7 +163,7 @@ def user_delete(user_id: int):
return redirect(url_for("admin.users"))
@bp.post("/benutzer/<int:user_id>/sitzungen-beenden")
@bp.post("/users/<int:user_id>/end-sessions")
@permission_required("users.edit")
def user_revoke_sessions(user_id: int):
conn = db()
@@ -184,7 +184,7 @@ def user_revoke_sessions(user_id: int):
return redirect(url_for("admin.users"))
@bp.get("/benutzer/verzeichnis-suche")
@bp.get("/users/directory-search")
@permission_required("users.create")
def directory_search():
conn = db()
@@ -200,7 +200,7 @@ def directory_search():
return jsonify({"results": results})
@bp.post("/benutzer/verzeichnis-uebernehmen")
@bp.post("/users/directory-import")
@permission_required("users.create")
def directory_adopt():
"""Legt ein Verzeichniskonto vorab an, damit Gruppen vor dem ersten Login sitzen."""
@@ -238,7 +238,7 @@ def directory_adopt():
# --------------------------------------------------------------------------- #
@bp.get("/gruppen")
@bp.get("/groups")
@permission_required("groups.view")
def groups():
conn = db()
@@ -254,7 +254,7 @@ def groups():
)
@bp.get("/gruppen/<int:group_id>")
@bp.get("/groups/<int:group_id>")
@permission_required("groups.view")
def group_detail(group_id: int):
conn = db()
@@ -275,11 +275,11 @@ def group_detail(group_id: int):
(group_id,),
),
can_edit=current_user.has("groups.edit"),
unlocked=request.args.get("freischalten") == "1",
unlocked=request.args.get("unlocked") == "1",
)
@bp.post("/gruppen/neu")
@bp.post("/groups/new")
@permission_required("groups.create")
def group_create():
conn = db()
@@ -301,7 +301,7 @@ def group_create():
return redirect(url_for("admin.groups"))
@bp.post("/gruppen/<int:group_id>")
@bp.post("/groups/<int:group_id>")
@permission_required("groups.edit")
def group_update(group_id: int):
conn = db()
@@ -334,7 +334,7 @@ def group_update(group_id: int):
return redirect(url_for("admin.group_detail", group_id=group_id))
@bp.post("/gruppen/<int:group_id>/loeschen")
@bp.post("/groups/<int:group_id>/delete")
@permission_required("groups.delete")
def group_delete(group_id: int):
conn = db()
@@ -354,7 +354,7 @@ def group_delete(group_id: int):
return redirect(url_for("admin.groups"))
@bp.post("/gruppen/<int:group_id>/vorlage-anwenden")
@bp.post("/groups/<int:group_id>/apply-preset")
@admin_required
def group_apply_preset(group_id: int):
"""Setzt eine Gruppe auf ihre Vorlage zurueck -- ausdruecklich, nie automatisch."""
@@ -386,7 +386,7 @@ def group_apply_preset(group_id: int):
# --------------------------------------------------------------------------- #
@bp.get("/sitzungen")
@bp.get("/sessions")
@admin_required
def sessions():
conn = db()
@@ -399,7 +399,7 @@ def sessions():
return render_template("tesm_core/sessions.html", sessions=rows)
@bp.post("/sitzungen/<sid>/beenden")
@bp.post("/sessions/<sid>/end")
@admin_required
def session_revoke(sid: str):
with transaction() as conn:
@@ -24,7 +24,7 @@ from ..keystore import check_private_file
from ..security import ratelimit
from ..security import sessions as session_store
bp = Blueprint("diagnostics", __name__, url_prefix="/diagnose")
bp = Blueprint("diagnostics", __name__, url_prefix="/administration/diagnostics")
@bp.get("/")
@@ -88,7 +88,7 @@ def overview():
)
@bp.post("/aufraeumen")
@bp.post("/cleanup")
@admin_required
def housekeeping():
"""Raeumt abgelaufene Sitzungen, alte Ratenbegrenzungs-Ereignisse und Protokolle."""
@@ -116,7 +116,7 @@ def housekeeping():
return redirect(url_for("diagnostics.overview"))
@bp.post("/schluessel-rotieren")
@bp.post("/rotate-keys")
@admin_required
def rotate_keys():
"""Legt einen neuen Datenschluessel an und verschluesselt bestehende Werte neu.
@@ -29,7 +29,7 @@ from ..licensing_client import LicenseError
from ..rbac import service as rbac
from ..system import hostnet, webserver
bp = Blueprint("hostsettings", __name__, url_prefix="/einstellungen")
bp = Blueprint("hostsettings", __name__, url_prefix="/administration")
PENDING_NETWORK_KEY = "pending_network_revert"
@@ -64,7 +64,7 @@ def _license_hint(feature: str) -> str:
# --------------------------------------------------------------------------- #
@bp.get("/netzwerk")
@bp.get("/network")
@permission_required("settings_network.view")
def network():
extension = core()
@@ -80,7 +80,7 @@ def network():
)
@bp.post("/netzwerk")
@bp.post("/network")
@permission_required("settings_network.edit")
def network_apply():
extension = core()
@@ -147,7 +147,7 @@ def network_apply():
return redirect(url_for("hostsettings.network"))
@bp.post("/netzwerk/bestaetigen")
@bp.post("/network/confirm")
@permission_required("settings_network.edit")
def network_confirm():
if core().registry.pop(PENDING_NETWORK_KEY, None) is None:
@@ -221,7 +221,7 @@ def _web_config() -> webserver.WebConfig:
)
@bp.get("/webserver")
@bp.get("/web")
@permission_required("settings_web.view")
def web():
extension = core()
@@ -240,7 +240,7 @@ def web():
)
@bp.post("/webserver")
@bp.post("/web")
@permission_required("settings_web.edit")
def web_save():
extension = core()
@@ -302,7 +302,7 @@ def web_save():
return redirect(url_for("hostsettings.web"))
@bp.post("/webserver/uebernehmen")
@bp.post("/web/apply")
@permission_required("settings_web.execute")
def web_apply():
problem = _license_hint("nginx")
@@ -327,7 +327,7 @@ def web_apply():
return redirect(url_for("hostsettings.web"))
@bp.post("/webserver/zertifikat")
@bp.post("/web/certificate")
@permission_required("settings_web.execute")
def web_certificate():
problem = _license_hint("nginx")
@@ -364,7 +364,7 @@ def web_certificate():
return redirect(url_for("hostsettings.web"))
@bp.post("/webserver/selbstsigniert")
@bp.post("/web/self-signed")
@permission_required("settings_web.execute")
def web_self_signed():
"""Erzeugt ein selbstsigniertes Zertifikat -- fuer Netze ohne Domain.
@@ -414,7 +414,7 @@ def web_self_signed():
# --------------------------------------------------------------------------- #
@bp.get("/verzeichnisdienst")
@bp.get("/directory")
@permission_required("settings_directory.view")
def directory_settings():
extension = core()
@@ -435,7 +435,7 @@ def directory_settings():
)
@bp.post("/verzeichnisdienst")
@bp.post("/directory")
@permission_required("settings_directory.edit")
def directory_save():
problem = _license_hint("directory")
@@ -481,7 +481,7 @@ def directory_save():
return redirect(url_for("hostsettings.directory_settings"))
@bp.post("/verzeichnisdienst/test")
@bp.post("/directory/test")
@permission_required("settings_directory.execute")
def directory_test():
result = directory.test_connection(db())
@@ -489,7 +489,7 @@ def directory_test():
return redirect(url_for("hostsettings.directory_settings"))
@bp.get("/verzeichnisdienst/gruppensuche")
@bp.get("/directory/group-search")
@permission_required("settings_directory.edit", "fileshare.edit", mode="any")
def directory_group_search():
"""Sucht Gruppen im Verzeichnis -- fuer die Auswahlfelder.
@@ -504,7 +504,7 @@ def directory_group_search():
)
@bp.post("/verzeichnisdienst/zuordnung")
@bp.post("/directory/mapping")
@permission_required("settings_directory.edit")
def directory_mapping_add():
conn = db()
@@ -534,7 +534,7 @@ def directory_mapping_add():
return redirect(url_for("hostsettings.directory_settings"))
@bp.post("/verzeichnisdienst/zuordnung/<int:mapping_id>/loeschen")
@bp.post("/directory/mapping/<int:mapping_id>/delete")
@permission_required("settings_directory.edit")
def directory_mapping_delete(mapping_id: int):
with transaction() as conn:
+17 -17
View File
@@ -26,7 +26,7 @@ from ..auth.service import client_ip
from ..extension import core, db, transaction
from ..security.sessions import fragment
bp = Blueprint("logs", __name__, url_prefix="/protokolle")
bp = Blueprint("logs", __name__, url_prefix="/logs")
MAX_TAIL_LINES = 2000
@@ -38,7 +38,7 @@ def _live_log():
return log
@bp.get("/laufend")
@bp.get("/live")
@permission_required("logs_live.view")
def live():
lines = min(int(request.args.get("lines") or 400), MAX_TAIL_LINES)
@@ -52,7 +52,7 @@ def live():
)
@bp.get("/laufend/inhalt")
@bp.get("/live/content")
@permission_required("logs_live.view")
@fragment
def live_fragment():
@@ -63,7 +63,7 @@ def live_fragment():
)
@bp.get("/verlauf")
@bp.get("/history")
@permission_required("logs_history.view", "logs_history.export", mode="any")
def history():
extension = core()
@@ -82,7 +82,7 @@ def history():
)
@bp.get("/verlauf/datei/<path:name>")
@bp.get("/history/file/<path:name>")
@permission_required("logs_history.view")
def history_file(name: str):
extension = core()
@@ -101,7 +101,7 @@ def history_file(name: str):
)
@bp.get("/verlauf/archiv/<day>")
@bp.get("/history/archive/<day>")
@permission_required("logs_history.view")
def history_archive(day: str):
if len(day) != 10 or day.count("-") != 2:
@@ -112,7 +112,7 @@ def history_archive(day: str):
return render_template("tesm_core/logs_archive.html", day=day, rows=rows)
@bp.post("/verlauf/archiv-export")
@bp.post("/history/archive-export")
@permission_required("logs_history.export")
def history_export():
"""Packt die archivierten Audit-Tage in ein ZIP.
@@ -152,7 +152,7 @@ def history_export():
)
@bp.post("/verlauf/archiv-loeschen")
@bp.post("/history/archive-delete")
@permission_required("logs_history.delete")
def history_purge():
removed = 0
@@ -176,20 +176,20 @@ def history_purge():
return redirect(url_for("logs.history"))
@bp.get("/aenderungen")
@bp.get("/audit")
@permission_required("logs_audit.view", "logs_audit.export", mode="any")
def audit_view():
conn = db()
page = max(1, int(request.args.get("seite") or 1))
page = max(1, int(request.args.get("page") or 1))
per_page = 100
return render_template(
"tesm_core/logs_audit.html",
rows=audit.search(
conn,
query=(request.args.get("q") or "").strip(),
action=(request.args.get("aktion") or "").strip(),
actor=(request.args.get("benutzer") or "").strip(),
severity=(request.args.get("stufe") or "").strip(),
action=(request.args.get("action") or "").strip(),
actor=(request.args.get("actor") or "").strip(),
severity=(request.args.get("severity") or "").strip(),
limit=per_page,
offset=(page - 1) * per_page,
),
@@ -200,14 +200,14 @@ def audit_view():
per_page=per_page,
filters={
"q": request.args.get("q") or "",
"aktion": request.args.get("aktion") or "",
"benutzer": request.args.get("benutzer") or "",
"stufe": request.args.get("stufe") or "",
"action": request.args.get("action") or "",
"actor": request.args.get("actor") or "",
"severity": request.args.get("severity") or "",
},
)
@bp.get("/aenderungen/export")
@bp.get("/audit/export")
@permission_required("logs_audit.export")
def audit_export():
conn = db()
@@ -28,7 +28,7 @@ from ..db import Database
from ..extension import core, db, transaction
from ..rbac import service as rbac
bp = Blueprint("trash", __name__, url_prefix="/papierkorb")
bp = Blueprint("trash", __name__, url_prefix="/administration/trash")
@dataclass(frozen=True, slots=True)
@@ -191,7 +191,7 @@ def _provider_or_404(key: str) -> TrashProvider:
return provider
@bp.post("/<kind>/<ident>/wiederherstellen")
@bp.post("/<kind>/<ident>/restore")
@permission_required("trash.edit")
def restore(kind: str, ident: str):
extension = core()
@@ -222,7 +222,7 @@ def restore(kind: str, ident: str):
return redirect(url_for("trash.overview"))
@bp.post("/<kind>/<ident>/endgueltig-loeschen")
@bp.post("/<kind>/<ident>/purge")
@permission_required("trash.delete")
def purge(kind: str, ident: str):
extension = core()
@@ -252,7 +252,7 @@ def purge(kind: str, ident: str):
return redirect(url_for("trash.overview"))
@bp.post("/leeren")
@bp.post("/empty")
@permission_required("trash.delete")
def purge_all():
extension = core()
+1 -1
View File
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
[project]
name = "tesm-licensing"
version = "2.4.1"
version = "2.5.2"
description = "Ed25519-basiertes Lizenz- und Aktivierungsprotokoll fuer TESM und TESM-Lizenzserver"
requires-python = ">=3.11"
dependencies = ["cryptography>=42"]