Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1d8f92fd2d | ||
|
|
5324174f90 | ||
|
|
d69d177995 | ||
|
|
f481a91773 | ||
|
|
970f45cdf7 | ||
|
|
c9ceb871b6 | ||
|
|
37c508297f |
No files matched your search
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
|
||||
|
||||
[project]
|
||||
name = "tesm"
|
||||
version = "2.8.34"
|
||||
version = "2.8.41"
|
||||
description = "TESM -- Verwaltung und Ueberwachung von PoE-Endgeraeten und Aruba-Switchen"
|
||||
requires-python = ">=3.11"
|
||||
dependencies = [
|
||||
|
||||
@@ -11,6 +11,7 @@ einen Dienst starten.
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import base64
|
||||
from typing import Any
|
||||
|
||||
from flask import Blueprint, abort, flash, redirect, render_template, request, url_for
|
||||
@@ -104,6 +105,12 @@ def overview():
|
||||
preview=kea.config_to_text(config),
|
||||
warnings=warnings,
|
||||
lease_file=kea.LEASE_FILE,
|
||||
# Was ein Linux-Client braucht, damit die Optionen bei ihm ankommen --
|
||||
# je Stil einmal, damit die Seite umschalten kann, ohne nachzuladen.
|
||||
client_stile=kea.CLIENT_STILE,
|
||||
client_konfig={
|
||||
stil: kea.client_konfiguration(conn, stil) for stil, _, _ in kea.CLIENT_STILE
|
||||
},
|
||||
sysops_available=bool(sysops and sysops.available),
|
||||
)
|
||||
|
||||
@@ -607,6 +614,102 @@ def _write_and_redirect():
|
||||
return redirect(url_for("dhcp.overview"))
|
||||
|
||||
|
||||
@bp.post("/client-config/push")
|
||||
# Verteilt wird ueber dieselbe Maschinerie wie ein Massenbefehl: Zugangsdaten
|
||||
# aus dem Datensatz, ein Auftrag je Geraet, Ausgabe zum Mitlesen. Deshalb
|
||||
# haengt es auch an demselben Recht -- wer Befehle auf Clients ausfuehren darf,
|
||||
# darf auch diese Datei schreiben; es ist dieselbe Wirkung.
|
||||
@permission_required("servicing_command.execute")
|
||||
def push_client_config():
|
||||
"""Schreibt die Client-Konfiguration per SSH auf ausgewaehlte Clients.
|
||||
|
||||
Der Inhalt ist fuer alle gleich -- angefordert wird, was der Server sendet,
|
||||
und das haengt nicht am einzelnen Geraet. Die **Werte** kommen weiterhin
|
||||
vom Server; hier geht es nur darum, dass der Client danach fragt.
|
||||
"""
|
||||
from ..services import maintenance as wartung
|
||||
|
||||
extension = core()
|
||||
conn = db()
|
||||
stil = (request.form.get("stil") or "").strip()
|
||||
if stil not in dict((s[0], s) for s in kea.CLIENT_STILE):
|
||||
flash("Unbekannter Client-Stil.", "danger")
|
||||
return redirect(url_for("dhcp.overview"))
|
||||
|
||||
konfig = kea.client_konfiguration(conn, stil)
|
||||
if not konfig["optionen"]:
|
||||
flash(
|
||||
"Es gibt nichts zu verteilen: dieser Server sendet derzeit keine Option, "
|
||||
"die ein Client eigens anfordern müsste.",
|
||||
"info",
|
||||
)
|
||||
return redirect(url_for("dhcp.overview"))
|
||||
|
||||
device_ids = [int(v) for v in request.form.getlist("device_ids") if v.isdigit()]
|
||||
if not device_ids:
|
||||
flash("Es wurde kein Gerät ausgewählt.", "warning")
|
||||
return redirect(url_for("dhcp.overview"))
|
||||
|
||||
# Ueber base64 statt ueber ein Here-Dokument: der Inhalt enthaelt
|
||||
# Anfuehrungszeichen, Rauten und Zeilenumbrueche, und er geht durch SSH,
|
||||
# eine Shell und moeglicherweise sudo. Was kodiert reist, kommt an.
|
||||
inhalt = base64.b64encode(konfig["inhalt"].encode("utf-8")).decode("ascii")
|
||||
verzeichnis = str(konfig["pfad"]).rsplit("/", 1)[0]
|
||||
befehl = (
|
||||
f"{{sudo}} mkdir -p {verzeichnis} && "
|
||||
f"echo {inhalt} | base64 -d | {{sudo}} tee {konfig['pfad']} >/dev/null && "
|
||||
f"{{sudo}} sh -c '{konfig['nachher']}' || true"
|
||||
)
|
||||
|
||||
gestartet = 0
|
||||
for device_id in device_ids:
|
||||
device = inventory.get_device(conn, device_id)
|
||||
if device is None or not device["credential_id"]:
|
||||
continue
|
||||
try:
|
||||
username, password = inventory.credential_secret(
|
||||
conn, extension.keystore, int(device["credential_id"])
|
||||
)
|
||||
except inventory.ValidationError as exc:
|
||||
flash(f"{device['name']}: {exc}", "danger")
|
||||
continue
|
||||
with transaction():
|
||||
auftrag = wartung.create_job(
|
||||
conn,
|
||||
kind=wartung.JOB_KIND_COMMAND,
|
||||
subject=str(device["name"]),
|
||||
actor=current_user.username,
|
||||
message="Wartet auf Start",
|
||||
)
|
||||
wartung.start_background(
|
||||
wartung.run_command,
|
||||
database=extension.database,
|
||||
job_id=auftrag.id,
|
||||
device=dict(device),
|
||||
username=username,
|
||||
password=password,
|
||||
befehl=befehl,
|
||||
timeout=int(extension.settings.get(conn, "maintenance_command_timeout") or 900),
|
||||
)
|
||||
gestartet += 1
|
||||
|
||||
if gestartet:
|
||||
_audit(
|
||||
"dhcp.client_config_pushed",
|
||||
f"{gestartet} Client(s)",
|
||||
f"Stil {stil}, Datei {konfig['pfad']}",
|
||||
severity="notice",
|
||||
)
|
||||
flash(
|
||||
f"{gestartet} Auftrag/Aufträge gestartet. Der Verlauf und die Ausgabe stehen "
|
||||
"unter Wartung.",
|
||||
"success",
|
||||
)
|
||||
else:
|
||||
flash("Kein Gerät mit hinterlegten Zugangsdaten ausgewählt.", "warning")
|
||||
return redirect(url_for("dhcp.overview"))
|
||||
|
||||
|
||||
@bp.post("/write")
|
||||
@permission_required("dhcp_config.execute")
|
||||
def write_config():
|
||||
|
||||
@@ -19,7 +19,11 @@ from tesm_core.auth.models import (
|
||||
from tesm_core.auth.service import client_ip
|
||||
from tesm_core.db import Database
|
||||
from tesm_core.extension import core, db, transaction
|
||||
from tesm_core.licensing_client import LICENSED_FEATURES, LicenseError
|
||||
from tesm_core.licensing_client import (
|
||||
ABFRAGE_WARNSCHWELLE_TAGE,
|
||||
LICENSED_FEATURES,
|
||||
LicenseError,
|
||||
)
|
||||
|
||||
import tesm_licensing as lic
|
||||
|
||||
@@ -50,8 +54,29 @@ def overview():
|
||||
manager = extension.license
|
||||
state = manager.reload(conn) if manager else None
|
||||
pending = manager._pending(conn) if manager else {} # noqa: SLF001 - eigenes Paket
|
||||
# Der Befehl, den ein Agent auf dieser Maschine ausfuehrt. Zusammengesetzt
|
||||
# aus dem, was hier wirklich installiert ist -- der Shim traegt den Namen
|
||||
# der Instanz, und der Dienstbenutzer auch. Abgeschrieben aus der Doku
|
||||
# waere er auf einer benannten Instanz schlicht falsch.
|
||||
werkzeug = f"/usr/local/bin/{extension.config.site_key}-admin"
|
||||
# Der Dienstbenutzer traegt den Namen der **Anwendung**, nicht den der
|
||||
# Instanz: install.sh setzt SERVICE_USER="$APP". Auf "tesm-test" heisst er
|
||||
# also "tesm" -- und auf dem Lizenzserver "tesm-license". Aus dem
|
||||
# Instanznamen ableiten waere genau dort falsch.
|
||||
dienstbenutzer = extension.config.app_key
|
||||
rmm_befehl = f"sudo -u {dienstbenutzer} {werkzeug} license"
|
||||
return render_template(
|
||||
"tesm/license.html",
|
||||
rmm_befehl=rmm_befehl,
|
||||
rmm_befehl_tage=f"{rmm_befehl} --days",
|
||||
rmm_warnschwelle=ABFRAGE_WARNSCHWELLE_TAGE,
|
||||
rmm_powershell=(
|
||||
f'$j = (& {rmm_befehl} 2>$null) | ConvertFrom-Json' + chr(10)
|
||||
+ 'if (-not $j.valid) { exit 2 }' + chr(10)
|
||||
+ 'if ($j.lifetime) { exit 0 }' + chr(10)
|
||||
+ f'if ($j.days_left -le {ABFRAGE_WARNSCHWELLE_TAGE}) ' + '{ exit 1 }' + chr(10)
|
||||
+ 'exit 0'
|
||||
),
|
||||
state=state,
|
||||
pending=pending,
|
||||
server_certificate=extension.settings.get(conn, "license_server_ca") or "",
|
||||
|
||||
@@ -110,6 +110,36 @@ def cmd_create_admin(args: argparse.Namespace) -> int:
|
||||
return 0
|
||||
|
||||
|
||||
def cmd_license(args: argparse.Namespace) -> int:
|
||||
"""Die Lizenz als Auskunft fuer ein Ueberwachungswerkzeug.
|
||||
|
||||
Gedacht fuer einen RMM-Agenten, der auf dieser Maschine laeuft: kein Netz,
|
||||
kein Token, keine Anmeldung. Die Antwort steht auf **stdout**, alles andere
|
||||
(Protokollzeilen des Starts) auf stderr -- ein ``| ConvertFrom-Json`` soll
|
||||
nicht daran scheitern, dass eine Migration etwas erzaehlt hat.
|
||||
|
||||
Der Ausstiegscode traegt die Aussage: 0 heil, 1 laeuft bald ab, 2
|
||||
ungueltig. Das ist die Sprache, in der ein RMM Alarm schlaegt -- Text
|
||||
auszuwerten waere der Umweg.
|
||||
"""
|
||||
from tesm_core.licensing_client import abfrage_ausstiegscode, zustand_als_auskunft
|
||||
|
||||
app, extension = _app_and_core()
|
||||
if extension.license is None:
|
||||
print("{}")
|
||||
return 2
|
||||
with app.app_context(), extension.database.session() as conn:
|
||||
auskunft = zustand_als_auskunft(extension.license.reload(conn))
|
||||
if getattr(args, "days", False):
|
||||
# Eine Zahl, sonst nichts -- fuer Werkzeuge, die keinen JSON-Parser
|
||||
# mitbringen. Unbefristet hat keine Zahl und sagt das auch.
|
||||
tage = auskunft.get("days_left")
|
||||
print("unbefristet" if auskunft.get("lifetime") else ("" if tage is None else int(tage)))
|
||||
else:
|
||||
print(json.dumps(auskunft, ensure_ascii=False, sort_keys=True))
|
||||
return abfrage_ausstiegscode(auskunft)
|
||||
|
||||
|
||||
def cmd_status(args: argparse.Namespace) -> int:
|
||||
app, extension = _app_and_core()
|
||||
with app.app_context(), extension.database.session() as conn:
|
||||
@@ -552,6 +582,14 @@ def build_parser() -> argparse.ArgumentParser:
|
||||
status.add_argument("--json", action="store_true")
|
||||
status.set_defaults(func=cmd_status)
|
||||
|
||||
lizenz = sub.add_parser(
|
||||
"license", help="Lizenzzustand als JSON ausgeben (für Überwachungswerkzeuge)"
|
||||
)
|
||||
lizenz.add_argument(
|
||||
"--days", action="store_true", help="Nur die Restlaufzeit in Tagen ausgeben"
|
||||
)
|
||||
lizenz.set_defaults(func=cmd_license)
|
||||
|
||||
house = sub.add_parser("housekeeping", help="Sitzungen, Ratenereignisse, Protokolle aufräumen")
|
||||
house.set_defaults(func=cmd_housekeeping)
|
||||
|
||||
|
||||
@@ -653,9 +653,157 @@ def read_leases(sysops: SysOps, *, path: str = LEASE_FILE) -> list[Lease]:
|
||||
return sorted(latest.values(), key=lambda entry: tuple(int(p) for p in entry.address.split(".") if p.isdigit()))
|
||||
|
||||
|
||||
#: Optionen, die jeder DHCP-Client von sich aus erfragt. Sie in die
|
||||
#: Client-Konfiguration zu schreiben waere Ballast -- und wer Ballast liest,
|
||||
#: liest irgendwann gar nicht mehr.
|
||||
IMMER_ANGEFRAGT = frozenset({1, 3, 6, 12, 15, 28, 42, 51, 54, 58, 59, 119, 121})
|
||||
|
||||
#: Die Stile, in denen eine Client-Konfiguration ausgegeben wird.
|
||||
#:
|
||||
#: Drei, weil es auf den Zielsystemen drei gibt, und die Wahl nicht am
|
||||
#: Geschmack haengt, sondern daran, was die Distribution mitbringt:
|
||||
#:
|
||||
#: * **networkd** -- Ubuntu-Server 22.04 bis 26.04 (netplan erzeugt die
|
||||
#: .network-Dateien), auch auf Debian verbreitet. Angeforderte Fremdoptionen
|
||||
#: landen als ``OPTION_<code>`` in der Lease unter /run/systemd/netif/leases.
|
||||
#: * **dhcpcd** -- Debian 12/13, Raspberry Pi OS, ab Ubuntu 24.04 verfuegbar.
|
||||
#: * **dhclient** -- Debian 11 bis 13 und Ubuntu 22.04, dort wo isc-dhcp-client
|
||||
#: noch installiert ist.
|
||||
CLIENT_STILE: tuple[tuple[str, str, str], ...] = (
|
||||
("networkd", "systemd-networkd", "/etc/systemd/network/10-tesm.network.d/50-tesm.conf"),
|
||||
("dhcpcd", "dhcpcd", "/etc/dhcpcd.conf"),
|
||||
("dhclient", "dhclient (isc-dhcp-client)", "/etc/dhcp/dhclient.conf"),
|
||||
)
|
||||
|
||||
#: Wie ein Typ aus dem Optionskatalog in den jeweiligen Clients heisst.
|
||||
_DHCPCD_TYPEN = {
|
||||
"string": "string",
|
||||
"ipv4-address": "ipaddress",
|
||||
"uint8": "byte",
|
||||
"uint16": "uint16",
|
||||
"uint32": "uint32",
|
||||
"boolean": "byte",
|
||||
}
|
||||
_DHCLIENT_TYPEN = {
|
||||
"string": "text",
|
||||
"ipv4-address": "ip-address",
|
||||
"uint8": "unsigned integer 8",
|
||||
"uint16": "unsigned integer 16",
|
||||
"uint32": "unsigned integer 32",
|
||||
"boolean": "boolean",
|
||||
}
|
||||
|
||||
|
||||
def gesendete_optionen(conn: sqlite3.Connection) -> list[dict[str, Any]]:
|
||||
"""Die Optionen, die dieser Server tatsaechlich ausliefert.
|
||||
|
||||
Gemeint ist: wofuer irgendwo ein Wert gesetzt ist -- global oder an einem
|
||||
einzelnen Geraet. Was im Katalog steht, aber leer ist, wird nicht gesendet
|
||||
und muss vom Client auch nicht angefordert werden.
|
||||
"""
|
||||
return Database.all(
|
||||
conn,
|
||||
"""
|
||||
SELECT DISTINCT o.code, o.name, o.type, o.description, o.is_standard
|
||||
FROM dhcp_options o
|
||||
JOIN dhcp_option_values v ON v.option_id = o.id
|
||||
WHERE TRIM(COALESCE(v.value, '')) <> ''
|
||||
ORDER BY o.code
|
||||
""",
|
||||
)
|
||||
|
||||
|
||||
def client_konfiguration(conn: sqlite3.Connection, stil: str) -> dict[str, Any]:
|
||||
"""Was ein Linux-Client braucht, damit die Optionen bei ihm ankommen.
|
||||
|
||||
**Warum es das braucht.** Ein DHCP-Client bekommt nur, wonach er fragt.
|
||||
Standardoptionen (Gateway, DNS, Domain) fragt er von sich aus; alles
|
||||
darueber hinaus -- und dazu gehoert jede eigene Option -- muss er
|
||||
ausdruecklich anfordern. Ohne diese Zeilen sendet der Server brav und der
|
||||
Client wirft es weg, ohne dass irgendwo etwas danebengeht.
|
||||
|
||||
Rueckgabe: ``{"pfad", "inhalt", "nachher", "optionen"}`` -- Datei, Inhalt,
|
||||
der Befehl zum Uebernehmen und die Optionen, um die es geht.
|
||||
"""
|
||||
optionen = [
|
||||
eintrag
|
||||
for eintrag in gesendete_optionen(conn)
|
||||
if int(eintrag["code"]) not in IMMER_ANGEFRAGT
|
||||
]
|
||||
codes = [int(eintrag["code"]) for eintrag in optionen]
|
||||
pfad = dict((s[0], s[2]) for s in CLIENT_STILE).get(stil, "")
|
||||
|
||||
if stil == "networkd":
|
||||
zeilen = [
|
||||
"# Von TESM erzeugt. Fordert die Optionen an, die dieser Server sendet --",
|
||||
"# ohne diese Zeilen verwirft der Client sie stillschweigend.",
|
||||
"#",
|
||||
"# Der Dateiname muss zur .network-Datei der Schnittstelle passen:",
|
||||
"# netplan legt sie unter /run/systemd/network/10-netplan-<if>.network ab,",
|
||||
"# der Zusatz gehoert also nach",
|
||||
"# /etc/systemd/network/10-netplan-<if>.network.d/50-tesm.conf.",
|
||||
"#",
|
||||
"# Die Werte stehen danach in /run/systemd/netif/leases/<ifindex>",
|
||||
"# als OPTION_<code>=...",
|
||||
"[DHCPv4]",
|
||||
]
|
||||
zeilen.append("RequestOptions=" + " ".join(str(code) for code in codes))
|
||||
nachher = "networkctl reload && networkctl reconfigure <schnittstelle>"
|
||||
elif stil == "dhcpcd":
|
||||
zeilen = [
|
||||
"# Von TESM erzeugt -- an das Ende von /etc/dhcpcd.conf.",
|
||||
"# 'define' macht die Option bekannt, 'option' fordert sie an.",
|
||||
"# Danach steht der Wert in der Lease (/var/lib/dhcpcd/<if>.lease)",
|
||||
"# und laesst sich mit 'dhcpcd -U <if>' als Variable auslesen.",
|
||||
]
|
||||
for eintrag in optionen:
|
||||
typ = _DHCPCD_TYPEN.get(str(eintrag["type"]), "string")
|
||||
zeilen.append(f"define {eintrag['code']} {typ} {eintrag['name']}")
|
||||
for eintrag in optionen:
|
||||
zeilen.append(f"option {eintrag['name']}")
|
||||
nachher = "systemctl restart dhcpcd"
|
||||
else:
|
||||
zeilen = [
|
||||
"# Von TESM erzeugt -- an das Ende von /etc/dhcp/dhclient.conf.",
|
||||
"# Die Werte stehen danach in /var/lib/dhcp/dhclient.leases,",
|
||||
"# und in Hooks unter $new_<name>.",
|
||||
]
|
||||
for eintrag in optionen:
|
||||
typ = _DHCLIENT_TYPEN.get(str(eintrag["type"]), "text")
|
||||
zeilen.append(f"option {eintrag['name']} code {eintrag['code']} = {typ};")
|
||||
if optionen:
|
||||
zeilen.append(
|
||||
"also request " + ", ".join(str(eintrag["name"]) for eintrag in optionen) + ";"
|
||||
)
|
||||
nachher = "systemctl restart networking || dhclient -r && dhclient"
|
||||
|
||||
return {
|
||||
"pfad": pfad,
|
||||
"inhalt": chr(10).join(zeilen) + chr(10),
|
||||
"nachher": nachher,
|
||||
"optionen": optionen,
|
||||
}
|
||||
|
||||
|
||||
def service_state(sysops: SysOps) -> dict[str, str]:
|
||||
state = sysops.service_state(SERVICE_UNIT)
|
||||
import shutil
|
||||
import subprocess
|
||||
|
||||
state["binary"] = "vorhanden" if shutil.which("kea-dhcp4") else "fehlt"
|
||||
pfad = shutil.which("kea-dhcp4")
|
||||
state["binary"] = "vorhanden" if pfad else "fehlt"
|
||||
# Die Fassung gehoert auf die Seite: zwischen Kea 2.4 (Ubuntu 24.04) und
|
||||
# 3.0 (26.04) liegen Aenderungen, und wer eine Konfiguration beurteilt,
|
||||
# will nicht erst auf der Kommandozeile nachsehen muessen, wogegen.
|
||||
state["version"] = ""
|
||||
if pfad:
|
||||
try:
|
||||
fertig = subprocess.run(
|
||||
[pfad, "-V"], capture_output=True, text=True, timeout=5, check=False
|
||||
)
|
||||
# ``kea-dhcp4 -V`` antwortet mit "3.0.3 (3.0.3 (tarball))" -- auf
|
||||
# einer Kachel steht davon die Nummer, nicht die Herkunft.
|
||||
state["version"] = (fertig.stdout or "").strip().split()[0].strip()
|
||||
except (OSError, subprocess.SubprocessError, IndexError):
|
||||
state["version"] = ""
|
||||
return state
|
||||
@@ -39,6 +39,10 @@
|
||||
</div>
|
||||
</div>
|
||||
|
||||
{# Dienst und Grundeinstellungen sind beides Kleinkram, den man selten
|
||||
anfasst -- nebeneinander statt untereinander, damit die Seite mit dem
|
||||
anfaengt, worum es geht: den Subnetzen und Optionen. #}
|
||||
<div class="grid grid--2">
|
||||
{% if current_user.has('dhcp_service.execute') %}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
@@ -66,6 +70,31 @@
|
||||
</section>
|
||||
{% endif %}
|
||||
|
||||
{% if current_user.has('dhcp_subnets.write') %}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1"><div class="card__title">{{ icon('sliders', size=17) }} Globale Einstellungen</div></div>
|
||||
</div>
|
||||
<form method="post" action="{{ url_for('dhcp.save_settings') }}">
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<div class="card__body">
|
||||
<div class="form-grid">
|
||||
{{ field('dhcp_domain', 'Domainname', value=values.dhcp_domain) }}
|
||||
{{ field('dhcp_lease_default', 'Lease-Dauer (s)', value=values.dhcp_lease_default, type='number') }}
|
||||
{{ field('dhcp_lease_max', 'Maximale Lease-Dauer (s)', value=values.dhcp_lease_max, type='number') }}
|
||||
{{ field('dhcp_output_path', 'Zielpfad der Konfiguration', value=values.dhcp_output_path,
|
||||
extra_class='field--full') }}
|
||||
</div>
|
||||
</div>
|
||||
<div class="card__footer">
|
||||
<button class="btn btn--primary" type="submit">Speichern und schreiben</button>
|
||||
</div>
|
||||
</form>
|
||||
</section>
|
||||
{% endif %}
|
||||
|
||||
</div>
|
||||
|
||||
{# -- Subnetze ---------------------------------------------------------- #}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
@@ -134,45 +163,111 @@
|
||||
{% endif %}
|
||||
</section>
|
||||
|
||||
{# -- Globale Einstellungen --------------------------------------------- #}
|
||||
{% if current_user.has('dhcp_subnets.write') %}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1"><div class="card__title">{{ icon('sliders', size=17) }} Globale Einstellungen</div></div>
|
||||
</div>
|
||||
<form method="post" action="{{ url_for('dhcp.save_settings') }}">
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<div class="card__body">
|
||||
<div class="form-grid">
|
||||
{{ field('dhcp_domain', 'Domainname', value=values.dhcp_domain) }}
|
||||
{{ field('dhcp_lease_default', 'Lease-Dauer (s)', value=values.dhcp_lease_default, type='number') }}
|
||||
{{ field('dhcp_lease_max', 'Maximale Lease-Dauer (s)', value=values.dhcp_lease_max, type='number') }}
|
||||
{{ field('dhcp_output_path', 'Zielpfad der Konfiguration', value=values.dhcp_output_path,
|
||||
extra_class='field--full') }}
|
||||
</div>
|
||||
</div>
|
||||
<div class="card__footer">
|
||||
<button class="btn btn--primary" type="submit">Speichern und schreiben</button>
|
||||
</div>
|
||||
</form>
|
||||
</section>
|
||||
{% endif %}
|
||||
|
||||
{# -- Optionen ---------------------------------------------------------- #}
|
||||
|
||||
{# Zwei Makros, weil dieselbe Zeile zweimal vorkommt: einmal in der kurzen
|
||||
Liste dessen, was wirklich gesendet wird, und einmal im vollen Katalog. #}
|
||||
{% macro optionswert(option) %}
|
||||
{% if current_user.has('dhcp_options.write') %}
|
||||
<form method="post" action="{{ url_for('dhcp.set_option_value') }}"
|
||||
class="row row--tight" style="flex-wrap:nowrap" data-no-guard>
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<input type="hidden" name="option_id" value="{{ option.id }}">
|
||||
{# min-width:0 und flex:1 statt einer festen Mindestbreite: sonst passte
|
||||
das Feld nicht in die Spalte, die Zeile brach um, und der Haken stand
|
||||
allein darunter -- es sah aus wie ein Bedienfehler der Seite. #}
|
||||
<input class="input input--mono" type="text" name="value"
|
||||
value="{{ option.value or '' }}" style="min-width:0;flex:1"
|
||||
placeholder="leer = nicht senden">
|
||||
<button class="btn btn--sm" type="submit" title="Wert übernehmen">
|
||||
{{ icon('check', size=14) }}
|
||||
</button>
|
||||
</form>
|
||||
{% else %}
|
||||
<span class="mono fs-sm">{{ option.value or '–' | safe }}</span>
|
||||
{% endif %}
|
||||
{% endmacro %}
|
||||
|
||||
{% macro optionsloeschen(option) %}
|
||||
{% if current_user.has('dhcp_options.write') and not option.is_standard %}
|
||||
<form method="post" action="{{ url_for('dhcp.delete_custom_option', option_id=option.id) }}"
|
||||
data-no-guard>
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<button class="btn btn--sm btn--ghost danger-text" type="submit"
|
||||
data-confirm="Eigene Option {{ option.name }} löschen?"
|
||||
data-confirm-title="Option löschen" data-confirm-ok="Löschen">
|
||||
{{ icon('trash', size=14) }}
|
||||
</button>
|
||||
</form>
|
||||
{% endif %}
|
||||
{% endmacro %}
|
||||
|
||||
{% set gesetzte = options | selectattr('value') | list %}
|
||||
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('puzzle', size=17) }} DHCP-Optionen</div>
|
||||
<div class="card__title">{{ icon('puzzle', size=17) }} Gesendete Optionen</div>
|
||||
<div class="card__sub">
|
||||
{{ options | length }} Optionen · Standardoptionen sind nicht löschbar, ihr Wert
|
||||
lässt sich leeren
|
||||
{% if gesetzte %}
|
||||
<strong>{{ gesetzte | length }}</strong> von {{ options | length }} Optionen tragen
|
||||
einen Wert. Was leer ist, wird nicht gesendet.
|
||||
{% else %}
|
||||
Derzeit trägt keine Option einen Wert – es wird also nichts über die
|
||||
Grundangaben hinaus gesendet.
|
||||
{% endif %}
|
||||
</div>
|
||||
</div>
|
||||
{{ search_box('options-table', 'Option suchen ...') }}
|
||||
</div>
|
||||
<div class="table-wrap" style="max-height:420px;overflow:auto">
|
||||
|
||||
{% if gesetzte %}
|
||||
<div class="table-wrap">
|
||||
<table class="table table--compact">
|
||||
<thead><tr>
|
||||
<th class="numeric">Code</th><th>Name</th><th>Typ</th>
|
||||
<th style="width:42%">Wert</th><th class="actions"></th>
|
||||
</tr></thead>
|
||||
<tbody>
|
||||
{% for option in gesetzte %}
|
||||
<tr>
|
||||
<td class="numeric fs-sm">{{ option.code }}</td>
|
||||
<td class="fs-sm">
|
||||
<div class="mono">{{ option.name }}</div>
|
||||
<div class="fs-xs faint">{{ option.description }}</div>
|
||||
</td>
|
||||
<td class="fs-xs mono">{{ option.type }}</td>
|
||||
<td>{{ optionswert(option) }}</td>
|
||||
<td class="actions">{{ optionsloeschen(option) }}</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
{% else %}
|
||||
{{ empty_state('Nichts gesetzt', 'Tragen Sie unten im Katalog einen Wert ein.', 'puzzle') }}
|
||||
{% endif %}
|
||||
</section>
|
||||
|
||||
{# Der Katalog hat 57 Zeilen. Er stand vorher ganz oben, in einem eigenen
|
||||
Rollbereich innerhalb der scrollenden Seite -- und das Gesuchte ging darin
|
||||
unter. Jetzt liegt er hinter einem Klick, mit eigener Suche. #}
|
||||
<details class="card" data-persist="dhcp-katalog">
|
||||
<summary class="card__header" style="cursor:pointer">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('list', size=17) }} Optionskatalog</div>
|
||||
<div class="card__sub">
|
||||
Alle {{ options | length }} bekannten Optionen. Standardoptionen sind nicht löschbar,
|
||||
ihr Wert lässt sich leeren.
|
||||
</div>
|
||||
</div>
|
||||
</summary>
|
||||
<div class="card__body pt-0">{{ search_box('options-table', 'Option suchen ...') }}</div>
|
||||
<div class="table-wrap">
|
||||
<table class="table table--compact" id="options-table">
|
||||
<thead><tr><th class="numeric">Code</th><th>Name</th><th>Typ</th><th>Wert</th><th class="actions"></th></tr></thead>
|
||||
<thead><tr>
|
||||
<th class="numeric">Code</th><th>Name</th><th>Typ</th>
|
||||
<th style="width:42%">Wert</th><th class="actions"></th>
|
||||
</tr></thead>
|
||||
<tbody>
|
||||
{% for option in options %}
|
||||
<tr data-filter-text="{{ option.code }} {{ option.name }} {{ option.description }}">
|
||||
@@ -182,43 +277,30 @@
|
||||
<div class="fs-xs faint">{{ option.description }}</div>
|
||||
</td>
|
||||
<td class="fs-xs mono">{{ option.type }}</td>
|
||||
<td>
|
||||
{% if current_user.has('dhcp_options.write') %}
|
||||
<form method="post" action="{{ url_for('dhcp.set_option_value') }}" class="row row--tight"
|
||||
data-no-guard>
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<input type="hidden" name="option_id" value="{{ option.id }}">
|
||||
<input class="input input--mono" type="text" name="value" value="{{ option.value or '' }}"
|
||||
style="min-width:180px" placeholder="leer = nicht senden">
|
||||
<button class="btn btn--sm" type="submit">{{ icon('check', size=14) }}</button>
|
||||
</form>
|
||||
{% else %}
|
||||
<span class="mono fs-sm">{{ option.value or '–' | safe }}</span>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td class="actions">
|
||||
{% if current_user.has('dhcp_options.write') and not option.is_standard %}
|
||||
<form method="post" action="{{ url_for('dhcp.delete_custom_option', option_id=option.id) }}"
|
||||
data-no-guard>
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<button class="btn btn--sm btn--ghost danger-text" type="submit"
|
||||
data-confirm="Eigene Option {{ option.name }} löschen?"
|
||||
data-confirm-title="Option löschen" data-confirm-ok="Löschen">
|
||||
{{ icon('trash', size=14) }}</button>
|
||||
</form>
|
||||
{% endif %}
|
||||
</td>
|
||||
<td>{{ optionswert(option) }}</td>
|
||||
<td class="actions">{{ optionsloeschen(option) }}</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
{% if current_user.has('dhcp_options.write') %}
|
||||
</details>
|
||||
|
||||
{% if current_user.has('dhcp_options.write') %}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('plus', size=17) }} Eigene Option anlegen</div>
|
||||
<div class="card__sub">
|
||||
Für alles jenseits des Katalogs – etwa eine URL, die der Client beim Start öffnet.
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<form method="post" action="{{ url_for('dhcp.add_custom_option') }}">
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<div class="card__body">
|
||||
<div class="form-grid">
|
||||
{{ field('code', 'Code', type='number', required=True) }}
|
||||
{{ field('code', 'Code', type='number', required=True, placeholder='225') }}
|
||||
{{ field('name', 'Name', required=True, placeholder='meine-option') }}
|
||||
<label class="field">
|
||||
<span class="field__label">Typ</span>
|
||||
@@ -231,13 +313,15 @@
|
||||
</div>
|
||||
<div class="card__footer"><button class="btn" type="submit">Eigene Option anlegen</button></div>
|
||||
</form>
|
||||
</section>
|
||||
|
||||
{# Der Wert einer Option gilt sonst für alle. Genau dafür gibt es
|
||||
``dhcp_option_values.device_id``: ein eigener Wert je Gerät, der in
|
||||
dessen Reservierung geschrieben wird -- etwa eine Terminal-URL, die je
|
||||
Gerät anders lautet. Auswertbar war das von Anfang an, eingeben liess
|
||||
es sich nicht. #}
|
||||
<div class="card__header" style="border-top:1px solid var(--border-subtle)">
|
||||
{# Der Wert einer Option gilt sonst für alle. Genau dafür gibt es
|
||||
``dhcp_option_values.device_id``: ein eigener Wert je Gerät, der in dessen
|
||||
Reservierung geschrieben wird -- etwa eine Terminal-URL, die je Gerät
|
||||
anders lautet. Auswertbar war das von Anfang an, eingeben liess es sich
|
||||
nicht. #}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('sliders', size=17) }} Option nur für ein Gerät</div>
|
||||
<div class="card__sub">
|
||||
@@ -276,6 +360,93 @@
|
||||
<button class="btn" type="submit">Für dieses Gerät speichern</button>
|
||||
</div>
|
||||
</form>
|
||||
</section>
|
||||
{% endif %}
|
||||
|
||||
{# -- Was der Client dafür braucht -------------------------------------- #}
|
||||
{#
|
||||
Ein DHCP-Client bekommt nur, wonach er fragt. Gateway, DNS und Domain
|
||||
fragt er von sich aus; alles darüber hinaus -- und dazu gehört jede eigene
|
||||
Option -- muss er ausdrücklich anfordern. Ohne diese Zeilen sendet der
|
||||
Server brav, und der Client wirft es weg, ohne dass irgendwo etwas
|
||||
danebengeht. Genau deshalb steht das hier und nicht in einer Anleitung.
|
||||
#}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('terminal', size=17) }} Konfiguration für Linux-Clients</div>
|
||||
<div class="card__sub">
|
||||
Ein Client erhält nur die Optionen, die er anfordert. Diese Zeilen sorgen dafür –
|
||||
erzeugt aus dem, was dieser Server tatsächlich sendet.
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
{% set beispiel = client_konfig.get('networkd') %}
|
||||
{% if not beispiel or not beispiel.optionen %}
|
||||
<div class="card__body">
|
||||
{{ alert('Dieser Server sendet derzeit keine Option, die ein Client eigens anfordern
|
||||
müsste. Sobald eine eigene Option einen Wert trägt, steht hier die passende
|
||||
Konfiguration.', 'info') }}
|
||||
</div>
|
||||
{% else %}
|
||||
<div class="card__body pt-0">
|
||||
<p class="fs-sm faint">
|
||||
Betrifft
|
||||
{% for eintrag in beispiel.optionen %}
|
||||
<code>{{ eintrag.code }} {{ eintrag.name }}</code>{% if not loop.last %}, {% endif %}
|
||||
{% endfor %}.
|
||||
Welcher Abschnitt gilt, entscheidet die Distribution des Clients.
|
||||
</p>
|
||||
</div>
|
||||
|
||||
{% for stil, bezeichnung, pfad in client_stile %}
|
||||
{% set konfig = client_konfig.get(stil) %}
|
||||
<details class="card__body pt-0">
|
||||
<summary class="row row--tight" style="cursor:pointer">
|
||||
<strong class="fs-sm">{{ bezeichnung }}</strong>
|
||||
<span class="fs-xs faint mono">{{ pfad }}</span>
|
||||
</summary>
|
||||
<div class="stack stack--tight mt-2">
|
||||
<div class="row row--tight">
|
||||
<span class="fs-xs faint flex-1">Inhalt der Datei</span>
|
||||
<button class="btn btn--sm btn--ghost" type="button" data-copy="#konfig-{{ stil }}"
|
||||
data-copy-message="Konfiguration kopiert.">
|
||||
{{ icon('copy', size=14) }} Kopieren
|
||||
</button>
|
||||
</div>
|
||||
<pre class="code-block code-block--wrap" id="konfig-{{ stil }}">{{ konfig.inhalt }}</pre>
|
||||
<div class="fs-xs faint">Danach: <code>{{ konfig.nachher }}</code></div>
|
||||
|
||||
{% if current_user.has('servicing_command.execute') %}
|
||||
<form method="post" action="{{ url_for('dhcp.push_client_config') }}">
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<input type="hidden" name="stil" value="{{ stil }}">
|
||||
<div class="divider"></div>
|
||||
<div class="fs-xs faint mb-2">
|
||||
Oder direkt schreiben lassen – über SSH, mit den hinterlegten Zugangsdaten.
|
||||
Jeder Client bekommt einen eigenen Auftrag; die Ausgabe steht unter Wartung.
|
||||
</div>
|
||||
<div class="row row--tight" style="flex-wrap:wrap">
|
||||
{% for reservation in reservations if reservation.device_id %}
|
||||
<label class="check">
|
||||
<input type="checkbox" name="device_ids" value="{{ reservation.device_id }}">
|
||||
<span>{{ reservation.name or reservation.hostname }}</span>
|
||||
</label>
|
||||
{% endfor %}
|
||||
</div>
|
||||
<div class="mt-2">
|
||||
<button class="btn btn--sm btn--primary" type="submit"
|
||||
data-confirm="Die Konfiguration für {{ bezeichnung }} auf die ausgewählten Clients schreiben ({{ pfad }})? Der DHCP-Client wird dort anschließend neu gestartet."
|
||||
data-confirm-title="Konfiguration verteilen" data-confirm-ok="Verteilen">
|
||||
{{ icon('upload', size=15) }} An ausgewählte Clients senden
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
{% endif %}
|
||||
</div>
|
||||
</details>
|
||||
{% endfor %}
|
||||
{% endif %}
|
||||
</section>
|
||||
|
||||
@@ -432,7 +603,10 @@
|
||||
<form method="post" action="{{ url_for('dhcp.adopt_lease') }}">
|
||||
<input type="hidden" name="{{ csrf_field_name }}" value="{{ csrf_token() }}">
|
||||
<input type="hidden" name="mac" value="{{ lease.mac }}">
|
||||
<button class="btn btn--sm btn--ghost" type="submit"
|
||||
{# Kein Geisterknopf mehr: die Uebernahme ist die eine
|
||||
Handlung in dieser Tabelle, und sie war als
|
||||
"btn--ghost" kaum von der Zeile zu unterscheiden. #}
|
||||
<button class="btn btn--sm btn--primary" type="submit"
|
||||
data-confirm="{{ lease.hostname or lease.address }} als überwachten Client anlegen? Switch, Port und Zugangsdaten tragen Sie danach nach."
|
||||
data-confirm-title="Als Client übernehmen"
|
||||
data-confirm-ok="Übernehmen">
|
||||
|
||||
@@ -249,6 +249,39 @@
|
||||
</div>
|
||||
</section>
|
||||
|
||||
{# Fuer ein Ueberwachungswerkzeug, das auf dieser Maschine laeuft. Bewusst
|
||||
kein HTTP-Endpunkt mit Token: der Agent sitzt ohnehin hier, und was ohne
|
||||
Netz auskommt, kann auch niemand aus dem Netz abfragen. #}
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
<div class="card__title">{{ icon('terminal', size=17) }} Abfrage durch ein RMM</div>
|
||||
<div class="card__sub">
|
||||
Ein Agent auf dieser Maschine liest die Restlaufzeit ohne Anmeldung und ohne Netz.
|
||||
</div>
|
||||
</div>
|
||||
<button class="btn btn--sm btn--ghost" type="button" data-copy="#rmm-json"
|
||||
data-copy-message="Befehl kopiert.">{{ icon('copy', size=14) }} Kopieren</button>
|
||||
</div>
|
||||
<div class="card__body stack stack--tight">
|
||||
<pre class="code-block code-block--wrap" id="rmm-json">{{ rmm_befehl }}</pre>
|
||||
<p class="fs-xs faint">
|
||||
Antwortet mit einer Zeile JSON auf <strong>stdout</strong>
|
||||
(<code>valid</code>, <code>days_left</code>, <code>expires_at</code>,
|
||||
<code>lifetime</code>, <code>modules</code>). Der <strong>Ausstiegscode</strong> trägt
|
||||
die Aussage: <strong>0</strong> in Ordnung, <strong>1</strong> läuft in
|
||||
{{ rmm_warnschwelle }} Tagen oder weniger ab, <strong>2</strong> ungültig oder nicht
|
||||
vorhanden. Meldungen des Starts gehen nach stderr und stören das Auswerten nicht.
|
||||
</p>
|
||||
<div class="divider"></div>
|
||||
<div class="fs-xs faint">Nur die Restlaufzeit, ohne JSON-Auswertung:</div>
|
||||
<pre class="code-block code-block--wrap" id="rmm-tage">{{ rmm_befehl_tage }}</pre>
|
||||
<div class="divider"></div>
|
||||
<div class="fs-xs faint">Beispiel für einen Agenten mit PowerShell:</div>
|
||||
<pre class="code-block code-block--wrap">{{ rmm_powershell }}</pre>
|
||||
</div>
|
||||
</section>
|
||||
|
||||
<section class="card">
|
||||
<div class="card__header">
|
||||
<div class="flex-1">
|
||||
|
||||
@@ -26,6 +26,23 @@
|
||||
# =============================================================================
|
||||
set -euo pipefail
|
||||
|
||||
# Ein Lauf dieses Skripts gehoert in eine definierte Sprachumgebung -- nicht in
|
||||
# die, die das Terminal des Administrators zufaellig ankuendigt. Per SSH kommt
|
||||
# LC_ALL mit (sshd: "AcceptEnv LANG LC_*"), und ist diese Locale auf dem Ziel
|
||||
# nicht erzeugt, warnt **jede neu gestartete Shell**:
|
||||
#
|
||||
# bash: warning: setlocale: LC_ALL: cannot change locale (en_US.UTF-8)
|
||||
#
|
||||
# Mitten in einer Aktualisierung sieht das nach einem Fehler aus und ist
|
||||
# keiner. Nebenbei sind damit auch die Meldungen der Werkzeuge, die hier
|
||||
# laufen, in einer Sprache -- ein Protokoll, das je nach Arbeitsplatz anders
|
||||
# klingt, liest sich schlecht.
|
||||
if locale -a 2>/dev/null | grep -qix 'c\.utf-\?8'; then
|
||||
export LC_ALL=C.UTF-8 LANG=C.UTF-8
|
||||
else
|
||||
export LC_ALL=C LANG=C
|
||||
fi
|
||||
|
||||
APP=""
|
||||
INSTANCE=""
|
||||
#: Verzeichnis der Umgebungsdateien. Ueberschreibbar, damit sich die
|
||||
|
||||
+41
-3
@@ -28,6 +28,18 @@
|
||||
# =============================================================================
|
||||
set -euo pipefail
|
||||
|
||||
# **Der venv muss fuer den Dienstbenutzer lesbar sein.**
|
||||
#
|
||||
# Dieses Programm laeuft als ExecStartPre der Dienst-Unit -- und erbt damit
|
||||
# deren UMask=0027. Alles, was es anlegt, gehoerte root und waere 0750: der
|
||||
# Dienst selbst laeuft unprivilegiert und koennte sein eigenes site-packages
|
||||
# nicht einmal betreten. Gemessen: nach der Reparatur ging "import gunicorn"
|
||||
# als root, als Benutzer tesm nicht -- die Reparatur baute etwas, das genau
|
||||
# der Prozess nicht benutzen konnte, fuer den sie gedacht war.
|
||||
#
|
||||
# Im venv liegt nichts Geheimes; Schluessel und Datenbank stehen woanders.
|
||||
umask 022
|
||||
|
||||
ROOT="${1:-}"
|
||||
APP="${2:-}"
|
||||
MODUS="reparieren"
|
||||
@@ -83,7 +95,19 @@ traegt() {
|
||||
}
|
||||
|
||||
bestuecken() {
|
||||
"$PY" -m pip install --quiet --upgrade pip setuptools wheel
|
||||
# **Jeder pip-Lauf wird einzeln geprueft.**
|
||||
#
|
||||
# "set -e" hilft hier nicht: diese Funktion wird in einer Bedingung
|
||||
# aufgerufen ("if ! bestuecken"), und darin ist errexit fuer den **ganzen**
|
||||
# Rumpf abgeschaltet. Ein gescheitertes pip lief deshalb einfach weiter bis
|
||||
# zum "return 0" -- der Lauf meldete "Fertig", und im venv lagen weiter die
|
||||
# alten Pakete.
|
||||
#
|
||||
# Real passiert: der Lizenzserver blieb ueber drei Auslieferungen hinweg auf
|
||||
# 2.8.16 stehen, weil eine Abhaengigkeit nicht aufloesbar war. Gesehen hat es
|
||||
# niemand, denn die Fehlerzeile von pip ging im Lauf unter und der
|
||||
# Ausstiegscode war 0.
|
||||
"$PY" -m pip install --quiet --upgrade pip setuptools wheel || return 1
|
||||
local pakete=("$ROOT/packages/tesm-licensing" "$ROOT/packages/tesm-core")
|
||||
if [[ "$APP" == "tesm-license" ]]; then
|
||||
[[ -d "$ROOT/packages/tesm-licensing-server" ]] || {
|
||||
@@ -92,9 +116,11 @@ bestuecken() {
|
||||
}
|
||||
pakete+=("$ROOT/packages/tesm-licensing-server")
|
||||
fi
|
||||
"$PY" -m pip install --quiet "${pakete[@]}" "$ROOT/apps/$APP" gunicorn
|
||||
"$PY" -m pip install --quiet "${pakete[@]}" "$ROOT/apps/$APP" gunicorn || return 1
|
||||
# Die WebSocket-Bruecke braucht nur TESM (Terminal und Bildschirm).
|
||||
[[ "$APP" == "tesm" ]] && "$PY" -m pip install --quiet flask-sock
|
||||
if [[ "$APP" == "tesm" ]]; then
|
||||
"$PY" -m pip install --quiet flask-sock || return 1
|
||||
fi
|
||||
return 0
|
||||
}
|
||||
|
||||
@@ -130,6 +156,18 @@ if ! bestuecken; then
|
||||
exit 1
|
||||
fi
|
||||
|
||||
# Und noch einmal ausdruecklich, fuer den Fall, dass ein frueherer Lauf mit
|
||||
# strengerer Maske gebaut hat: was hier liegt, muss lesbar sein. Idempotent
|
||||
# und in einer Sekunde durch.
|
||||
chmod -R a+rX "$VENV" 2>/dev/null || true
|
||||
|
||||
# Vertrauen ist gut: nach dem Einspielen muss die Anwendung auch importierbar
|
||||
# sein. Ohne diese Probe hiesse "Fertig" nur, dass pip nicht geschimpft hat.
|
||||
if ! "$PY" -c "import $MODUL" >/dev/null 2>&1; then
|
||||
melden "FEHLER" "Die Pakete fuer $NAME wurden eingespielt, aber '$MODUL' laesst sich nicht importieren."
|
||||
exit 1
|
||||
fi
|
||||
|
||||
[[ "$MODUS" == "immer" ]] || melden "INFO" "Python-Umgebung von $NAME ist wieder vollstaendig."
|
||||
rm -f "$MERKER" 2>/dev/null || true
|
||||
exit 0
|
||||
@@ -29,6 +29,23 @@
|
||||
# =============================================================================
|
||||
set -euo pipefail
|
||||
|
||||
# Ein Lauf dieses Skripts gehoert in eine definierte Sprachumgebung -- nicht in
|
||||
# die, die das Terminal des Administrators zufaellig ankuendigt. Per SSH kommt
|
||||
# LC_ALL mit (sshd: "AcceptEnv LANG LC_*"), und ist diese Locale auf dem Ziel
|
||||
# nicht erzeugt, warnt **jede neu gestartete Shell**:
|
||||
#
|
||||
# bash: warning: setlocale: LC_ALL: cannot change locale (en_US.UTF-8)
|
||||
#
|
||||
# Mitten in einer Aktualisierung sieht das nach einem Fehler aus und ist
|
||||
# keiner. Nebenbei sind damit auch die Meldungen der Werkzeuge, die hier
|
||||
# laufen, in einer Sprache -- ein Protokoll, das je nach Arbeitsplatz anders
|
||||
# klingt, liest sich schlecht.
|
||||
if locale -a 2>/dev/null | grep -qix 'c\.utf-\?8'; then
|
||||
export LC_ALL=C.UTF-8 LANG=C.UTF-8
|
||||
else
|
||||
export LC_ALL=C LANG=C
|
||||
fi
|
||||
|
||||
APP=""
|
||||
INSTANCE=""
|
||||
PURGE=0
|
||||
|
||||
@@ -18,6 +18,23 @@
|
||||
# =============================================================================
|
||||
set -euo pipefail
|
||||
|
||||
# Ein Lauf dieses Skripts gehoert in eine definierte Sprachumgebung -- nicht in
|
||||
# die, die das Terminal des Administrators zufaellig ankuendigt. Per SSH kommt
|
||||
# LC_ALL mit (sshd: "AcceptEnv LANG LC_*"), und ist diese Locale auf dem Ziel
|
||||
# nicht erzeugt, warnt **jede neu gestartete Shell**:
|
||||
#
|
||||
# bash: warning: setlocale: LC_ALL: cannot change locale (en_US.UTF-8)
|
||||
#
|
||||
# Mitten in einer Aktualisierung sieht das nach einem Fehler aus und ist
|
||||
# keiner. Nebenbei sind damit auch die Meldungen der Werkzeuge, die hier
|
||||
# laufen, in einer Sprache -- ein Protokoll, das je nach Arbeitsplatz anders
|
||||
# klingt, liest sich schlecht.
|
||||
if locale -a 2>/dev/null | grep -qix 'c\.utf-\?8'; then
|
||||
export LC_ALL=C.UTF-8 LANG=C.UTF-8
|
||||
else
|
||||
export LC_ALL=C LANG=C
|
||||
fi
|
||||
|
||||
APP="${1:-}"
|
||||
TAG="${2:-latest}"
|
||||
|
||||
|
||||
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
|
||||
|
||||
[project]
|
||||
name = "tesm-core"
|
||||
version = "2.8.18"
|
||||
version = "2.8.20"
|
||||
description = "Gemeinsames Anwendungsgeruest (Auth, RBAC, Navigation, Design-System, Migrationen) fuer TESM und TESM-Lizenzserver"
|
||||
requires-python = ">=3.11"
|
||||
dependencies = [
|
||||
|
||||
@@ -162,6 +162,67 @@ class LicenseState:
|
||||
return dict(self.status.vendor) if self.status else {}
|
||||
|
||||
|
||||
#: Ausstiegscodes der Abfrage -- danach schlaegt ein RMM Alarm, nicht nach Text.
|
||||
ABFRAGE_OK = 0
|
||||
ABFRAGE_LAEUFT_AB = 1
|
||||
ABFRAGE_UNGUELTIG = 2
|
||||
|
||||
#: Ab hier gilt eine Lizenz als "laeuft bald ab". Dieselbe Zahl wie in der
|
||||
#: Oberflaeche -- zwei Schwellen fuer dieselbe Frage waeren eine zu viel.
|
||||
ABFRAGE_WARNSCHWELLE_TAGE = 30
|
||||
|
||||
|
||||
def zustand_als_auskunft(state: "LicenseState") -> dict[str, Any]:
|
||||
"""Der Lizenzzustand als schlichtes Woerterbuch -- fuer JSON und Skripte.
|
||||
|
||||
Gedacht fuer ein RMM, das auf der Maschine selbst laeuft: kein Netz, kein
|
||||
Token, keine Anmeldung. Was hier steht, beantwortet die eine Frage, die ein
|
||||
Kunde wirklich hat -- wie lange laeuft die Lizenz noch --, und nichts
|
||||
darueber hinaus: keine Schluessel, keine Kennungen anderer Installationen.
|
||||
"""
|
||||
status = state.status
|
||||
return {
|
||||
"valid": bool(state.valid),
|
||||
"activated": bool(state.activated),
|
||||
"type": str(status.type) if status else "",
|
||||
"role": state.role,
|
||||
"lifetime": bool(status.lifetime) if status else False,
|
||||
"expires_at": lic.iso(status.expires_at) if status and status.expires_at else "",
|
||||
# Bei einer unbefristeten Lizenz ist die Zahl bewusst ``null`` und
|
||||
# keine grosse Zahl: "noch 99999 Tage" waere eine Behauptung.
|
||||
"days_left": (status.days_left if status and not status.lifetime else None),
|
||||
"expiring_soon": bool(status.expiring_soon) if status else False,
|
||||
"grace_active": bool(status.grace_active) if status else False,
|
||||
# Drei Angaben, weil zwei davon verschieden sein koennen und die
|
||||
# Verwechslung teuer ist: "modules" ist, was die **Lizenz** freigibt --
|
||||
# dieselbe Liste, die der Lizenzserver zeigt. Was davon vor Ort
|
||||
# abgeschaltet wurde, steht daneben.
|
||||
#
|
||||
# Vorher stand hier allein das Laufende. Beim Kunden fehlte darin
|
||||
# "dhcp", waehrend die Lizenzseite es auswies -- es war lediglich unter
|
||||
# Verwaltung -> System abgeschaltet. Aus der Antwort ging das nicht
|
||||
# hervor, und damit sah es nach einem Lizenzproblem aus.
|
||||
"modules": sorted(state.modules),
|
||||
"modules_active": sorted(state.modules_in_use),
|
||||
"modules_off": sorted(state.modules_off),
|
||||
"customer": state.customer_name,
|
||||
"last_heartbeat_at": state.last_heartbeat_at,
|
||||
"error": state.error,
|
||||
}
|
||||
|
||||
|
||||
def abfrage_ausstiegscode(auskunft: dict[str, Any]) -> int:
|
||||
"""0 heil, 1 laeuft bald ab, 2 ungueltig -- die Sprache eines RMM."""
|
||||
if not auskunft.get("valid"):
|
||||
return ABFRAGE_UNGUELTIG
|
||||
if auskunft.get("lifetime"):
|
||||
return ABFRAGE_OK
|
||||
tage = auskunft.get("days_left")
|
||||
if tage is None or int(tage) <= ABFRAGE_WARNSCHWELLE_TAGE:
|
||||
return ABFRAGE_LAEUFT_AB
|
||||
return ABFRAGE_OK
|
||||
|
||||
|
||||
class LicenseManager:
|
||||
"""Haelt den Lizenzzustand und fuehrt die Handshakes durch."""
|
||||
|
||||
|
||||
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
|
||||
|
||||
[project]
|
||||
name = "tesm-licensing"
|
||||
version = "2.7.7"
|
||||
version = "2.7.8"
|
||||
description = "Ed25519-basiertes Lizenz- und Aktivierungsprotokoll fuer TESM und TESM-Lizenzserver"
|
||||
requires-python = ">=3.11"
|
||||
dependencies = ["cryptography>=42"]
|
||||
|
||||
@@ -46,6 +46,7 @@ from .license import (
|
||||
key_id,
|
||||
license_status,
|
||||
parse_iso,
|
||||
tage_bis,
|
||||
split_bundle,
|
||||
utcnow,
|
||||
verify_license,
|
||||
@@ -103,6 +104,7 @@ __all__ = [
|
||||
"machine_identity",
|
||||
"new_nonce",
|
||||
"parse_iso",
|
||||
"tage_bis",
|
||||
"sign",
|
||||
"split_bundle",
|
||||
"system_fingerprint",
|
||||
|
||||
@@ -221,6 +221,27 @@ def verify_license(
|
||||
)
|
||||
|
||||
|
||||
def tage_bis(expires_at: datetime, *, now: datetime | None = None) -> int:
|
||||
"""Restlaufzeit in **angefangenen** Tagen.
|
||||
|
||||
Aufgerundet, und das ist eine Entscheidung: eine Lizenz, die in zwei
|
||||
Stunden ablaeuft, hat "1 Tag" und nicht "0". Null bedeutet hier
|
||||
ausschliesslich *abgelaufen* -- eine gueltige Lizenz, die mit "0 Tage"
|
||||
dasteht, liest sich wie eine tote.
|
||||
|
||||
**Es gibt genau diese eine Rechnung.** Der Lizenzserver hatte eine zweite,
|
||||
abgerundete: dieselbe Lizenz zeigte in seiner Oberflaeche "21 Tage" und im
|
||||
Abruf beim Kunden "22". Zwei Zahlen fuer dieselbe Frage sind schlimmer als
|
||||
eine ungenaue -- sie kosten jemanden einen Nachmittag mit der Suche nach
|
||||
einem Fehler, den es nicht gibt.
|
||||
"""
|
||||
moment = now or utcnow()
|
||||
sekunden = int((expires_at - moment).total_seconds())
|
||||
if sekunden <= 0:
|
||||
return 0
|
||||
return -(-sekunden // 86400)
|
||||
|
||||
|
||||
def license_status(
|
||||
document: Mapping[str, Any],
|
||||
*,
|
||||
@@ -278,7 +299,7 @@ def license_status(
|
||||
days_left = 0
|
||||
days_since_expiry = int((moment - expires_at).total_seconds() // 86400)
|
||||
else:
|
||||
days_left = -(-int(delta.total_seconds()) // 86400)
|
||||
days_left = tage_bis(expires_at, now=moment)
|
||||
days_since_expiry = None
|
||||
|
||||
grace_active = bool(
|
||||
|
||||
Reference in new issue
Block a user