d72c945a61
Klick auf den PO oeffnet ein Modal, in dem sich die Projekte (Owner/Repo + Farbe), aus denen der Codeberg-Sync liest, hinzufuegen, bearbeiten und loeschen lassen - Icon-Schaltflaechen mit Tooltip statt Textbuttons. Die Projektliste war bisher eine Umgebungsvariable (CODEBERG_REPOS, Issue #26) und wandert dafuer in eine neue Tabelle repo_configs (Migration 003_repo_configs.sql, geseedet mit den bisherigen drei Default-Projekten); CodebergSyncService liest sie ueber RepoConfigRepository bei jedem Lauf frisch ein, damit eine Aenderung im laufenden --watch-Prozess ohne Neustart wirkt. Neue Endpunkte GET/POST/PATCH/DELETE /api/v1/repo-configs, Schreiben hinter X-Admin-Key wie die Agenten-Registrierung; das Frontend fragt den Key bei der ersten Aenderung per Prompt ab und merkt ihn sich im lokalen Speicher. office-modal.js bekommt dafuer einen Oeffnen-Token (isCurrentModal()), damit ein verspaetet aufloesender Request nach dem Oeffnen eines anderen Modals nicht dessen Inhalt ueberschreibt. Schliesst #27
72 lines
2.5 KiB
PHP
Executable file
72 lines
2.5 KiB
PHP
Executable file
#!/usr/bin/env php
|
|
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
use Monitor\Api\Config;
|
|
use Monitor\Api\Db\Database;
|
|
use Monitor\Api\Repository\RepoConfigRepository;
|
|
use Monitor\Api\Repository\TicketRepository;
|
|
use Monitor\Api\Sync\CodebergSyncService;
|
|
use Monitor\Api\Sync\CurlCodebergClient;
|
|
use Monitor\Api\Sync\SyncSchedule;
|
|
use Monitor\Api\Sync\SyncTrigger;
|
|
|
|
require dirname(__DIR__) . '/vendor/autoload.php';
|
|
|
|
$config = Config::fromEnvironment();
|
|
$db = Database::forFile($config->dbPath());
|
|
|
|
$service = new CodebergSyncService(
|
|
new CurlCodebergClient($config->codebergApiBase(), $config->codebergToken()),
|
|
new TicketRepository($db),
|
|
new RepoConfigRepository($db),
|
|
);
|
|
|
|
// Ohne --watch bleibt das Skript ein einmaliger Lauf (manueller Aufruf, siehe README).
|
|
if (!in_array('--watch', $argv, true)) {
|
|
$service->sync();
|
|
fwrite(STDOUT, "Codeberg-Sync abgeschlossen.\n");
|
|
|
|
return;
|
|
}
|
|
|
|
$trigger = new SyncTrigger($config->syncTriggerPath());
|
|
$interval = $config->syncIntervalSeconds();
|
|
$schedule = new SyncSchedule($interval);
|
|
|
|
fwrite(STDOUT, sprintf("[sync] Watch-Modus, periodischer Lauf alle %ds, Webhook-Trigger sofort.\n", $interval));
|
|
|
|
$lastRun = 0;
|
|
$failures = 0;
|
|
while (true) {
|
|
$triggered = $trigger->consume();
|
|
$due = (time() - $lastRun) >= $schedule->secondsUntilNextRun($failures);
|
|
|
|
if ($triggered || $due) {
|
|
$lastRun = time();
|
|
try {
|
|
$service->sync();
|
|
$failures = 0;
|
|
fwrite(STDOUT, sprintf("[sync] Lauf beendet (%s).\n", $triggered ? 'Webhook' : 'periodisch'));
|
|
} catch (Throwable $e) {
|
|
// Ein fehlgeschlagener Lauf (Codeberg nicht erreichbar, Rate-Limit) darf die
|
|
// Schleife nicht beenden, sonst landet der Container in einer Restart-Schleife.
|
|
// Stattdessen wird der naechste Versuch vorgezogen (siehe SyncSchedule) - eine
|
|
// per Webhook angeforderte Aktualisierung ist sonst verloren, weil die
|
|
// Anforderung vor dem Lauf quittiert wurde.
|
|
$failures++;
|
|
fwrite(STDERR, sprintf(
|
|
"[sync] Lauf fehlgeschlagen (%dx in Folge, naechster Versuch in %ds): %s\n",
|
|
$failures,
|
|
$schedule->secondsUntilNextRun($failures),
|
|
$e->getMessage()
|
|
));
|
|
}
|
|
}
|
|
|
|
// Sekundentakt: bestimmt, wie schnell ein Webhook-Trigger bemerkt wird. Der Check ist
|
|
// ein file_exists() auf einem lokalen Volume, kostet also praktisch nichts - im
|
|
// Gegensatz zum Codeberg-Request, der weiterhin nur bei Bedarf laeuft.
|
|
sleep(1);
|
|
}
|