Ataulização em migrations - correção de Erros | criação de Job para limpar tabela de Events

Author: wallacemartinss

.env.example

@@ -74,3 +74,5 @@ CASHIER_CURRENCY_LOCALE=br
 STRIPE_KEY=
 STRIPE_SECRET=
 STRIPE_WEBHOOK_SECRET=
+STRIPE_DEVICE_NAME=
+

Dockerfile

@@ -24,7 +24,7 @@ RUN apt-get clean && rm -rf /var/lib/apt/lists/*
 # Add Node.js repository and install Node.js & NPM
 RUN curl -fsSL https://deb.nodesource.com/setup_20.x | bash - && \
     apt-get install -y nodejs && \
-    npm install -g npm@latest 
+    npm install -g npm@latest
 
 # Install PHP extensions
 RUN docker-php-ext-install pdo_mysql mbstring exif pcntl bcmath gd sockets intl zip

app/Console/Commands/CleanWebhookEvents.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Jobs\CleanWebhookEventsJob;
+use Illuminate\Console\Command;
+
+class CleanWebhookEvents extends Command
+{
+    protected $signature = 'webhook:clean';
+    protected $description = 'Limpar registros antigos da tabela webhook_events com base no período de retenção';
+
+    public function handle()
+    {
+        $retentionPeriod = config('webhook-events.retention_period');
+
+        CleanWebhookEventsJob::dispatch($retentionPeriod);
+
+        $this->info("Job de limpeza de eventos de webhook enfileirada com sucesso para registros mais antigos que {$retentionPeriod} dias.");
+    }
+}

app/Console/Kernel.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace App\Console;
+
+use App\Console\Commands\CleanWebhookEvents;
+use Illuminate\Console\Scheduling\Schedule;
+use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
+
+class Kernel extends ConsoleKernel
+{
+    protected function schedule(Schedule $schedule)
+    {
+        // Carrega as configurações de agendamento
+        $scheduleConfig = config('webhook-events.schedule');
+        $time = $scheduleConfig['time'];
+
+        // Verifica o tipo de agendamento
+        switch ($scheduleConfig['type']) {
+            case 'daily':
+                // Agendamento diário
+                $schedule->command(CleanWebhookEvents::class)->dailyAt($time);
+                break;
+
+            case 'weekly_on':
+                // Agendamento semanal
+                $schedule->command(CleanWebhookEvents::class)->weeklyOn(
+                    $this->dayOfWeekToInteger($scheduleConfig['weekly_day']), // Chama o método aqui
+                    $time
+                );
+                break;
+
+            default:
+                // Caso o tipo de agendamento não seja válido
+                throw new \InvalidArgumentException("Tipo de agendamento inválido: {$scheduleConfig['type']}");
+        }
+    }
+
+    /**
+     * Converte o dia da semana em string para o valor inteiro correspondente.
+     *
+     * @param string $day
+     * @return int
+     */
+    private function dayOfWeekToInteger(string $day): int
+    {
+        $days = [
+            'Sunday' => 0,
+            'Monday' => 1,
+            'Tuesday' => 2,
+            'Wednesday' => 3,
+            'Thursday' => 4,
+            'Friday' => 5,
+            'Saturday' => 6,
+        ];
+
+        // Retorna o valor correspondente ou lança uma exceção se o dia for inválido
+        return $days[$day] ?? throw new \InvalidArgumentException("Dia da semana inválido: {$day}");
+    }
+
+    protected function commands()
+    {
+        $this->load(__DIR__ . '/Commands');
+    }
+}

app/Jobs/CleanWebhookEventsJob.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Jobs;
+
+use Carbon\Carbon;
+use App\Models\WebhookEvent;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Foundation\Queue\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+
+class CleanWebhookEventsJob implements ShouldQueue
+{
+    use Queueable, InteractsWithQueue, SerializesModels, Dispatchable;
+
+    private int $retentionPeriod;
+
+    /**
+     * Create a new job instance.
+     *
+     * @param int $retentionPeriod
+     */
+    public function __construct(int $retentionPeriod)
+    {
+        $this->retentionPeriod = $retentionPeriod;
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle()
+    {
+        Log::info("CleanWebhookEventsJob iniciado.");
+
+        // Calcula a data limite com base no período de retenção
+        $dateLimit = Carbon::now()->subDays($this->retentionPeriod);
+
+        // Exclui os eventos mais antigos que a data limite
+        $deletedCount = WebhookEvent::where('created_at', '<', $dateLimit)->delete();
+
+        Log::info("{$deletedCount} registros excluídos.");
+
+        // Log para auditoria (opcional)
+        Log::info("{$deletedCount} registros de webhook mais antigos que {$this->retentionPeriod} dias foram excluídos.");
+    }
+}

app/Models/WebhookEvent.php

@@ -14,6 +14,7 @@ class WebhookEvent extends Model
         'payload',
         'status',
         'received_at',
+        'created_at',
     ];
 
 

config/webhook-events.php

@@ -0,0 +1,14 @@
+<?php
+
+return [
+    // Período de retenção para limpar registros de webhook
+    'retention_period' => 1,  // Em dias, por exemplo 2 dias
+
+    // Configuração de agendamento para o comando de limpeza
+    'schedule' => [
+        'type' => 'daily',   // Tipo de agendamento: 'daily' ou 'weekly_on'
+        'time' => '15:33',   // Hora específica para o agendamento diário
+        // Para o agendamento semanal, você pode adicionar o dia da semana
+        // 'weekly_day' => 'Sunday',  // Exemplo para agendar no domingo
+    ],
+];

database/migrations/2025_01_08_144505_create_subscriptions_table.php

@@ -46,7 +46,7 @@ public function up(): void
 
         Schema::create('subscription_refunds', function (Blueprint $table) {
             $table->id();
-            $table->foreignId(Organization::class)->constrained()->cascadeOnDelete();
+            $table->foreignIdFor(Organization::class)->constrained()->cascadeOnDelete();
             $table->foreignIdFor(Subscription::class);
             $table->string('object')->default('refund');
             $table->string('refund_id')->nullable();
@@ -57,7 +57,7 @@ public function up(): void
             $table->string('reason');
             $table->timestamps();
 
-            $table->index(['organization_id', 'subscription_id', 'refund_id']);
+            $table->index(['organization_id', 'subscription_id']);
         });
 
         Schema::create('subscription_cancellations', function (Blueprint $table) {
@@ -69,7 +69,7 @@ public function up(): void
             $table->string('rating')->default('other');
             $table->timestamps();
 
-            $table->index(['organization_id', 'stripe_id', 'reason']);
+            $table->index(['organization_id', 'stripe_id']);
         });
 
     }

database/migrations/2025_01_16_142454_create_subscription_cancellations_table.php

@@ -25,11 +25,11 @@ services:
         uid: ${UID:-1000}
       dockerfile: Dockerfile
     restart: always
-    command: "php artisan queue:work"
+    command: ["php", "artisan", "queue:work", "--sleep=3", "--tries=3"]
     volumes:
       - ./:/var/www
     depends_on:
-      - redis
+      - mysql
     networks:
       - tenant