<?php

namespace App\Console\Commands;

use App\Models\ConversionEvent;
use App\Models\EmailBounce;
use Illuminate\Console\Command;

/**
 * Begrenzt die Ereignisse der Konversionsleiter auf den Aufbewahrungszeitraum
 * (Roadmap 0.7).
 *
 * Die Frist wurde zusammen mit der Tabelle festgelegt, nicht nachgetragen: 395
 * Tage, derselbe Horizont wie beim Aufruf-Ereignis-Log. Anders als dort gibt es
 * hier keine Wasserstandsmarke zu beachten — die Ereignisse werden nirgends
 * aufsummiert, sie SIND die Auswertung. Wer ältere Zeiträume vergleichen will,
 * muss den Report vorher laufen lassen und das Ergebnis festhalten.
 *
 * Mit aufgeräumt: die Rückläufer-Ereignisse (`email_bounces`, Adresse und
 * Diagnosetext) nach `bounces.retention_days` (Umsetzungsaudit 29.09.2026,
 * R-10). Die Sperrliste `email_suppressions` bleibt — sie ist der Zustand,
 * die Ereignisse sind nur seine Herleitung.
 */
class PurgeConversionEvents extends Command
{
    protected $signature = 'conversion:purge-events
        {--days= : Ereignisse älter als X Tage löschen (Standard: config conversion.events.retention_days)}
        {--chunk=5000 : Zeilen je Durchgang}
        {--dry-run : Nur zählen, nichts löschen}';

    protected $description = 'Begrenzt die Ereignisse der Konversionsleiter und die Rückläufer-Ereignisse (email_bounces) auf den Aufbewahrungszeitraum.';

    public function handle(): int
    {
        $days = (int) ($this->option('days') ?? config('conversion.events.retention_days'));

        if ($days < 1) {
            $this->error('Aufbewahrungszeitraum muss mindestens einen Tag betragen.');

            return self::FAILURE;
        }

        $cutoff = now()->subDays($days);
        $chunk = max(100, (int) $this->option('chunk'));

        $expired = ConversionEvent::query()->where('created_at', '<', $cutoff);

        $bounceDays = max(1, (int) config('bounces.retention_days', 395));
        $bounceCutoff = now()->subDays($bounceDays);
        $expiredBounces = EmailBounce::query()->where('created_at', '<', $bounceCutoff);

        if ($this->option('dry-run')) {
            $this->info(sprintf(
                '[Dry-Run] %d Ereignisse älter als %s.',
                (clone $expired)->count(),
                $cutoff->format('d.m.Y'),
            ));
            $this->info(sprintf(
                '[Dry-Run] %d Rückläufer-Ereignisse älter als %s.',
                (clone $expiredBounces)->count(),
                $bounceCutoff->format('d.m.Y'),
            ));

            return self::SUCCESS;
        }

        $deleted = 0;

        while (true) {
            $removed = (clone $expired)->limit($chunk)->delete();

            if ($removed === 0) {
                break;
            }

            $deleted += $removed;
        }

        $this->info(sprintf(
            'Konversions-Ereignisse bereinigt: %d Einträge vor dem %s gelöscht (Aufbewahrung %d Tage).',
            $deleted,
            $cutoff->format('d.m.Y'),
            $days,
        ));

        $bouncesDeleted = 0;

        while (true) {
            $removed = (clone $expiredBounces)->limit($chunk)->delete();

            if ($removed === 0) {
                break;
            }

            $bouncesDeleted += $removed;
        }

        $this->info(sprintf(
            'Rückläufer-Ereignisse bereinigt: %d Einträge vor dem %s gelöscht (Aufbewahrung %d Tage, Sperrliste bleibt).',
            $bouncesDeleted,
            $bounceCutoff->format('d.m.Y'),
            $bounceDays,
        ));

        return self::SUCCESS;
    }
}