Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a237a79915 | ||
|
|
18ed4de9f9 | ||
|
|
4d1389c3a8 | ||
|
|
252c0686df | ||
|
|
f1e4271488 |
@@ -56,6 +56,21 @@ APP_SECRET="bitte-aendern-mindestens-32-zeichen-langer-zufallswert"
|
||||
# Lebensdauer einer Anmeldung in Tagen.
|
||||
SESSION_TTL_DAYS="30"
|
||||
|
||||
# ── Benachrichtigungen ───────────────────────────────────────
|
||||
# ntfy und Webhook brauchen nichts weiter – die Ziele werden in der
|
||||
# Anwendung unter "Mein Konto" eingerichtet.
|
||||
#
|
||||
# E-Mail steht erst zur Verfuegung, wenn SMTP_HOST gesetzt ist:
|
||||
# SMTP_HOST="smtp.example.com"
|
||||
# SMTP_PORT="587"
|
||||
# SMTP_SECURE="false" # true bei Port 465, sonst STARTTLS
|
||||
# SMTP_USER="nebula@example.com"
|
||||
# SMTP_PASSWORD="geheim"
|
||||
# SMTP_FROM="Nebula <nebula@example.com>"
|
||||
|
||||
# Timeout fuer das Zustellen in Millisekunden
|
||||
NOTIFY_TIMEOUT_MS="10000"
|
||||
|
||||
# ── Ausgehende Git-Zugriffe ──────────────────────────────────
|
||||
# Timeout fuer Git-API-Aufrufe in Millisekunden
|
||||
GIT_API_TIMEOUT_MS="15000"
|
||||
|
||||
+73
@@ -322,6 +322,75 @@ Dateneinsicht. Ein Administrator sieht dadurch weiterhin keine fremden Projekte.
|
||||
|
||||
---
|
||||
|
||||
## 4b. Benachrichtigungen
|
||||
|
||||
Einzurichten unter *Mein Konto → Benachrichtigungen*, pro Konto und beliebig viele Ziele.
|
||||
|
||||
### Anlässe
|
||||
|
||||
| Anlass | Wann |
|
||||
| --- | --- |
|
||||
| ⚠️ **Abgleich fehlgeschlagen** | Das Git-System war nicht erreichbar oder hat abgelehnt |
|
||||
| 🔴 **CI rot** | Der letzte Lauf auf dem Default-Branch ist fehlgeschlagen |
|
||||
| 🏷️ **Neues Release** | Ein neuer Tag oder ein neues Release ist aufgetaucht |
|
||||
| 🕸️ **Projekt steht still** | Seit längerem kein Commit — Schwelle einstellbar, Vorgabe 60 Tage |
|
||||
|
||||
### Nur bei Änderung
|
||||
|
||||
Der entscheidende Punkt: Gemeldet wird **ausschließlich, wenn sich etwas ändert**
|
||||
gegenüber dem, worüber zuletzt benachrichtigt wurde. Ein Repository mit abgelaufenem
|
||||
Token meldet sich also **einmal**, nicht bei jedem stündlichen Durchlauf. Wird der Fehler
|
||||
ein anderer, kommt eine neue Meldung; ist er behoben und tritt später erneut auf, ebenso.
|
||||
|
||||
Zwei Feinheiten:
|
||||
|
||||
- **Beim allerersten Abgleich** eines Repositories wird kein Release gemeldet — sonst
|
||||
wäre jede bereits vorhandene Version eine „Neuigkeit".
|
||||
- Der Merkstand wird auch dann fortgeschrieben, wenn **kein** Ziel eingerichtet ist. Sonst
|
||||
käme beim ersten eingerichteten Ziel die ganze Vergangenheit hinterher.
|
||||
|
||||
### Stillstand
|
||||
|
||||
Der einzige Anlass, der an keinem Ereignis hängt — es passiert ja gerade nichts. Deshalb
|
||||
ein eigener Durchlauf, **höchstens einmal am Tag**, unabhängig vom automatischen Abgleich.
|
||||
Hört niemand auf diesen Anlass, läuft die Prüfung gar nicht erst.
|
||||
|
||||
Maßstab ist ausschließlich der **letzte Commit** im verknüpften Repository. Das
|
||||
Änderungsdatum des Projekts taugt nicht: jeder Abgleich fasst es an und würde den
|
||||
Stillstand immer wieder zurücksetzen. Projekte **ohne Repository** bleiben deshalb außen
|
||||
vor, ebenso fertige und archivierte.
|
||||
|
||||
Gemeldet wird je Projekt einmal. Erneut erst, wenn danach wieder ein Commit kam und es
|
||||
seitdem wieder still geworden ist — ein Projekt, das aufwacht und wieder einschläft, meldet
|
||||
sich also ein zweites Mal.
|
||||
|
||||
Die Schwelle setzt ein Administrator unter *Admin-Einstellungen → Stillstand* (14 Tage bis
|
||||
ein Jahr). Eine Änderung wirkt sofort, nicht erst nach 24 Stunden.
|
||||
|
||||
### Zustellwege
|
||||
|
||||
| Weg | Details |
|
||||
| --- | --- |
|
||||
| **ntfy** | Vollständige Themen-URL. Titel, Priorität und Symbol als Kopfzeilen; optionales Bearer-Token für geschützte Themen. Läuft auch gegen ein selbst gehostetes ntfy im eigenen Netz. |
|
||||
| **Webhook** | JSON per POST mit Anlass, Titel, Text, Projektbezug und Tieflink. Mit hinterlegtem Geheimnis wird der Rumpf per HMAC-SHA256 signiert (`X-Nebula-Signature`), damit der Empfänger die Herkunft prüfen kann. |
|
||||
| **E-Mail** | Über SMTP. Steht erst zur Verfügung, wenn `SMTP_HOST` in der `.env` gesetzt ist — sonst ist die Auswahl in der Oberfläche gesperrt und erklärt, warum. |
|
||||
|
||||
Jedes Ziel lässt sich einzeln **testen** und **pausieren**; Ergebnis und Zeitpunkt der
|
||||
letzten Zustellung stehen an der Karte.
|
||||
|
||||
### Absicherung
|
||||
|
||||
- Zieladressen sind Benutzereingaben, die der Server abruft — sie laufen deshalb durch
|
||||
denselben **SSRF-Schutz** wie die Git-Verbindungen. Ein ntfy im eigenen Netz bleibt
|
||||
erlaubt, Loopback und Cloud-Metadaten nicht.
|
||||
- Redirects werden **nicht verfolgt**: ein Umleitungsziel wäre nicht geprüft.
|
||||
- Geheimnisse liegen AES-256-GCM-verschlüsselt und verlassen den Server nie; die
|
||||
Oberfläche zeigt nur einen Hinweis wie `test…mnis`.
|
||||
- Eine fehlgeschlagene Zustellung lässt den Abgleich nicht scheitern — der Fehler landet
|
||||
am Ziel, nicht im Sync.
|
||||
|
||||
---
|
||||
|
||||
## 5. Oberfläche
|
||||
|
||||
- **Dark Glassmorphism**: milchige Glasflächen, driftende Nebel im Hintergrund, feines
|
||||
@@ -349,6 +418,7 @@ Dateneinsicht. Ein Administrator sieht dadurch weiterhin keine fremden Projekte.
|
||||
| `AppSettings` | Betriebsart und Registrierung (eine Zeile) |
|
||||
| `Project` | Projektstammdaten, Status, Fortschritt, Repo-Verknüpfung, Besitzer |
|
||||
| `Task` | Aufgaben mit Spalte, Position, Fälligkeit und Labels |
|
||||
| `NotificationTarget` | Zustellwege je Konto, mit verschlüsseltem Geheimnis |
|
||||
| `Note` | Notizen (n:1 zu Projekt, Cascade-Delete) |
|
||||
| `GitConnection` | Git-Systeme inkl. verschlüsseltem Token, Besitzer |
|
||||
| `RepoSnapshot` | Zwischengespeicherter Repo-Stand (1:1 zu Projekt) |
|
||||
@@ -414,6 +484,9 @@ Datenbank):
|
||||
| `security/ssrf` | Sperrlisten für Loopback, Link-Local, Metadaten-Endpunkt, CGNAT und Multicast; Formprüfung; die drei Umgebungsschalter |
|
||||
| `auth/password` | scrypt-Rundlauf, unterschiedliches Salz, Ablageformat, Verhalten bei kaputten Hashes, Passwortregeln |
|
||||
| `tasks` | Berechnung des abgeleiteten Fortschritts, Spaltenreihenfolge |
|
||||
| `notify/pending` | Wann eine Benachrichtigung fällig ist: neuer Fehler ja, gleicher Fehler nein; CI-Wechsel nach rot; Release erst ab dem zweiten Abgleich |
|
||||
| `notify/stale` | Stillstandsschwelle, keine Zweitmeldung, aber erneute Meldung nach zwischenzeitlicher Aktivität |
|
||||
| `validation` | Dass jeder Anlass, den die Oberfläche anbietet, auch vom Schema akzeptiert wird — entstanden aus genau diesem Fehler |
|
||||
|
||||
**`npm run test:e2e` — Ende-zu-Ende** (Playwright, 13 Stück, rund 20 Sekunden). Läuft
|
||||
gegen die gebaute Anwendung mit eigener Datenbank auf Port 3111 — also durch Middleware,
|
||||
|
||||
@@ -127,6 +127,8 @@ Alle Variablen sind in [`.env.example`](.env.example) dokumentiert.
|
||||
| `GIT_ALLOW_LOOPBACK` | Git-Instanz auf demselben Rechner erlauben | `false` |
|
||||
| `GIT_BLOCK_PRIVATE` | Zugriff ins private LAN sperren | `false` |
|
||||
| `GIT_ALLOWED_HOSTS` | Strengster Modus: nur diese Hosts erlauben | leer |
|
||||
| `NOTIFY_TIMEOUT_MS` | Timeout beim Zustellen von Benachrichtigungen | `10000` |
|
||||
| `SMTP_HOST` … `SMTP_FROM` | SMTP-Zugang; ohne `SMTP_HOST` steht der Weg „E-Mail" nicht zur Verfügung | leer |
|
||||
|
||||
`APP_NAME`, `APP_TAGLINE` und `APP_URL` werden **zur Laufzeit** gelesen. Dasselbe
|
||||
Docker-Image lässt sich also ohne Neubau umbenennen oder unter einer anderen Adresse
|
||||
@@ -338,6 +340,9 @@ ausschließlich Daten des angemeldeten Kontos.
|
||||
| `POST` | `/api/projects/import` | Import, mit `dryRun` für die Vorschau |
|
||||
| `GET` | `/api/admin/backup` | Vollständige Sicherung als JSON (Admin) |
|
||||
| `GET` | `/api/search?q=` | Volltextsuche über die eigenen Notizen |
|
||||
| `GET` `POST` | `/api/notifications` | Benachrichtigungsziele |
|
||||
| `PATCH` `DELETE` | `/api/notifications/:id` | Ziel ändern / entfernen |
|
||||
| `POST` | `/api/notifications/:id/test` | Testnachricht senden |
|
||||
| `GET` `PATCH` `DELETE` | `/api/projects/:id` | Projekt lesen / ändern / löschen |
|
||||
| `POST` | `/api/projects/:id/sync` | Repo-Daten vom Git-System holen |
|
||||
| `GET` `POST` | `/api/projects/:id/tasks` | Aufgaben des Projekts |
|
||||
|
||||
+9
-14
@@ -11,31 +11,24 @@ Was bereits steht, listet [FEATURES.md](FEATURES.md).
|
||||
|
||||
## 1 · Als Nächstes empfohlen
|
||||
|
||||
### 1.1 Benachrichtigungen `M`
|
||||
|
||||
Bei Sync-Fehlern, roter CI, neuen Releases oder Projekten, die lange
|
||||
stillstehen. Kanäle: E-Mail (SMTP), ntfy, generischer Webhook. Zusammen mit
|
||||
dem automatischen Abgleich und dem CI-Status ergibt das ein brauchbares
|
||||
Frühwarnsystem — die Daten liegen bereits vor.
|
||||
|
||||
---
|
||||
|
||||
## 2 · Danach
|
||||
|
||||
### 2.1 Webhooks statt Polling `M`
|
||||
### 1.1 Webhooks statt Polling `M`
|
||||
|
||||
Ein Push aktualisiert den Snapshot sofort, statt bis zum nächsten Durchlauf
|
||||
zu warten. Braucht einen öffentlich erreichbaren Endpunkt mit
|
||||
Signaturprüfung je Provider — sinnvoll erst, wenn die Instanz von außen
|
||||
erreichbar ist. Der Zeitplan bleibt als Rückfalllösung.
|
||||
|
||||
### 2.2 Commit-Aktivität als Heatmap `S`
|
||||
---
|
||||
|
||||
## 2 · Danach
|
||||
|
||||
### 2.1 Commit-Aktivität als Heatmap `S`
|
||||
|
||||
Die Sparkline gibt es auf Karte und Projektseite. Eine Heatmap über ein Jahr
|
||||
wäre die nächste Ausbaustufe — dafür braucht es allerdings mehr als eine
|
||||
Seite Commits, also Paginierung oder die Statistik-Endpunkte.
|
||||
|
||||
### 2.3 Kanban mit freier Reihenfolge `M`
|
||||
### 2.2 Kanban mit freier Reihenfolge `M`
|
||||
|
||||
Heute folgt die Reihenfolge innerhalb einer Spalte der gewählten Sortierung.
|
||||
Frei sortieren hieße, eine Position je Projekt zu speichern.
|
||||
@@ -117,6 +110,8 @@ Damit klar ist, was **nicht** kommt und warum:
|
||||
| **v0.4.0** Kanban mit Drag & Drop, CI-Status je Branch, Commit-Aktivität | ✓ |
|
||||
| **v0.5.0** Aufgabenbrett je Projekt mit sortierbaren Spalten, Fortschritt aus Aufgaben | ✓ |
|
||||
| **v0.6.0** Ende-zu-Ende-Tests mit Playwright, CI-Pipeline für Gitea Actions | ✓ |
|
||||
| **v0.7.0** Benachrichtigungen über ntfy, Webhook und E-Mail | ✓ |
|
||||
| **v0.8.0** Stillstehende Projekte melden, Schwelle im Adminbereich | ✓ |
|
||||
|
||||
Zur Entscheidung beim Export: Git-Tokens gehen **nicht** mit. Die Verbindung wird nur
|
||||
beschrieben, das Token ist nach dem Import neu zu hinterlegen. Snapshots bleiben
|
||||
|
||||
@@ -59,6 +59,13 @@ services:
|
||||
APP_URL: ${APP_URL:-http://localhost:3000}
|
||||
SESSION_TTL_DAYS: ${SESSION_TTL_DAYS:-30}
|
||||
GIT_API_TIMEOUT_MS: ${GIT_API_TIMEOUT_MS:-15000}
|
||||
NOTIFY_TIMEOUT_MS: ${NOTIFY_TIMEOUT_MS:-10000}
|
||||
SMTP_HOST: ${SMTP_HOST:-}
|
||||
SMTP_PORT: ${SMTP_PORT:-587}
|
||||
SMTP_SECURE: ${SMTP_SECURE:-}
|
||||
SMTP_USER: ${SMTP_USER:-}
|
||||
SMTP_PASSWORD: ${SMTP_PASSWORD:-}
|
||||
SMTP_FROM: ${SMTP_FROM:-}
|
||||
GIT_ALLOW_LOOPBACK: ${GIT_ALLOW_LOOPBACK:-false}
|
||||
GIT_BLOCK_PRIVATE: ${GIT_BLOCK_PRIVATE:-false}
|
||||
GIT_ALLOWED_HOSTS: ${GIT_ALLOWED_HOSTS:-}
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "nebula",
|
||||
"version": "0.7.0",
|
||||
"version": "0.8.0",
|
||||
"private": true,
|
||||
"description": "Nebula – Dashboard fuer Vibe-Coding Projekte mit Git-Anbindung (GitHub, GitLab, Gitea)",
|
||||
"scripts": {
|
||||
|
||||
@@ -0,0 +1,9 @@
|
||||
-- AlterEnum
|
||||
ALTER TYPE "NotificationEvent" ADD VALUE 'PROJECT_STALE';
|
||||
|
||||
-- AlterTable
|
||||
ALTER TABLE "AppSettings" ADD COLUMN "lastStaleCheckAt" TIMESTAMP(3),
|
||||
ADD COLUMN "staleAfterDays" INTEGER NOT NULL DEFAULT 60;
|
||||
|
||||
-- AlterTable
|
||||
ALTER TABLE "Project" ADD COLUMN "notifiedStaleAt" TIMESTAMP(3);
|
||||
@@ -48,6 +48,8 @@ enum NotificationEvent {
|
||||
CI_FAILED
|
||||
/// Im Repository ist ein neuer Tag oder ein neues Release aufgetaucht.
|
||||
NEW_RELEASE
|
||||
/// Seit laengerem kein Commit mehr – der sanfte Stups.
|
||||
PROJECT_STALE
|
||||
}
|
||||
|
||||
/// Spalten des Aufgabenbretts innerhalb eines Projekts.
|
||||
@@ -181,6 +183,12 @@ model AppSettings {
|
||||
/// Kurzbericht des letzten Durchlaufs: { synced, failed, skipped, ms }
|
||||
lastAutoSyncReport Json?
|
||||
|
||||
// ── Stillstand ─────────────────────────────────────────────
|
||||
/// Ab wie vielen Tagen ohne Commit ein Projekt als stillstehend gilt.
|
||||
staleAfterDays Int @default(60)
|
||||
/// Die Pruefung laeuft hoechstens einmal am Tag.
|
||||
lastStaleCheckAt DateTime?
|
||||
|
||||
updatedAt DateTime @updatedAt
|
||||
}
|
||||
|
||||
@@ -273,6 +281,9 @@ model Project {
|
||||
notifiedSyncError String?
|
||||
notifiedCiState String?
|
||||
notifiedRelease String?
|
||||
/// Wann zuletzt wegen Stillstands gemeldet wurde. Erneut gemeldet wird
|
||||
/// erst, wenn danach wieder ein Commit kam und es dann wieder still wurde.
|
||||
notifiedStaleAt DateTime?
|
||||
|
||||
notes Note[]
|
||||
tasks Task[]
|
||||
|
||||
@@ -1,5 +1,10 @@
|
||||
import type { Metadata } from "next";
|
||||
import { AccountManager, type AccountData } from "@/components/account/AccountManager";
|
||||
import {
|
||||
NotificationSection,
|
||||
type NotificationTargetEntry,
|
||||
} from "@/components/account/NotificationSection";
|
||||
import { emailAvailable } from "@/lib/notify";
|
||||
import { requireUserPage } from "@/lib/auth/guard";
|
||||
import { WEBAUTHN_AVAILABLE } from "@/lib/config";
|
||||
import { prisma } from "@/lib/db";
|
||||
@@ -13,7 +18,7 @@ export async function generateMetadata(): Promise<Metadata> {
|
||||
export default async function AccountPage() {
|
||||
const user = await requireUserPage();
|
||||
|
||||
const [passkeys, sessions] = await Promise.all([
|
||||
const [passkeys, sessions, targets] = await Promise.all([
|
||||
prisma.credential.findMany({
|
||||
where: { userId: user.id },
|
||||
select: {
|
||||
@@ -37,6 +42,22 @@ export default async function AccountPage() {
|
||||
},
|
||||
orderBy: { lastSeenAt: "desc" },
|
||||
}),
|
||||
prisma.notificationTarget.findMany({
|
||||
where: { userId: user.id },
|
||||
select: {
|
||||
id: true,
|
||||
name: true,
|
||||
channel: true,
|
||||
target: true,
|
||||
secretHint: true,
|
||||
events: true,
|
||||
isActive: true,
|
||||
lastSentAt: true,
|
||||
lastOk: true,
|
||||
lastMessage: true,
|
||||
},
|
||||
orderBy: { name: "asc" },
|
||||
}),
|
||||
]);
|
||||
|
||||
const data: AccountData = {
|
||||
@@ -60,6 +81,11 @@ export default async function AccountPage() {
|
||||
</header>
|
||||
|
||||
<AccountManager data={data} />
|
||||
|
||||
<NotificationSection
|
||||
targets={targets as unknown as NotificationTargetEntry[]}
|
||||
emailAvailable={emailAvailable()}
|
||||
/>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
@@ -19,7 +19,7 @@ export async function generateMetadata(): Promise<Metadata> {
|
||||
export default async function AdminPage() {
|
||||
const admin = await requireAdminPage();
|
||||
|
||||
const [settings, users, eligible] = await Promise.all([
|
||||
const [settings, users, eligible, staleListeners] = await Promise.all([
|
||||
getAppSettings(),
|
||||
prisma.user.findMany({
|
||||
select: userSafeSelect,
|
||||
@@ -36,6 +36,9 @@ export default async function AdminPage() {
|
||||
],
|
||||
},
|
||||
}),
|
||||
prisma.notificationTarget.count({
|
||||
where: { isActive: true, events: { has: "PROJECT_STALE" } },
|
||||
}),
|
||||
]);
|
||||
|
||||
const data: AdminData = {
|
||||
@@ -54,6 +57,11 @@ export default async function AdminPage() {
|
||||
lastReport: (settings.lastAutoSyncReport as AutoSyncReport | null) ?? null,
|
||||
eligible,
|
||||
},
|
||||
stale: {
|
||||
afterDays: settings.staleAfterDays,
|
||||
lastCheckAt: settings.lastStaleCheckAt,
|
||||
listeners: staleListeners,
|
||||
},
|
||||
};
|
||||
|
||||
return (
|
||||
|
||||
@@ -37,6 +37,7 @@ export async function PATCH(request: Request) {
|
||||
autoSyncIntervalMinutes,
|
||||
autoSyncActiveOnly,
|
||||
autoSyncBatchSize,
|
||||
staleAfterDays,
|
||||
} = parsed.data;
|
||||
|
||||
// Der Wechsel in den Einzelbetrieb wuerde weitere Konten aussperren –
|
||||
@@ -57,6 +58,11 @@ export async function PATCH(request: Request) {
|
||||
...(autoSyncIntervalMinutes !== undefined ? { autoSyncIntervalMinutes } : {}),
|
||||
...(autoSyncActiveOnly !== undefined ? { autoSyncActiveOnly } : {}),
|
||||
...(autoSyncBatchSize !== undefined ? { autoSyncBatchSize } : {}),
|
||||
// Neue Schwelle: die Pruefung soll beim naechsten Tick greifen, nicht
|
||||
// erst in 24 Stunden.
|
||||
...(staleAfterDays !== undefined
|
||||
? { staleAfterDays, lastStaleCheckAt: null }
|
||||
: {}),
|
||||
};
|
||||
|
||||
const settings = await prisma.appSettings.upsert({
|
||||
|
||||
@@ -0,0 +1,93 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { requireUserApi } from "@/lib/auth/guard";
|
||||
import { encryptSecret, tokenHint } from "@/lib/crypto";
|
||||
import { prisma } from "@/lib/db";
|
||||
import { jsonError, readJsonBody } from "@/lib/security/request";
|
||||
import { BlockedHostError, assertAllowedUrl } from "@/lib/security/ssrf";
|
||||
import { targetSafeSelect } from "@/lib/notify/types";
|
||||
import { formatZodError, notificationTargetUpdateSchema } from "@/lib/validation";
|
||||
|
||||
export const dynamic = "force-dynamic";
|
||||
|
||||
type Params = { params: Promise<{ id: string }> };
|
||||
|
||||
export async function PATCH(request: Request, { params }: Params) {
|
||||
const auth = await requireUserApi();
|
||||
if (!auth.ok) return auth.response;
|
||||
|
||||
const { id } = await params;
|
||||
const existing = await prisma.notificationTarget.findFirst({
|
||||
where: { id, userId: auth.user.id },
|
||||
});
|
||||
if (!existing) return jsonError("Ziel nicht gefunden", 404);
|
||||
|
||||
const body = await readJsonBody(request);
|
||||
if (!body.ok) return body.response;
|
||||
|
||||
const parsed = notificationTargetUpdateSchema.safeParse(body.data);
|
||||
if (!parsed.success) {
|
||||
return NextResponse.json(
|
||||
{ error: "Validierung fehlgeschlagen", fields: formatZodError(parsed.error) },
|
||||
{ status: 422 },
|
||||
);
|
||||
}
|
||||
|
||||
const data = parsed.data;
|
||||
const update: Record<string, unknown> = {};
|
||||
|
||||
if (data.name !== undefined) update.name = data.name;
|
||||
if (data.events !== undefined) update.events = data.events;
|
||||
if (data.isActive !== undefined) update.isActive = data.isActive;
|
||||
|
||||
if (data.target !== undefined) {
|
||||
if (existing.channel !== "EMAIL") {
|
||||
try {
|
||||
await assertAllowedUrl(data.target);
|
||||
} catch (error) {
|
||||
if (error instanceof BlockedHostError) {
|
||||
return NextResponse.json(
|
||||
{ error: error.message, fields: { target: error.message } },
|
||||
{ status: 422 },
|
||||
);
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
update.target = data.target;
|
||||
}
|
||||
|
||||
// Leeres Feld heisst "unveraendert", null heisst "entfernen".
|
||||
if (data.secret !== undefined) {
|
||||
if (data.secret) {
|
||||
update.secretCipher = encryptSecret(data.secret);
|
||||
update.secretHint = tokenHint(data.secret);
|
||||
} else {
|
||||
update.secretCipher = null;
|
||||
update.secretHint = null;
|
||||
}
|
||||
}
|
||||
|
||||
try {
|
||||
const target = await prisma.notificationTarget.update({
|
||||
where: { id },
|
||||
data: update,
|
||||
select: targetSafeSelect,
|
||||
});
|
||||
return NextResponse.json({ target });
|
||||
} catch {
|
||||
return jsonError("Name bereits vergeben.", 409);
|
||||
}
|
||||
}
|
||||
|
||||
export async function DELETE(_request: Request, { params }: Params) {
|
||||
const auth = await requireUserApi();
|
||||
if (!auth.ok) return auth.response;
|
||||
|
||||
const { id } = await params;
|
||||
const result = await prisma.notificationTarget.deleteMany({
|
||||
where: { id, userId: auth.user.id },
|
||||
});
|
||||
if (result.count === 0) return jsonError("Ziel nicht gefunden", 404);
|
||||
|
||||
return NextResponse.json({ ok: true });
|
||||
}
|
||||
@@ -0,0 +1,40 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { requireUserApi } from "@/lib/auth/guard";
|
||||
import { prisma } from "@/lib/db";
|
||||
import { deliver } from "@/lib/notify/channels";
|
||||
import { testMessage } from "@/lib/notify";
|
||||
import { LIMITS, rateLimit } from "@/lib/security/rateLimit";
|
||||
import { clientIp, jsonError, tooManyRequests } from "@/lib/security/request";
|
||||
|
||||
export const dynamic = "force-dynamic";
|
||||
|
||||
type Params = { params: Promise<{ id: string }> };
|
||||
|
||||
/** Schickt eine Testnachricht an genau dieses Ziel. */
|
||||
export async function POST(request: Request, { params }: Params) {
|
||||
const auth = await requireUserApi();
|
||||
if (!auth.ok) return auth.response;
|
||||
|
||||
// Loest einen ausgehenden Aufruf aus – entsprechend begrenzt.
|
||||
const limited = rateLimit(
|
||||
`notify-test:${auth.user.id}:${clientIp(request)}`,
|
||||
LIMITS.outbound.limit,
|
||||
LIMITS.outbound.windowMs,
|
||||
);
|
||||
if (!limited.ok) return tooManyRequests(limited.retryAfter);
|
||||
|
||||
const { id } = await params;
|
||||
const target = await prisma.notificationTarget.findFirst({
|
||||
where: { id, userId: auth.user.id },
|
||||
});
|
||||
if (!target) return jsonError("Ziel nicht gefunden", 404);
|
||||
|
||||
const result = await deliver(target, testMessage());
|
||||
|
||||
await prisma.notificationTarget.update({
|
||||
where: { id },
|
||||
data: { lastSentAt: new Date(), lastOk: result.ok, lastMessage: result.message },
|
||||
});
|
||||
|
||||
return NextResponse.json(result, { status: result.ok ? 200 : 502 });
|
||||
}
|
||||
@@ -0,0 +1,83 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { requireUserApi } from "@/lib/auth/guard";
|
||||
import { encryptSecret, tokenHint } from "@/lib/crypto";
|
||||
import { prisma } from "@/lib/db";
|
||||
import { readJsonBody } from "@/lib/security/request";
|
||||
import { targetSafeSelect } from "@/lib/notify/types";
|
||||
import { BlockedHostError, assertAllowedUrl } from "@/lib/security/ssrf";
|
||||
import { formatZodError, notificationTargetCreateSchema } from "@/lib/validation";
|
||||
|
||||
export const dynamic = "force-dynamic";
|
||||
|
||||
export async function GET() {
|
||||
const auth = await requireUserApi();
|
||||
if (!auth.ok) return auth.response;
|
||||
|
||||
const targets = await prisma.notificationTarget.findMany({
|
||||
where: { userId: auth.user.id },
|
||||
select: targetSafeSelect,
|
||||
orderBy: { name: "asc" },
|
||||
});
|
||||
return NextResponse.json({ targets });
|
||||
}
|
||||
|
||||
export async function POST(request: Request) {
|
||||
const auth = await requireUserApi();
|
||||
if (!auth.ok) return auth.response;
|
||||
|
||||
const body = await readJsonBody(request);
|
||||
if (!body.ok) return body.response;
|
||||
|
||||
const parsed = notificationTargetCreateSchema.safeParse(body.data);
|
||||
if (!parsed.success) {
|
||||
return NextResponse.json(
|
||||
{ error: "Validierung fehlgeschlagen", fields: formatZodError(parsed.error) },
|
||||
{ status: 422 },
|
||||
);
|
||||
}
|
||||
|
||||
const { name, channel, target, secret, events, isActive } = parsed.data;
|
||||
|
||||
// Webhook und ntfy ruft der Server spaeter selbst auf – gleiche Pruefung
|
||||
// wie bei den Git-Verbindungen.
|
||||
if (channel !== "EMAIL") {
|
||||
try {
|
||||
await assertAllowedUrl(target);
|
||||
} catch (error) {
|
||||
if (error instanceof BlockedHostError) {
|
||||
return NextResponse.json(
|
||||
{ error: error.message, fields: { target: error.message } },
|
||||
{ status: 422 },
|
||||
);
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
const duplicate = await prisma.notificationTarget.findFirst({
|
||||
where: { userId: auth.user.id, name },
|
||||
select: { id: true },
|
||||
});
|
||||
if (duplicate) {
|
||||
return NextResponse.json(
|
||||
{ error: "Name bereits vergeben.", fields: { name: "Name bereits vergeben" } },
|
||||
{ status: 409 },
|
||||
);
|
||||
}
|
||||
|
||||
const created = await prisma.notificationTarget.create({
|
||||
data: {
|
||||
userId: auth.user.id,
|
||||
name,
|
||||
channel,
|
||||
target,
|
||||
secretCipher: secret ? encryptSecret(secret) : null,
|
||||
secretHint: secret ? tokenHint(secret) : null,
|
||||
events,
|
||||
isActive,
|
||||
},
|
||||
select: targetSafeSelect,
|
||||
});
|
||||
|
||||
return NextResponse.json({ target: created }, { status: 201 });
|
||||
}
|
||||
@@ -0,0 +1,515 @@
|
||||
"use client";
|
||||
|
||||
import { useEffect, useState } from "react";
|
||||
import { useRouter } from "next/navigation";
|
||||
import {
|
||||
Bell,
|
||||
BellRing,
|
||||
CheckCircle2,
|
||||
KeyRound,
|
||||
Loader2,
|
||||
Mail,
|
||||
Pencil,
|
||||
Plus,
|
||||
Trash2,
|
||||
Webhook,
|
||||
XCircle,
|
||||
} from "lucide-react";
|
||||
import type { NotificationChannel, NotificationEvent } from "@prisma/client";
|
||||
import { Modal } from "@/components/ui/Modal";
|
||||
import { EVENT_META, NOTIFICATION_EVENTS } from "@/lib/notify/types";
|
||||
import { cn, formatRelative } from "@/lib/utils";
|
||||
|
||||
export interface NotificationTargetEntry {
|
||||
id: string;
|
||||
name: string;
|
||||
channel: NotificationChannel;
|
||||
target: string;
|
||||
secretHint: string | null;
|
||||
events: NotificationEvent[];
|
||||
isActive: boolean;
|
||||
lastSentAt: string | Date | null;
|
||||
lastOk: boolean | null;
|
||||
lastMessage: string | null;
|
||||
}
|
||||
|
||||
const CHANNEL_META: Record<
|
||||
NotificationChannel,
|
||||
{ label: string; icon: typeof Webhook; hint: string; placeholder: string }
|
||||
> = {
|
||||
NTFY: {
|
||||
label: "ntfy",
|
||||
icon: BellRing,
|
||||
hint: "Vollstaendige Themen-URL, z. B. https://ntfy.sh/mein-geheimes-thema",
|
||||
placeholder: "https://ntfy.sh/mein-thema",
|
||||
},
|
||||
WEBHOOK: {
|
||||
label: "Webhook",
|
||||
icon: Webhook,
|
||||
hint: "Bekommt JSON per POST. Mit Geheimnis wird der Rumpf signiert (X-Nebula-Signature).",
|
||||
placeholder: "https://mein-dienst.de/haken",
|
||||
},
|
||||
EMAIL: {
|
||||
label: "E-Mail",
|
||||
icon: Mail,
|
||||
hint: "Braucht SMTP-Zugangsdaten in der .env der Instanz.",
|
||||
placeholder: "ich@example.com",
|
||||
},
|
||||
};
|
||||
|
||||
export function NotificationSection({
|
||||
targets,
|
||||
emailAvailable,
|
||||
}: {
|
||||
targets: NotificationTargetEntry[];
|
||||
emailAvailable: boolean;
|
||||
}) {
|
||||
const router = useRouter();
|
||||
const [dialogOpen, setDialogOpen] = useState(false);
|
||||
const [editing, setEditing] = useState<NotificationTargetEntry | null>(null);
|
||||
const [busyId, setBusyId] = useState<string | null>(null);
|
||||
const [notice, setNotice] = useState<{ ok: boolean; text: string } | null>(null);
|
||||
|
||||
async function test(entry: NotificationTargetEntry) {
|
||||
setBusyId(entry.id);
|
||||
setNotice(null);
|
||||
try {
|
||||
const response = await fetch(`/api/notifications/${entry.id}/test`, { method: "POST" });
|
||||
const body = await response.json().catch(() => ({}));
|
||||
setNotice({ ok: response.ok, text: body.message ?? body.error ?? "Unbekannte Antwort." });
|
||||
router.refresh();
|
||||
} finally {
|
||||
setBusyId(null);
|
||||
}
|
||||
}
|
||||
|
||||
async function remove(entry: NotificationTargetEntry) {
|
||||
if (!window.confirm(`Ziel „${entry.name}“ entfernen?`)) return;
|
||||
setBusyId(entry.id);
|
||||
await fetch(`/api/notifications/${entry.id}`, { method: "DELETE" }).catch(() => undefined);
|
||||
setBusyId(null);
|
||||
router.refresh();
|
||||
}
|
||||
|
||||
async function toggle(entry: NotificationTargetEntry) {
|
||||
setBusyId(entry.id);
|
||||
await fetch(`/api/notifications/${entry.id}`, {
|
||||
method: "PATCH",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify({ isActive: !entry.isActive }),
|
||||
}).catch(() => undefined);
|
||||
setBusyId(null);
|
||||
router.refresh();
|
||||
}
|
||||
|
||||
return (
|
||||
<section className="glass p-5">
|
||||
<div className="mb-4 flex flex-wrap items-start justify-between gap-3">
|
||||
<div className="flex items-start gap-3">
|
||||
<span className="grid h-9 w-9 shrink-0 place-items-center rounded-xl bg-violet-500/12 text-violet-300">
|
||||
<Bell className="h-4 w-4" />
|
||||
</span>
|
||||
<div>
|
||||
<h2 className="text-sm font-semibold uppercase tracking-wider text-slate-200">
|
||||
Benachrichtigungen
|
||||
</h2>
|
||||
<p className="mt-1 max-w-xl text-sm text-slate-400">
|
||||
Meldung bei fehlgeschlagenem Abgleich, roter CI oder neuem Release. Gemeldet
|
||||
wird nur bei einer <strong className="text-slate-300">Aenderung</strong> –
|
||||
nicht bei jedem Durchlauf.
|
||||
</p>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<button
|
||||
type="button"
|
||||
className="btn btn-ghost px-3 py-1.5 text-xs"
|
||||
onClick={() => {
|
||||
setEditing(null);
|
||||
setDialogOpen(true);
|
||||
}}
|
||||
>
|
||||
<Plus className="h-3.5 w-3.5" />
|
||||
Ziel hinzufuegen
|
||||
</button>
|
||||
</div>
|
||||
|
||||
{targets.length === 0 ? (
|
||||
<p className="rounded-xl border border-dashed border-white/8 px-4 py-6 text-center text-sm text-slate-500">
|
||||
Noch kein Ziel eingerichtet.
|
||||
</p>
|
||||
) : (
|
||||
<div className="space-y-2">
|
||||
{targets.map((entry) => {
|
||||
const meta = CHANNEL_META[entry.channel];
|
||||
const Icon = meta.icon;
|
||||
return (
|
||||
<div key={entry.id} className="glass-soft px-3 py-3">
|
||||
<div className="flex flex-wrap items-start justify-between gap-3">
|
||||
<div className="min-w-0 flex-1">
|
||||
<p className="flex flex-wrap items-center gap-2 text-sm text-slate-100">
|
||||
<Icon className="h-3.5 w-3.5 shrink-0 text-violet-300" />
|
||||
{entry.name}
|
||||
<span className="rounded bg-white/6 px-1.5 py-0.5 text-[10px] uppercase tracking-wider text-slate-400">
|
||||
{meta.label}
|
||||
</span>
|
||||
{!entry.isActive ? (
|
||||
<span className="rounded bg-slate-500/15 px-1.5 py-0.5 text-[10px] text-slate-400">
|
||||
pausiert
|
||||
</span>
|
||||
) : null}
|
||||
{entry.secretHint ? (
|
||||
<span className="inline-flex items-center gap-1 font-mono text-[10px] text-amber-300/70">
|
||||
<KeyRound className="h-2.5 w-2.5" />
|
||||
{entry.secretHint}
|
||||
</span>
|
||||
) : null}
|
||||
</p>
|
||||
<p className="mt-0.5 truncate font-mono text-[11px] text-slate-500">
|
||||
{entry.target}
|
||||
</p>
|
||||
<p className="mt-1.5 flex flex-wrap gap-1">
|
||||
{entry.events.map((event) => (
|
||||
<span
|
||||
key={event}
|
||||
className="rounded bg-white/6 px-1.5 py-0.5 text-[10px] text-slate-400"
|
||||
>
|
||||
{EVENT_META[event].emoji} {EVENT_META[event].label}
|
||||
</span>
|
||||
))}
|
||||
</p>
|
||||
{entry.lastSentAt ? (
|
||||
<p
|
||||
className={cn(
|
||||
"mt-1.5 flex items-center gap-1.5 text-[11px]",
|
||||
entry.lastOk ? "text-emerald-200/80" : "text-rose-200/80",
|
||||
)}
|
||||
suppressHydrationWarning
|
||||
>
|
||||
{entry.lastOk ? (
|
||||
<CheckCircle2 className="h-3 w-3" />
|
||||
) : (
|
||||
<XCircle className="h-3 w-3" />
|
||||
)}
|
||||
{formatRelative(entry.lastSentAt)} · {entry.lastMessage}
|
||||
</p>
|
||||
) : null}
|
||||
</div>
|
||||
|
||||
<div className="flex shrink-0 items-center gap-1">
|
||||
{busyId === entry.id ? (
|
||||
<Loader2 className="h-4 w-4 animate-spin text-slate-500" />
|
||||
) : (
|
||||
<>
|
||||
<button
|
||||
type="button"
|
||||
className="btn btn-ghost px-2.5 py-1.5 text-xs"
|
||||
onClick={() => test(entry)}
|
||||
>
|
||||
Testen
|
||||
</button>
|
||||
<button
|
||||
type="button"
|
||||
className="btn btn-ghost px-2.5 py-1.5 text-xs"
|
||||
onClick={() => toggle(entry)}
|
||||
title={entry.isActive ? "Pausieren" : "Fortsetzen"}
|
||||
>
|
||||
{entry.isActive ? "Pause" : "An"}
|
||||
</button>
|
||||
<button
|
||||
type="button"
|
||||
className="rounded-lg p-1.5 text-slate-500 transition-colors hover:bg-white/8 hover:text-violet-300"
|
||||
onClick={() => {
|
||||
setEditing(entry);
|
||||
setDialogOpen(true);
|
||||
}}
|
||||
aria-label="Bearbeiten"
|
||||
>
|
||||
<Pencil className="h-3.5 w-3.5" />
|
||||
</button>
|
||||
<button
|
||||
type="button"
|
||||
className="rounded-lg p-1.5 text-slate-500 transition-colors hover:bg-rose-500/12 hover:text-rose-300"
|
||||
onClick={() => remove(entry)}
|
||||
aria-label="Entfernen"
|
||||
>
|
||||
<Trash2 className="h-3.5 w-3.5" />
|
||||
</button>
|
||||
</>
|
||||
)}
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
})}
|
||||
</div>
|
||||
)}
|
||||
|
||||
{notice ? (
|
||||
<p
|
||||
className={cn(
|
||||
"mt-3 rounded-lg border px-3 py-2 text-sm",
|
||||
notice.ok
|
||||
? "border-emerald-500/30 bg-emerald-500/10 text-emerald-200"
|
||||
: "border-rose-500/30 bg-rose-500/10 text-rose-200",
|
||||
)}
|
||||
>
|
||||
{notice.text}
|
||||
</p>
|
||||
) : null}
|
||||
|
||||
{!emailAvailable ? (
|
||||
<p className="mt-3 text-[11px] text-slate-600">
|
||||
E-Mail steht nicht bereit: In der <code className="text-violet-300">.env</code> der
|
||||
Instanz fehlt <code className="text-violet-300">SMTP_HOST</code>. ntfy und Webhook
|
||||
funktionieren ohne weitere Einrichtung.
|
||||
</p>
|
||||
) : null}
|
||||
|
||||
<TargetDialog
|
||||
open={dialogOpen}
|
||||
entry={editing}
|
||||
emailAvailable={emailAvailable}
|
||||
onClose={() => {
|
||||
setDialogOpen(false);
|
||||
setEditing(null);
|
||||
}}
|
||||
/>
|
||||
</section>
|
||||
);
|
||||
}
|
||||
|
||||
function TargetDialog({
|
||||
open,
|
||||
entry,
|
||||
emailAvailable,
|
||||
onClose,
|
||||
}: {
|
||||
open: boolean;
|
||||
entry: NotificationTargetEntry | null;
|
||||
emailAvailable: boolean;
|
||||
onClose: () => void;
|
||||
}) {
|
||||
const router = useRouter();
|
||||
const [name, setName] = useState("");
|
||||
const [channel, setChannel] = useState<NotificationChannel>("NTFY");
|
||||
const [target, setTarget] = useState("");
|
||||
const [secret, setSecret] = useState("");
|
||||
const [events, setEvents] = useState<NotificationEvent[]>(["SYNC_FAILED", "CI_FAILED"]);
|
||||
const [busy, setBusy] = useState(false);
|
||||
const [error, setError] = useState<string | null>(null);
|
||||
const [fieldErrors, setFieldErrors] = useState<Record<string, string>>({});
|
||||
|
||||
const isEdit = Boolean(entry);
|
||||
|
||||
useEffect(() => {
|
||||
if (!open) return;
|
||||
setName(entry?.name ?? "");
|
||||
setChannel(entry?.channel ?? "NTFY");
|
||||
setTarget(entry?.target ?? "");
|
||||
setSecret("");
|
||||
setEvents(entry?.events ?? ["SYNC_FAILED", "CI_FAILED"]);
|
||||
setError(null);
|
||||
setFieldErrors({});
|
||||
}, [open, entry]);
|
||||
|
||||
async function submit(event: React.FormEvent) {
|
||||
event.preventDefault();
|
||||
setBusy(true);
|
||||
setError(null);
|
||||
setFieldErrors({});
|
||||
|
||||
const body: Record<string, unknown> = { name, target, events };
|
||||
if (!isEdit) body.channel = channel;
|
||||
if (!isEdit || secret.trim()) body.secret = secret;
|
||||
|
||||
try {
|
||||
const response = await fetch(
|
||||
isEdit ? `/api/notifications/${entry?.id}` : "/api/notifications",
|
||||
{
|
||||
method: isEdit ? "PATCH" : "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(body),
|
||||
},
|
||||
);
|
||||
const payload = await response.json().catch(() => ({}));
|
||||
if (!response.ok) {
|
||||
setFieldErrors(payload.fields ?? {});
|
||||
throw new Error(payload.error ?? "Speichern fehlgeschlagen.");
|
||||
}
|
||||
onClose();
|
||||
router.refresh();
|
||||
} catch (caught) {
|
||||
setError(caught instanceof Error ? caught.message : String(caught));
|
||||
} finally {
|
||||
setBusy(false);
|
||||
}
|
||||
}
|
||||
|
||||
const meta = CHANNEL_META[channel];
|
||||
|
||||
return (
|
||||
<Modal
|
||||
open={open}
|
||||
onClose={onClose}
|
||||
width="md"
|
||||
title={isEdit ? "Ziel bearbeiten" : "Neues Benachrichtigungsziel"}
|
||||
description={
|
||||
isEdit ? "Der Zustellweg selbst laesst sich nicht mehr aendern." : undefined
|
||||
}
|
||||
>
|
||||
<form onSubmit={submit} className="space-y-4">
|
||||
{!isEdit ? (
|
||||
<div>
|
||||
<span className="field-label">Weg</span>
|
||||
<div className="grid grid-cols-3 gap-2">
|
||||
{(Object.keys(CHANNEL_META) as NotificationChannel[]).map((value) => {
|
||||
const option = CHANNEL_META[value];
|
||||
const Icon = option.icon;
|
||||
const disabled = value === "EMAIL" && !emailAvailable;
|
||||
return (
|
||||
<button
|
||||
key={value}
|
||||
type="button"
|
||||
disabled={disabled}
|
||||
onClick={() => setChannel(value)}
|
||||
title={disabled ? "Kein SMTP in der .env hinterlegt" : undefined}
|
||||
className={cn(
|
||||
"rounded-xl border px-3 py-2.5 text-sm transition-all disabled:opacity-40",
|
||||
channel === value
|
||||
? "border-violet-400/60 bg-violet-500/12 text-white"
|
||||
: "border-white/9 text-slate-400 hover:border-white/20",
|
||||
)}
|
||||
>
|
||||
<span className="flex items-center justify-center gap-1.5">
|
||||
<Icon className="h-3.5 w-3.5" />
|
||||
{option.label}
|
||||
</span>
|
||||
</button>
|
||||
);
|
||||
})}
|
||||
</div>
|
||||
</div>
|
||||
) : null}
|
||||
|
||||
<div>
|
||||
<label className="field-label" htmlFor="notify-name">
|
||||
Name *
|
||||
</label>
|
||||
<input
|
||||
id="notify-name"
|
||||
className="field"
|
||||
value={name}
|
||||
onChange={(e) => setName(e.target.value)}
|
||||
placeholder="Handy"
|
||||
required
|
||||
maxLength={60}
|
||||
/>
|
||||
{fieldErrors.name ? (
|
||||
<p className="mt-1 text-xs text-rose-300">{fieldErrors.name}</p>
|
||||
) : null}
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<label className="field-label" htmlFor="notify-target">
|
||||
{channel === "EMAIL" ? "E-Mail-Adresse *" : "URL *"}
|
||||
</label>
|
||||
<input
|
||||
id="notify-target"
|
||||
className="field font-mono text-xs"
|
||||
value={target}
|
||||
onChange={(e) => setTarget(e.target.value)}
|
||||
placeholder={meta.placeholder}
|
||||
required
|
||||
/>
|
||||
<p className="mt-1 text-[11px] text-slate-500">{meta.hint}</p>
|
||||
{fieldErrors.target ? (
|
||||
<p className="mt-1 text-xs text-rose-300">{fieldErrors.target}</p>
|
||||
) : null}
|
||||
</div>
|
||||
|
||||
{channel !== "EMAIL" ? (
|
||||
<div>
|
||||
<label className="field-label" htmlFor="notify-secret">
|
||||
Geheimnis {isEdit ? "(leer = unveraendert)" : "(optional)"}
|
||||
</label>
|
||||
<input
|
||||
id="notify-secret"
|
||||
className="field font-mono text-xs"
|
||||
type="password"
|
||||
value={secret}
|
||||
onChange={(e) => setSecret(e.target.value)}
|
||||
autoComplete="off"
|
||||
placeholder={isEdit ? "••••••••" : ""}
|
||||
/>
|
||||
<p className="mt-1 text-[11px] text-slate-500">
|
||||
{channel === "NTFY"
|
||||
? "Wird als Bearer-Token gesendet – fuer geschuetzte Themen."
|
||||
: "Signiert den Rumpf per HMAC-SHA256 im Kopf X-Nebula-Signature."}
|
||||
</p>
|
||||
</div>
|
||||
) : null}
|
||||
|
||||
<div>
|
||||
<span className="field-label">Anlaesse *</span>
|
||||
<div className="space-y-1.5">
|
||||
{NOTIFICATION_EVENTS.map((event) => {
|
||||
const option = EVENT_META[event];
|
||||
const checked = events.includes(event);
|
||||
return (
|
||||
<label
|
||||
key={event}
|
||||
className="flex cursor-pointer items-start gap-2.5 rounded-lg border border-white/8 bg-black/20 px-3 py-2"
|
||||
>
|
||||
<input
|
||||
type="checkbox"
|
||||
checked={checked}
|
||||
onChange={(e) =>
|
||||
setEvents((current) =>
|
||||
e.target.checked
|
||||
? [...current, event]
|
||||
: current.filter((value) => value !== event),
|
||||
)
|
||||
}
|
||||
className="mt-0.5 h-4 w-4 accent-violet-500"
|
||||
/>
|
||||
<span>
|
||||
<span className="block text-sm text-slate-200">
|
||||
{option.emoji} {option.label}
|
||||
</span>
|
||||
<span className="mt-0.5 block text-[11px] text-slate-500">
|
||||
{option.description}
|
||||
</span>
|
||||
</span>
|
||||
</label>
|
||||
);
|
||||
})}
|
||||
</div>
|
||||
{fieldErrors.events ? (
|
||||
<p className="mt-1 text-xs text-rose-300">{fieldErrors.events}</p>
|
||||
) : null}
|
||||
</div>
|
||||
|
||||
{error ? (
|
||||
<p className="rounded-lg border border-rose-500/30 bg-rose-500/10 px-3 py-2 text-sm text-rose-200">
|
||||
{error}
|
||||
</p>
|
||||
) : null}
|
||||
|
||||
<div className="flex justify-end gap-2 pt-1">
|
||||
<button type="button" className="btn btn-ghost" onClick={onClose} disabled={busy}>
|
||||
Abbrechen
|
||||
</button>
|
||||
<button
|
||||
type="submit"
|
||||
className="btn btn-primary"
|
||||
disabled={busy || events.length === 0}
|
||||
>
|
||||
{busy ? <Loader2 className="h-4 w-4 animate-spin" /> : null}
|
||||
Speichern
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
</Modal>
|
||||
);
|
||||
}
|
||||
@@ -9,6 +9,7 @@ import {
|
||||
Download,
|
||||
Fingerprint,
|
||||
FolderGit2,
|
||||
Hourglass,
|
||||
Loader2,
|
||||
Lock,
|
||||
Plus,
|
||||
@@ -67,6 +68,12 @@ export interface AdminData {
|
||||
/** Projekte mit Repository, die grundsaetzlich in Frage kommen. */
|
||||
eligible: number;
|
||||
};
|
||||
stale: {
|
||||
afterDays: number;
|
||||
lastCheckAt: string | Date | null;
|
||||
/** Wie viele Konten ueberhaupt auf Stillstand hoeren. */
|
||||
listeners: number;
|
||||
};
|
||||
}
|
||||
|
||||
type Notice = { ok: boolean; text: string } | null;
|
||||
@@ -187,6 +194,7 @@ export function AdminManager({ data }: { data: AdminData }) {
|
||||
</section>
|
||||
|
||||
<AutoSyncSection data={data.autoSync} />
|
||||
<StaleSection data={data.stale} />
|
||||
|
||||
{/* ── Instanz ─────────────────────────────────────── */}
|
||||
<section className="glass p-5">
|
||||
@@ -574,6 +582,124 @@ function AutoSyncSection({ data }: { data: AdminData["autoSync"] }) {
|
||||
);
|
||||
}
|
||||
|
||||
const STALE_OPTIONS = [14, 30, 60, 90, 180, 365];
|
||||
|
||||
function StaleSection({ data }: { data: AdminData["stale"] }) {
|
||||
const router = useRouter();
|
||||
const [days, setDays] = useState(data.afterDays);
|
||||
const [busy, setBusy] = useState(false);
|
||||
const [notice, setNotice] = useState<Notice>(null);
|
||||
|
||||
async function save(value: number) {
|
||||
setBusy(true);
|
||||
setNotice(null);
|
||||
try {
|
||||
const response = await fetch("/api/admin/settings", {
|
||||
method: "PATCH",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify({ staleAfterDays: value }),
|
||||
});
|
||||
const body = await response.json().catch(() => ({}));
|
||||
if (!response.ok) throw new Error(body.error ?? "Speichern fehlgeschlagen.");
|
||||
setNotice({ ok: true, text: "Gespeichert." });
|
||||
router.refresh();
|
||||
} catch (caught) {
|
||||
setDays(data.afterDays);
|
||||
setNotice({ ok: false, text: caught instanceof Error ? caught.message : String(caught) });
|
||||
} finally {
|
||||
setBusy(false);
|
||||
}
|
||||
}
|
||||
|
||||
return (
|
||||
<section className="glass p-5">
|
||||
<div className="mb-4 flex items-start gap-3">
|
||||
<span className="grid h-9 w-9 shrink-0 place-items-center rounded-xl bg-amber-500/12 text-amber-300">
|
||||
<Hourglass className="h-4 w-4" />
|
||||
</span>
|
||||
<div>
|
||||
<h2 className="text-sm font-semibold uppercase tracking-wider text-slate-200">
|
||||
Stillstand
|
||||
</h2>
|
||||
<p className="mt-1 max-w-xl text-sm text-slate-400">
|
||||
Ab wann ein Projekt als eingeschlafen gilt. Massstab ist der letzte Commit im
|
||||
verknuepften Repository – das Aenderungsdatum taugt nicht, weil jeder Abgleich
|
||||
es anfasst. Projekte ohne Repository bleiben aussen vor, ebenso fertige und
|
||||
archivierte.
|
||||
</p>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div className="grid gap-4 sm:grid-cols-2">
|
||||
<div>
|
||||
<label className="field-label" htmlFor="stale-days">
|
||||
Schwelle
|
||||
</label>
|
||||
<select
|
||||
id="stale-days"
|
||||
className="field"
|
||||
value={days}
|
||||
disabled={busy}
|
||||
onChange={(event) => {
|
||||
const value = Number(event.target.value);
|
||||
setDays(value);
|
||||
void save(value);
|
||||
}}
|
||||
>
|
||||
{STALE_OPTIONS.map((value) => (
|
||||
<option key={value} value={value}>
|
||||
nach {value} Tagen ohne Commit
|
||||
</option>
|
||||
))}
|
||||
</select>
|
||||
</div>
|
||||
|
||||
<dl className="grid grid-cols-2 gap-3">
|
||||
<div className="glass-soft px-3 py-2.5">
|
||||
<dt className="text-[11px] uppercase tracking-wider text-slate-500">
|
||||
Letzte Pruefung
|
||||
</dt>
|
||||
<dd className="mt-1 text-sm text-slate-200" suppressHydrationWarning>
|
||||
{data.lastCheckAt ? formatRelative(data.lastCheckAt) : "noch keine"}
|
||||
</dd>
|
||||
</div>
|
||||
<div className="glass-soft px-3 py-2.5">
|
||||
<dt className="text-[11px] uppercase tracking-wider text-slate-500">
|
||||
Empfaenger
|
||||
</dt>
|
||||
<dd className="mt-1 text-sm tabular-nums text-slate-200">{data.listeners}</dd>
|
||||
</div>
|
||||
</dl>
|
||||
</div>
|
||||
|
||||
{data.listeners === 0 ? (
|
||||
<p className="mt-3 text-[11px] text-slate-600">
|
||||
Niemand hoert derzeit auf diesen Anlass – die Pruefung laeuft dann gar nicht
|
||||
erst. Einzurichten unter „Mein Konto → Benachrichtigungen“.
|
||||
</p>
|
||||
) : (
|
||||
<p className="mt-3 text-[11px] text-slate-600">
|
||||
Die Pruefung laeuft hoechstens einmal am Tag. Je Projekt wird einmal gemeldet;
|
||||
erneut erst, wenn danach wieder ein Commit kam und es wieder still wurde.
|
||||
</p>
|
||||
)}
|
||||
|
||||
{notice ? (
|
||||
<p
|
||||
className={cn(
|
||||
"mt-3 rounded-lg border px-3 py-2 text-sm",
|
||||
notice.ok
|
||||
? "border-emerald-500/30 bg-emerald-500/10 text-emerald-200"
|
||||
: "border-rose-500/30 bg-rose-500/10 text-rose-200",
|
||||
)}
|
||||
>
|
||||
{notice.text}
|
||||
</p>
|
||||
) : null}
|
||||
</section>
|
||||
);
|
||||
}
|
||||
|
||||
function ModeCard({
|
||||
active,
|
||||
disabled,
|
||||
|
||||
@@ -0,0 +1,61 @@
|
||||
import { describe, expect, it } from "vitest";
|
||||
import { daysSince, isStaleDue } from "./stale";
|
||||
|
||||
/**
|
||||
* Die Entscheidung, wann ein Projekt als eingeschlafen gilt – und vor allem,
|
||||
* wann es *nicht* erneut gemeldet wird.
|
||||
*/
|
||||
|
||||
const TAG = 86_400_000;
|
||||
const jetzt = new Date("2026-07-26T12:00:00Z");
|
||||
const vorTagen = (tage: number) => new Date(jetzt.getTime() - tage * TAG);
|
||||
/** Schwelle: 60 Tage. */
|
||||
const cutoff = vorTagen(60);
|
||||
|
||||
describe("isStaleDue", () => {
|
||||
it("meldet ein Projekt, dessen letzter Commit laenger zurueckliegt", () => {
|
||||
expect(isStaleDue({ notifiedStaleAt: null }, vorTagen(90), cutoff)).toBe(true);
|
||||
});
|
||||
|
||||
it("meldet nichts innerhalb der Frist", () => {
|
||||
expect(isStaleDue({ notifiedStaleAt: null }, vorTagen(30), cutoff)).toBe(false);
|
||||
});
|
||||
|
||||
it("meldet nichts genau an der Schwelle", () => {
|
||||
expect(isStaleDue({ notifiedStaleAt: null }, cutoff, cutoff)).toBe(false);
|
||||
});
|
||||
|
||||
it("meldet nichts ohne bekannten letzten Commit", () => {
|
||||
// Ein Projekt ohne Repository oder ohne Snapshot laesst sich nicht
|
||||
// beurteilen – lieber schweigen als raten.
|
||||
expect(isStaleDue({ notifiedStaleAt: null }, null, cutoff)).toBe(false);
|
||||
});
|
||||
|
||||
it("meldet dasselbe Projekt kein zweites Mal", () => {
|
||||
expect(isStaleDue({ notifiedStaleAt: vorTagen(5) }, vorTagen(90), cutoff)).toBe(false);
|
||||
});
|
||||
|
||||
it("meldet erneut, wenn zwischendurch gearbeitet wurde und es wieder still ist", () => {
|
||||
// Gemeldet vor 200 Tagen, danach ein Commit vor 90 Tagen, seitdem Ruhe.
|
||||
expect(isStaleDue({ notifiedStaleAt: vorTagen(200) }, vorTagen(90), cutoff)).toBe(true);
|
||||
});
|
||||
|
||||
it("meldet nicht erneut, wenn der Commit vor der letzten Meldung lag", () => {
|
||||
expect(isStaleDue({ notifiedStaleAt: vorTagen(10) }, vorTagen(90), cutoff)).toBe(false);
|
||||
});
|
||||
});
|
||||
|
||||
describe("daysSince", () => {
|
||||
it("zaehlt volle Tage", () => {
|
||||
expect(daysSince(vorTagen(60), jetzt)).toBe(60);
|
||||
expect(daysSince(vorTagen(1), jetzt)).toBe(1);
|
||||
});
|
||||
|
||||
it("rundet angebrochene Tage ab", () => {
|
||||
expect(daysSince(new Date(jetzt.getTime() - 1.9 * TAG), jetzt)).toBe(1);
|
||||
});
|
||||
|
||||
it("liefert null fuer soeben", () => {
|
||||
expect(daysSince(jetzt, jetzt)).toBe(0);
|
||||
});
|
||||
});
|
||||
@@ -0,0 +1,128 @@
|
||||
import type { Project, RepoSnapshot } from "@prisma/client";
|
||||
import { APP_URL } from "@/lib/config";
|
||||
import { prisma } from "@/lib/db";
|
||||
import { statusOf } from "@/lib/status";
|
||||
import { deliver } from "./channels";
|
||||
import { EVENT_META, type NotificationMessage } from "./types";
|
||||
|
||||
/**
|
||||
* Meldet Projekte, in denen laenger nichts passiert ist.
|
||||
*
|
||||
* Anders als die uebrigen Anlaesse haengt dieser an keinem Ereignis – es
|
||||
* passiert ja gerade nichts. Deshalb ein eigener Durchlauf, hoechstens
|
||||
* einmal am Tag.
|
||||
*
|
||||
* Massstab ist ausschliesslich der letzte Commit im verknuepften
|
||||
* Repository. Das Aenderungsdatum des Projekts taugt nicht: jeder Abgleich
|
||||
* fasst es an und wuerde den Stillstand immer wieder zuruecksetzen.
|
||||
* Projekte ohne Repository bleiben folglich aussen vor.
|
||||
*/
|
||||
|
||||
export interface StaleReport {
|
||||
at: string;
|
||||
checked: number;
|
||||
stale: number;
|
||||
notified: number;
|
||||
thresholdDays: number;
|
||||
}
|
||||
|
||||
/** Entscheidet, ob ein Projekt jetzt zu melden ist. */
|
||||
export function isStaleDue(
|
||||
project: Pick<Project, "notifiedStaleAt">,
|
||||
lastCommitAt: Date | null,
|
||||
cutoff: Date,
|
||||
): boolean {
|
||||
// Ohne bekannten letzten Commit gibt es nichts zu beurteilen.
|
||||
if (!lastCommitAt) return false;
|
||||
// Noch innerhalb der Frist.
|
||||
if (lastCommitAt >= cutoff) return false;
|
||||
// Noch nie gemeldet: jetzt.
|
||||
if (!project.notifiedStaleAt) return true;
|
||||
// Schon gemeldet – erneut nur, wenn danach wieder ein Commit kam und es
|
||||
// seitdem wieder still geworden ist.
|
||||
return lastCommitAt > project.notifiedStaleAt;
|
||||
}
|
||||
|
||||
/** Wie viele volle Tage seit dem letzten Commit vergangen sind. */
|
||||
export function daysSince(date: Date, now: Date = new Date()): number {
|
||||
return Math.floor((now.getTime() - date.getTime()) / 86_400_000);
|
||||
}
|
||||
|
||||
function message(
|
||||
project: Project,
|
||||
snapshot: RepoSnapshot | null,
|
||||
tage: number,
|
||||
): NotificationMessage {
|
||||
return {
|
||||
event: "PROJECT_STALE",
|
||||
title: `${EVENT_META.PROJECT_STALE.emoji} ${project.name}: seit ${tage} Tagen kein Commit`,
|
||||
body:
|
||||
`Der letzte Commit liegt ${tage} Tage zurueck. ` +
|
||||
`Status: ${statusOf(project.status).label}. Vielleicht abschliessen oder archivieren?`,
|
||||
priority: "normal",
|
||||
url: snapshot?.htmlUrl ?? `${APP_URL}/projects/${project.id}`,
|
||||
project: { id: project.id, name: project.name, slug: project.slug },
|
||||
at: new Date().toISOString(),
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Ein Durchlauf. Meldet je Projekt hoechstens einmal und schreibt den
|
||||
* Merkstand fort – auch dann, wenn niemand zuhoert.
|
||||
*/
|
||||
export async function runStaleCheck(thresholdDays: number): Promise<StaleReport> {
|
||||
const now = new Date();
|
||||
const cutoff = new Date(now.getTime() - thresholdDays * 86_400_000);
|
||||
|
||||
const kandidaten = await prisma.project.findMany({
|
||||
where: {
|
||||
// Fertige und archivierte Projekte duerfen ruhen.
|
||||
status: { notIn: ["DONE", "ARCHIVED"] },
|
||||
ownerId: { not: null },
|
||||
snapshot: { isNot: null },
|
||||
},
|
||||
include: { snapshot: true },
|
||||
});
|
||||
|
||||
const faellig = kandidaten.filter((project) =>
|
||||
isStaleDue(project, project.snapshot?.lastCommitAt ?? null, cutoff),
|
||||
);
|
||||
|
||||
let zugestellt = 0;
|
||||
|
||||
for (const project of faellig) {
|
||||
const lastCommitAt = project.snapshot?.lastCommitAt;
|
||||
if (!lastCommitAt || !project.ownerId) continue;
|
||||
|
||||
const ziele = await prisma.notificationTarget.findMany({
|
||||
where: { userId: project.ownerId, isActive: true, events: { has: "PROJECT_STALE" } },
|
||||
});
|
||||
|
||||
for (const ziel of ziele) {
|
||||
const ergebnis = await deliver(
|
||||
ziel,
|
||||
message(project, project.snapshot, daysSince(lastCommitAt, now)),
|
||||
);
|
||||
zugestellt += 1;
|
||||
await prisma.notificationTarget.update({
|
||||
where: { id: ziel.id },
|
||||
data: { lastSentAt: now, lastOk: ergebnis.ok, lastMessage: ergebnis.message },
|
||||
});
|
||||
}
|
||||
|
||||
// Auch ohne Ziel vermerken, sonst kaeme beim ersten eingerichteten Ziel
|
||||
// die gesamte Vergangenheit hinterher.
|
||||
await prisma.project.update({
|
||||
where: { id: project.id },
|
||||
data: { notifiedStaleAt: now },
|
||||
});
|
||||
}
|
||||
|
||||
return {
|
||||
at: now.toISOString(),
|
||||
checked: kandidaten.length,
|
||||
stale: faellig.length,
|
||||
notified: zugestellt,
|
||||
thresholdDays,
|
||||
};
|
||||
}
|
||||
@@ -5,6 +5,7 @@ export const NOTIFICATION_EVENTS: NotificationEvent[] = [
|
||||
"SYNC_FAILED",
|
||||
"CI_FAILED",
|
||||
"NEW_RELEASE",
|
||||
"PROJECT_STALE",
|
||||
];
|
||||
|
||||
export const EVENT_META: Record<
|
||||
@@ -26,6 +27,11 @@ export const EVENT_META: Record<
|
||||
description: "Im Repository ist ein neuer Tag oder ein Release aufgetaucht.",
|
||||
emoji: "🏷️",
|
||||
},
|
||||
PROJECT_STALE: {
|
||||
label: "Projekt steht still",
|
||||
description: "Seit laengerem kein Commit mehr. Die Schwelle setzt ein Administrator.",
|
||||
emoji: "🕸️",
|
||||
},
|
||||
};
|
||||
|
||||
/** Eine fertig formulierte Nachricht, unabhaengig vom Zustellweg. */
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import type { Prisma } from "@prisma/client";
|
||||
import { getAppSettings } from "@/lib/auth/settings";
|
||||
import { prisma } from "@/lib/db";
|
||||
import { runStaleCheck } from "@/lib/notify/stale";
|
||||
import { syncProject } from "@/lib/sync";
|
||||
|
||||
/**
|
||||
@@ -20,6 +21,8 @@ import { syncProject } from "@/lib/sync";
|
||||
*/
|
||||
|
||||
const TICK_MS = 60_000;
|
||||
/** Stillstand aendert sich langsam – einmal am Tag genuegt. */
|
||||
const STALE_CHECK_INTERVAL_MS = 24 * 60 * 60 * 1000;
|
||||
/** Kleine Verschnaufpause zwischen zwei Projekten. */
|
||||
const PAUSE_MS = 400;
|
||||
/** Hoechstens so lange wird nach Fehlschlaegen zurueckgehalten. */
|
||||
@@ -64,18 +67,54 @@ export function startAutoSyncScheduler() {
|
||||
async function tick() {
|
||||
try {
|
||||
const settings = await getAppSettings();
|
||||
if (!settings.autoSyncEnabled) return;
|
||||
|
||||
if (settings.autoSyncEnabled) {
|
||||
const intervalMs = Math.max(5, settings.autoSyncIntervalMinutes) * 60_000;
|
||||
const last = settings.lastAutoSyncAt?.getTime() ?? 0;
|
||||
if (Date.now() - last < intervalMs) return;
|
||||
|
||||
if (Date.now() - last >= intervalMs) {
|
||||
await runAutoSyncPass("zeitplan");
|
||||
}
|
||||
}
|
||||
|
||||
// Unabhaengig vom Abgleich: der Stillstand ergibt sich aus dem
|
||||
// gespeicherten Stand, dafuer muss nichts geholt werden.
|
||||
await maybeCheckStale();
|
||||
} catch (error) {
|
||||
console.error("[nebula] Automatischer Abgleich fehlgeschlagen:", error);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Stillstandspruefung, hoechstens einmal am Tag. Laeuft nur, wenn ueberhaupt
|
||||
* jemand darauf hoert – sonst waere es reine Datenbanklast.
|
||||
*/
|
||||
async function maybeCheckStale() {
|
||||
const settings = await getAppSettings();
|
||||
const last = settings.lastStaleCheckAt?.getTime() ?? 0;
|
||||
if (Date.now() - last < STALE_CHECK_INTERVAL_MS) return;
|
||||
|
||||
const zuhoerer = await prisma.notificationTarget.count({
|
||||
where: { isActive: true, events: { has: "PROJECT_STALE" } },
|
||||
});
|
||||
|
||||
// Zeitstempel auch ohne Zuhoerer setzen, damit nicht jede Minute gezaehlt
|
||||
// wird.
|
||||
await prisma.appSettings.update({
|
||||
where: { id: "singleton" },
|
||||
data: { lastStaleCheckAt: new Date() },
|
||||
});
|
||||
|
||||
if (zuhoerer === 0) return;
|
||||
|
||||
const report = await runStaleCheck(Math.max(1, settings.staleAfterDays));
|
||||
if (report.stale > 0) {
|
||||
console.log(
|
||||
`[nebula] Stillstand: ${report.stale} von ${report.checked} Projekten ` +
|
||||
`ueber ${report.thresholdDays} Tage ohne Commit, ${report.notified} Meldungen.`,
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Ein Durchlauf. Laeuft nie zweimal gleichzeitig – ein zweiter Aufruf
|
||||
* waehrend eines laufenden Durchlaufs bekommt null zurueck.
|
||||
|
||||
@@ -0,0 +1,72 @@
|
||||
import { describe, expect, it } from "vitest";
|
||||
import { NOTIFICATION_EVENTS } from "@/lib/notify/types";
|
||||
import { notificationTargetCreateSchema } from "./validation";
|
||||
|
||||
/**
|
||||
* Dieser Test entstand aus einem Fehler: beim Ergaenzen eines neuen
|
||||
* Anlasses war das Zod-Schema nicht mitgezogen worden, die API lehnte ihn
|
||||
* mit 422 ab. Die Liste steht an zwei Stellen – hier wird geprueft, dass
|
||||
* sie zusammenpassen.
|
||||
*/
|
||||
|
||||
const basis = {
|
||||
name: "Handy",
|
||||
channel: "NTFY" as const,
|
||||
target: "https://ntfy.sh/mein-thema",
|
||||
};
|
||||
|
||||
describe("notificationTargetCreateSchema", () => {
|
||||
it("kennt jeden Anlass, den die Oberflaeche anbietet", () => {
|
||||
for (const event of NOTIFICATION_EVENTS) {
|
||||
const ergebnis = notificationTargetCreateSchema.safeParse({
|
||||
...basis,
|
||||
events: [event],
|
||||
});
|
||||
expect(ergebnis.success, `Anlass ${event} wird abgelehnt`).toBe(true);
|
||||
}
|
||||
});
|
||||
|
||||
it("verlangt mindestens einen Anlass", () => {
|
||||
expect(notificationTargetCreateSchema.safeParse({ ...basis, events: [] }).success).toBe(
|
||||
false,
|
||||
);
|
||||
});
|
||||
|
||||
it("weist unbekannte Anlaesse ab", () => {
|
||||
expect(
|
||||
notificationTargetCreateSchema.safeParse({ ...basis, events: ["WAS_AUCH_IMMER"] })
|
||||
.success,
|
||||
).toBe(false);
|
||||
});
|
||||
|
||||
it("verlangt bei E-Mail eine Adresse, keine URL", () => {
|
||||
const alsUrl = notificationTargetCreateSchema.safeParse({
|
||||
name: "Post",
|
||||
channel: "EMAIL",
|
||||
target: "https://example.com",
|
||||
events: ["SYNC_FAILED"],
|
||||
});
|
||||
expect(alsUrl.success).toBe(false);
|
||||
|
||||
const alsAdresse = notificationTargetCreateSchema.safeParse({
|
||||
name: "Post",
|
||||
channel: "EMAIL",
|
||||
target: "ich@example.com",
|
||||
events: ["SYNC_FAILED"],
|
||||
});
|
||||
expect(alsAdresse.success).toBe(true);
|
||||
});
|
||||
|
||||
it("verlangt bei Webhook und ntfy eine http-URL", () => {
|
||||
for (const channel of ["WEBHOOK", "NTFY"] as const) {
|
||||
expect(
|
||||
notificationTargetCreateSchema.safeParse({
|
||||
name: "X",
|
||||
channel,
|
||||
target: "ich@example.com",
|
||||
events: ["SYNC_FAILED"],
|
||||
}).success,
|
||||
).toBe(false);
|
||||
}
|
||||
});
|
||||
});
|
||||
@@ -146,6 +146,8 @@ export const profileUpdateSchema = z.object({
|
||||
export const adminSettingsSchema = z.object({
|
||||
mode: z.enum(["SINGLE_USER", "MULTI_USER"]).optional(),
|
||||
allowRegistration: z.boolean().optional(),
|
||||
/** Ab wie vielen Tagen ohne Commit ein Projekt als stillstehend gilt. */
|
||||
staleAfterDays: z.coerce.number().int().min(7).max(365).optional(),
|
||||
autoSyncEnabled: z.boolean().optional(),
|
||||
/** Untergrenze 5 Minuten – haeufiger waere den Git-APIs gegenueber unfair. */
|
||||
autoSyncIntervalMinutes: z.coerce.number().int().min(5).max(10080).optional(),
|
||||
@@ -173,7 +175,7 @@ export const adminUserUpdateSchema = z.object({
|
||||
// ── Benachrichtigungen ───────────────────────────────────────
|
||||
|
||||
const CHANNELS = ["WEBHOOK", "NTFY", "EMAIL"] as const;
|
||||
const EVENTS = ["SYNC_FAILED", "CI_FAILED", "NEW_RELEASE"] as const;
|
||||
const EVENTS = ["SYNC_FAILED", "CI_FAILED", "NEW_RELEASE", "PROJECT_STALE"] as const;
|
||||
|
||||
export const notificationTargetCreateSchema = z
|
||||
.object({
|
||||
|
||||
Reference in New Issue
Block a user