technik: Aufrufe über ein Ereignis-Log zählen statt im Request

Bisher lief pro Seitenaufruf ein UPDATE press_releases SET hits = hits + 1 im
Request. Auf der über 1 GB großen Tabelle blockiert dieser Schreibzugriff,
sobald dort eine Schemaänderung läuft — die wartenden Requests belegten dabei
PHP-FPM-Worker und DB-Verbindungen, bis die ganze Seite stand.

Der Request schreibt jetzt nur noch in die kleine Append-Tabelle
press_release_events, und selbst dabei wird jeder Fehler geschluckt und
gemeldet: Ein Aufruf-Zähler darf eine Seite niemals langsamer oder kaputt
machen. Die Summierung in press_releases.hits übernimmt gebündelt der
Scheduler.

Der Fortschritt läuft über eine Wasserstandsmarke (höchste bereits verbuchte
Event-ID) statt über einen Zwischenspeicher, damit bei einem Neustart kein
Aufruf verloren geht. Zähler und Marke werden je Durchgang gemeinsam
committet — sonst wäre nur der Durchgang wiederanlaufsicher, nicht der Abbruch
darin, und der nächste Lauf verbuchte dieselben Aufrufe doppelt. Eine Migration
setzt die Marke beim Deploy auf den Ist-Stand; ohne sie würde der erste Lauf
den gesamten Altbestand ein zweites Mal aufaddieren.

Weil das Log damit mit dem Traffic wächst und als einzige Log-Tabelle des
Systems keine Bereinigung hatte, begrenzt press-releases:purge-events es auf
einen Aufbewahrungszeitraum (Default 395 Tage = 13 Monate, damit der
Vorjahresmonats-Vergleich möglich bleibt). Gelöscht wird ausschließlich
unterhalb der Wasserstandsmarke — alles darüber ist noch nicht in hits verbucht
und wäre sonst dauerhaft verloren. Fehlt die Marke, bricht der Lauf ab, statt
zu raten.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

tests/Feature/Web/PressReleaseTrackingTest.php

@@ -1,15 +1,18 @@
 <?php
 
+use App\Console\Commands\AggregatePressReleaseViews;
 use App\Enums\Portal;
 use App\Enums\PressReleaseEventType;
 use App\Enums\PressReleaseShareChannel;
 use App\Enums\PressReleaseStatus;
+use App\Models\AppSetting;
 use App\Models\Category;
 use App\Models\Company;
 use App\Models\PressRelease;
 use App\Models\PressReleaseEvent;
 use App\Models\User;
 use Database\Seeders\RolesAndPermissionsSeeder;
+use Illuminate\Support\Facades\Cache;
 use Livewire\Volt\Volt as LivewireVolt;
 use Tests\TestCase;
 
@@ -29,18 +32,120 @@ function trackingRelease(array $attributes = []): PressRelease
         ->create(array_merge(['slug' => 'tracking-pm', 'published_at' => now()->subDay()], $attributes));
 }
 
-test('release detail logs a view event alongside the hit counter', function () {
+test('release detail logs a view event without writing to the press release table', function () {
     /** @var TestCase $this */
     $release = trackingRelease(['hits' => 4]);
 
     $this->get('https://businessportal24.test/de/press-release/'.$release->slug)->assertSuccessful();
 
-    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(5);
-
     $event = PressReleaseEvent::query()->sole();
     expect($event->press_release_id)->toBe($release->id)
         ->and($event->type)->toBe(PressReleaseEventType::View)
         ->and($event->channel)->toBeNull();
+
+    // Der Request fasst press_releases NICHT an — ein blockierender
+    // Schreibzugriff auf die große Tabelle hat früher Worker gebunden.
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(4);
+
+    // Erst der Scheduler verbucht den Aufruf im Gesamtzähler.
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(5);
+});
+
+test('view aggregation is idempotent and does not double count', function () {
+    /** @var TestCase $this */
+    $release = trackingRelease(['hits' => 0]);
+    $url = 'https://businessportal24.test/de/press-release/'.$release->slug;
+
+    $this->get($url)->assertSuccessful();
+    $this->get($url)->assertSuccessful();
+
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(2);
+
+    // Zweiter Lauf ohne neue Ereignisse darf nichts verändern — die
+    // Wasserstandsmarke steht bereits hinter den verbuchten Aufrufen.
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(2);
+
+    // Ein weiterer Aufruf wird beim nächsten Lauf nachgetragen.
+    $this->get($url)->assertSuccessful();
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(3);
+});
+
+test('an existing hit count is never counted twice through the event log', function () {
+    /** @var TestCase $this */
+    $release = trackingRelease(['hits' => 1000]);
+
+    // Bestand: Ereignisse, die bereits in `hits` stecken.
+    PressReleaseEvent::factory()->count(5)->create([
+        'press_release_id' => $release->id,
+        'type' => PressReleaseEventType::View,
+    ]);
+
+    // Genau das tut die Migration beim Deploy: Marke auf den Ist-Stand.
+    AppSetting::setValue(
+        AggregatePressReleaseViews::WatermarkKey,
+        (int) PressReleaseEvent::query()->max('id'),
+    );
+
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(1000);
+
+    // Nur neue Aufrufe kommen hinzu.
+    $this->get('https://businessportal24.test/de/press-release/'.$release->slug)->assertSuccessful();
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(1001);
+});
+
+test('a missing watermark initialises instead of counting the backlog twice', function () {
+    /** @var TestCase $this */
+    $release = trackingRelease(['hits' => 1000]);
+
+    PressReleaseEvent::factory()->count(4)->create([
+        'press_release_id' => $release->id,
+        'type' => PressReleaseEventType::View,
+    ]);
+
+    // Zustand im Deploy-Fenster: Code läuft schon, Migration noch nicht —
+    // der Scheduler startet den Task ohne gesetzte Marke.
+    AppSetting::query()->whereKey(AggregatePressReleaseViews::WatermarkKey)->delete();
+    Cache::forget('app-setting.'.AggregatePressReleaseViews::WatermarkKey);
+
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
+    // Der Bestand darf NICHT ein zweites Mal aufaddiert werden.
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(1000);
+
+    // Ab jetzt zählt nur noch, was neu hinzukommt.
+    $this->get('https://businessportal24.test/de/press-release/'.$release->slug)->assertSuccessful();
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(1001);
+});
+
+test('view aggregation ignores share events and walks through in chunks', function () {
+    /** @var TestCase $this */
+    $release = trackingRelease(['hits' => 0]);
+
+    PressReleaseEvent::factory()->count(7)->create([
+        'press_release_id' => $release->id,
+        'type' => PressReleaseEventType::View,
+    ]);
+    PressReleaseEvent::factory()->count(3)->create([
+        'press_release_id' => $release->id,
+        'type' => PressReleaseEventType::Share,
+        'channel' => PressReleaseShareChannel::Email,
+    ]);
+
+    // Chunk kleiner als die Ereignismenge: erzwingt mehrere Durchgänge.
+    $this->artisan('press-releases:aggregate-views', ['--chunk' => 100])->assertSuccessful();
+
+    expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(7);
 });
 
 test('release detail shows the public view count', function () {

tests/Feature/Web/ReleaseDetailTest.php

@@ -354,6 +354,10 @@ test('release detail counts a hit', function () {
 
     $this->get('https://businessportal24.test/de/press-release/'.$release->slug)->assertSuccessful();
 
+    // Der Aufruf landet im Ereignis-Log; in den Gesamtzähler verbucht ihn der
+    // Scheduler, damit der Request die große Tabelle nicht beschreiben muss.
+    $this->artisan('press-releases:aggregate-views')->assertSuccessful();
+
     expect(PressRelease::withoutGlobalScopes()->find($release->id)->hits)->toBe(5);
 });