3aaf6aea54
Der Codeberg-Sync liest nun Issues aus mehreren konfigurierbaren Projekten (Config::codebergRepos(), Default: fds2610/monitor gelb, fds2610/Steuerkram gruen, fds2610/nc-gantt blau) statt nur aus einem einzigen Repo. Damit external_ref (Issue-Nummer) projektuebergreifend nicht kollidiert, ist es jetzt zusammen mit dem neuen Ticket-Feld "repo" eindeutig; Migration 002_multi_repo_tickets.sql ergaenzt die Spalte und den Index. Da Migrationen dadurch nicht mehr rein additiv sind, trackt Database::migrate() jetzt angewandte Dateien in schema_migrations, damit ALTER TABLE nicht bei jedem Prozessstart erneut laeuft. Das Frontend baut Codeberg-Links jetzt aus dem repo-Feld jedes Tickets statt aus einer global fixen owner/repo-Angabe. Schliesst #26
71 lines
2.5 KiB
PHP
Executable file
71 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\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),
|
|
$config->codebergRepos(),
|
|
);
|
|
|
|
// 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);
|
|
}
|