0b1d4ec3b8
- Notifier: controllerUnreachable, loginNewIp, updateAvailable - Login von neuer IP -> Webhook (Abgleich gegen audit_log) - cron_sync meldet nicht erreichbare Controller; cron_cleanup prüft täglich optional auf Updates und meldet Verfügbarkeit - health.php: Status-Endpoint (DB; optional Controller per ?deep=1&token=)
71 lines
2.8 KiB
PHP
71 lines
2.8 KiB
PHP
<?php
|
||
/**
|
||
* Notifier – sendet Ereignis-Benachrichtigungen an einen konfigurierten
|
||
* Webhook (Slack / Microsoft Teams / generischer JSON-Endpunkt).
|
||
*
|
||
* Gesteuert über Einstellungen:
|
||
* webhook_enabled (0/1), webhook_url
|
||
*
|
||
* Sendet ein Slack/Teams-kompatibles { "text": "..." }-Payload plus ein
|
||
* strukturiertes "event"-Feld. Fehler werden still ignoriert – eine
|
||
* Benachrichtigung darf nie den eigentlichen Vorgang blockieren.
|
||
*/
|
||
class Notifier {
|
||
/** Generisches Event senden. */
|
||
public static function send($text, array $data = []) {
|
||
try {
|
||
$db = Database::getInstance();
|
||
if ((string)$db->getSetting('webhook_enabled', '0') !== '1') {
|
||
return;
|
||
}
|
||
$url = trim((string)$db->getSetting('webhook_url', ''));
|
||
if ($url === '' || !filter_var($url, FILTER_VALIDATE_URL)) {
|
||
return;
|
||
}
|
||
} catch (\Exception $e) {
|
||
return;
|
||
}
|
||
|
||
$payload = json_encode(array_merge(['text' => $text], $data ? ['event' => $data] : []));
|
||
|
||
$ch = curl_init($url);
|
||
curl_setopt_array($ch, [
|
||
CURLOPT_POST => true,
|
||
CURLOPT_POSTFIELDS => $payload,
|
||
CURLOPT_HTTPHEADER => ['Content-Type: application/json'],
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
CURLOPT_TIMEOUT => 5,
|
||
CURLOPT_CONNECTTIMEOUT => 3,
|
||
]);
|
||
@curl_exec($ch);
|
||
curl_close($ch);
|
||
}
|
||
|
||
/** Controller nicht erreichbar (z.B. beim Sync). */
|
||
public static function controllerUnreachable($siteName, $detail = '') {
|
||
self::send("⚠️ UniFi-Controller für \"{$siteName}\" nicht erreichbar." . ($detail ? " ({$detail})" : ''),
|
||
['type' => 'controller_unreachable', 'site' => $siteName, 'detail' => $detail]);
|
||
}
|
||
|
||
/** Anmeldung von einer bisher unbekannten IP. */
|
||
public static function loginNewIp($email, $ip) {
|
||
self::send("🔐 Neue Anmeldung für {$email} von IP {$ip}.",
|
||
['type' => 'login_new_ip', 'email' => $email, 'ip' => $ip]);
|
||
}
|
||
|
||
/** Update verfügbar. */
|
||
public static function updateAvailable($sha) {
|
||
self::send("⬆️ Update verfügbar (" . substr((string)$sha, 0, 7) . "). Siehe Administration → System-Update.",
|
||
['type' => 'update_available', 'sha' => $sha]);
|
||
}
|
||
|
||
/** Bequemer Helfer für erstellte Voucher. */
|
||
public static function voucherCreated($count, $siteName, $byUser = null) {
|
||
$who = $byUser ? " von {$byUser}" : '';
|
||
$what = $count > 1 ? "{$count} Voucher" : 'Ein Voucher';
|
||
self::send(
|
||
"🎫 {$what} für \"{$siteName}\"{$who} erstellt.",
|
||
['type' => 'voucher_created', 'count' => $count, 'site' => $siteName, 'user' => $byUser]
|
||
);
|
||
}
|
||
}
|