<?php

namespace App\Console\Commands;

use App\Models\StripeWebhookEvent;
use App\Services\Payment\Stripe\StripeWebhookHandler;
use Illuminate\Console\Command;

/**
 * Verarbeitet gespeicherte, aber noch unverarbeitete Stripe-Webhook-Events nach
 * (Plan dev/2026-07-08-stripe/, S6.4 vorgezogen in S4).
 *
 * Hintergrund: Der Abo-Cron bucht innerhalb einer DB-Transaktion ab — der Webhook
 * kann den Commit überholen und wird dann mit 503 beantwortet. In Produktion
 * stellt Stripe non-2xx erneut zu (mit Verzögerung), die Stripe CLI auf dem
 * Test-Server jedoch nicht. Dieses Command schließt beide Lücken: es läuft am
 * Ende des Abo-Crons und regelmäßig über den Scheduler.
 */
class StripeProcessPendingEvents extends Command
{
    protected $signature = 'stripe:process-pending-events
        {--event= : Nur dieses eine Event (event_id) nachverarbeiten}';

    protected $description = 'Verarbeitet gespeicherte, unverarbeitete Stripe-Webhook-Events nach (z. B. nach Cron-Race oder verpasstem Retry)';

    public function handle(StripeWebhookHandler $webhookHandler): int
    {
        $query = StripeWebhookEvent::whereNull('processed_at')
            ->whereIn('type', StripeWebhookHandler::HANDLED_TYPES)
            ->orderBy('id');

        if ($this->option('event')) {
            $query->where('event_id', $this->option('event'));
        }

        $pending = $query->get();

        if ($pending->isEmpty()) {
            $this->info('Keine unverarbeiteten Stripe-Events.');

            return self::SUCCESS;
        }

        $processed = 0;
        $skipped = 0;

        foreach ($pending as $storedEvent) {
            try {
                if ($webhookHandler->processStoredEvent($storedEvent)) {
                    $processed++;
                    $this->info("Verarbeitet: {$storedEvent->event_id} ({$storedEvent->type})");
                } else {
                    $skipped++;
                    $this->warn("Weiterhin nicht zuordenbar: {$storedEvent->event_id} ({$storedEvent->type})");
                }
            } catch (\Throwable $e) {
                $skipped++;
                $this->error("Fehler bei {$storedEvent->event_id}: {$e->getMessage()}");
                \Log::channel('stripe')->error('stripe:process-pending-events fehlgeschlagen', [
                    'event_id' => $storedEvent->event_id,
                    'type' => $storedEvent->type,
                    'error' => $e->getMessage(),
                ]);
            }
        }

        \Log::channel('stripe')->info("stripe:process-pending-events: {$processed} verarbeitet, {$skipped} übersprungen.");
        $this->info("Fertig: {$processed} verarbeitet, {$skipped} übersprungen.");

        return self::SUCCESS;
    }
}