padosoft / laravel-super-cache-invalidate

src/Console/PruneCacheInvalidationDataCommand.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         }
 
         // Build DROP PARTITION statement
-        $partitionNames = implode(', ', array_map(function ($partition) {
+        $partitionNames = implode(', ', array_map(function($partition) {
             return $partition->PARTITION_NAME;
         }, $partitions));
 

database/migrations/2024_11_20_200802_create_cache_invalidation_event_associations_table.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
         if (Schema::hasTable('cache_invalidation_event_associations')) {
             return;
         }
-        Schema::create('cache_invalidation_event_associations', function (Blueprint $table) {
+        Schema::create('cache_invalidation_event_associations', function(Blueprint $table) {
             //$table->bigIncrements('id');
             $table->bigInteger('id')->unsigned(); // Definiamo l'ID come bigInteger senza autoincrement sennò la primarykey multipla non funziona
             $table->unsignedBigInteger('event_id')->comment('Reference to cache_invalidation_events.id');

database/migrations/2024_11_20_200801_create_cache_invalidation_timestamps_table.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
         if (Schema::hasTable('cache_invalidation_timestamps')) {
             return;
         }
-        Schema::create('cache_invalidation_timestamps', function (Blueprint $table) {
+        Schema::create('cache_invalidation_timestamps', function(Blueprint $table) {
             $table->enum('identifier_type', ['key', 'tag'])->comment('Indicates whether the identifier is a cache key or tag');
             $table->string('identifier')->comment('The cache key or tag');
             $table->dateTime('last_invalidated')->comment('Timestamp of the last invalidation');

src/SuperCacheInvalidateServiceProvider.php

Spacing +5 added lines, -5 removed lines

@@ -16,16 +16,16 @@ 
     {
         // Merge package configuration
         $this->mergeConfigFrom(
-            __DIR__ . '/../config/super_cache_invalidate.php',
+            __DIR__.'/../config/super_cache_invalidate.php',
             'super_cache_invalidate'
         );
 
         // Register the helper as a singleton
-        $this->app->singleton(SuperCacheInvalidationHelper::class, function () {
+        $this->app->singleton(SuperCacheInvalidationHelper::class, function() {
             return new SuperCacheInvalidationHelper();
         });
 
-        $this->app->singleton('super_cache_invalidate', function () {
+        $this->app->singleton('super_cache_invalidate', function() {
             return new SuperCacheInvalidationHelper();
         });
     }
@@ -37,11 +37,11 @@ 
     {
         // Publish configuration
         $this->publishes([
-            __DIR__ . '/../config/super_cache_invalidate.php' => config_path('super_cache_invalidate.php'),
+            __DIR__.'/../config/super_cache_invalidate.php' => config_path('super_cache_invalidate.php'),
         ], 'config');
 
         // Publish migrations
-        $this->loadMigrationsFrom(__DIR__ . '/../database/migrations');
+        $this->loadMigrationsFrom(__DIR__.'/../database/migrations');
         // Register commands
         if ($this->app->runningInConsole()) {
             $this->commands([

database/migrations/2025_01_08_400999_create_cache_invalidation_events_table.php

Spacing +1 added lines, -1 removed lines

@@ -61,7 +61,7 @@
         // Per i siti in cui l'ho già creata (lvr, Santha, Pissei) la ricreo con le partizioni giuste
         Schema::dropIfExists('cache_invalidation_events');
 
-        Schema::create('cache_invalidation_events', function (Blueprint $table) {
+        Schema::create('cache_invalidation_events', function(Blueprint $table) {
             //$table->bigIncrements('id');
             $table->bigInteger('id')->unsigned(); // Definiamo l'ID come bigInteger senza autoincrement sennò la primarykey multipla non funziona
             $table->enum('type', ['key', 'tag'])->comment('Indicates whether the event is for a cache key or tag');

src/Helpers/SuperCacheInvalidationHelper.php

Spacing +5 added lines, -5 removed lines

@@ -93,11 +93,11 @@ 
             } catch (\Throwable $e) {
                 // DB::rollBack(); // Annulla la transazione in caso di errore
                 $attempts++;
-                Log::error("SuperCacheInvalidate: impossibile eseguire insert, tentativo $attempts di $maxAttempts: " . $e->getMessage());
+                Log::error("SuperCacheInvalidate: impossibile eseguire insert, tentativo $attempts di $maxAttempts: ".$e->getMessage());
                 // Logica per gestire i tentativi falliti
                 if ($attempts >= $maxAttempts) {
                     // Salta il record dopo il numero massimo di tentativi
-                    Log::error("SuperCacheInvalidate: impossibile eseguire insert dopo $maxAttempts tentativi: " . $e->getMessage());
+                    Log::error("SuperCacheInvalidate: impossibile eseguire insert dopo $maxAttempts tentativi: ".$e->getMessage());
                 }
             }
         }
@@ -111,9 +111,9 @@ 
      * @param  string       $connection_name The Redis Connection name
      * @return string|false The lock value if acquired, false otherwise
      */
-    public function acquireShardLock(int $shardId, int $priority, int $lockTimeout, string $connection_name): bool|string
+    public function acquireShardLock(int $shardId, int $priority, int $lockTimeout, string $connection_name): bool | string
     {
-        $lockKey = 'shard_lock:' . $shardId . '_' . $priority;
+        $lockKey = 'shard_lock:'.$shardId.'_'.$priority;
         // Il metodo has/exists occupa troppa memoria!!!
         $retrieveValue = Redis::connection($connection_name)->get($lockKey);
         if ($retrieveValue !== null) {
@@ -139,7 +139,7 @@ 
      */
     public function releaseShardLock(int $shardId, int $priority, string $lockValue, string $connection_name): void
     {
-        $lockKey = 'shard_lock:' . $shardId . '_' . $priority;
+        $lockKey = 'shard_lock:'.$shardId.'_'.$priority;
         $currentValue = Redis::connection($connection_name)->get($lockKey);
         if ($currentValue === $lockValue) {
             Redis::connection($connection_name)->del($lockKey);

database/migrations/2025_06_04_400978_add_column_to_cache_invalidation_events.php

Spacing +2 added lines, -2 removed lines

@@ -11,7 +11,7 @@ 
             return;
         }
 
-        Schema::table('cache_invalidation_events', function (Blueprint $table) {
+        Schema::table('cache_invalidation_events', function(Blueprint $table) {
             $table->char('batch_ID', 36)->nullable()->after('id');
         });
     }
@@ -24,7 +24,7 @@ 
         if (!Schema::hasColumn('cache_invalidation_events', 'batch_ID')) {
             return;
         }
-        Schema::table('cache_invalidation_events', function (Blueprint $table) {
+        Schema::table('cache_invalidation_events', function(Blueprint $table) {
             $table->dropColumn('batch_ID');
         });
     }

src/Console/ProcessCacheInvalidationEventsCommand.php

Spacing +15 added lines, -15 removed lines

@@ -75,7 +75,7 @@ 
         if (!$this->log_attivo && $level === 'info') {
             return;
         }
-        $this->$level(now()->toDateTimeString() . ' Shard[' . $this->shardId . '] Priority[' . $this->priority . '] Connection[' . $this->connection_name . '] : ' . PHP_EOL . $message);
+        $this->$level(now()->toDateTimeString().' Shard['.$this->shardId.'] Priority['.$this->priority.'] Connection['.$this->connection_name.'] : '.PHP_EOL.$message);
     }
 
     protected function processEvents(): void
@@ -83,7 +83,7 @@ 
         $processingStartTime = now();
         // Recupero gli eventi da invalidare
         $events = $this->getEventsToInvalidate($processingStartTime);
-        $this->logIf('Trovati ' . count($events) . ' Eventi da invalidare');
+        $this->logIf('Trovati '.count($events).' Eventi da invalidare');
         if (count($events) === 0) {
             return;
         }
@@ -92,7 +92,7 @@ 
         $unique_events = [];
 
         foreach ($events as $event) {
-            $key = $event->type . ':' . $event->identifier; // Chiave univoca per type + identifier
+            $key = $event->type.':'.$event->identifier; // Chiave univoca per type + identifier
             $event->event_time = \Illuminate\Support\Carbon::parse($event->event_time);
             // Quando la chiave non esiste o il nuovo valore ha un event_time più vecchio, lo sostituisco così a parità di tag ho sempre quello più vecchio e mi baso su quello per verificare la finestra
             if (!isset($unique_events[$key]) || $event->event_time <= $unique_events[$key]->event_time) {
@@ -102,12 +102,12 @@ 
 
         $unique_events = array_values($unique_events);
 
-        $this->logIf('Eventi unici ' . count($unique_events));
+        $this->logIf('Eventi unici '.count($unique_events));
         // Quando il numero di eventi unici è inferiore al batchSize e quello più vecchio aspetta da almeno due minuti, mando l'invalidazione.
         // Questo serve per i siti piccoli che hanno pochi eventi, altrimenti si rischia di attendere troppo per invalidare i tags
         // In questo caso invalido i tag/key "unici" e setto a processed = 1 tutti quelli recuperati
         if (count($unique_events) < $this->tagBatchSize && $processingStartTime->diffInSeconds($unique_events[0]->event_time) >= 120) {
-            $this->logIf('Il numero di eventi unici è inferiore al batchSize ( ' . $this->tagBatchSize . ' ) e sono passati più di due minuti, procedo');
+            $this->logIf('Il numero di eventi unici è inferiore al batchSize ( '.$this->tagBatchSize.' ) e sono passati più di due minuti, procedo');
             $this->processBatch($events, $unique_events);
 
             return;
@@ -127,7 +127,7 @@ 
             // altrimenti aggiungo l'evento a quelli da processare
             $eventsToUpdate[] = $event;
             // e recupero tutti gli ID che hanno quel tag/key
-            $eventsAll[] = array_filter($events, function ($event) use ($typeFilter, $identifierFilter) {
+            $eventsAll[] = array_filter($events, function($event) use ($typeFilter, $identifierFilter) {
                 return $event->type === $typeFilter && $event->identifier === $identifierFilter;
             });
         }
@@ -149,15 +149,15 @@ 
         foreach ($eventsToInvalidate as $item) {
             switch ($item->type) {
                 case 'key':
-                    $keys[] = $item->identifier . '§' . $item->connection_name;
+                    $keys[] = $item->identifier.'§'.$item->connection_name;
                     break;
                 case 'tag':
-                    $tags[] = $item->identifier . '§' . $item->connection_name;
+                    $tags[] = $item->identifier.'§'.$item->connection_name;
                     break;
             }
         }
 
-        $this->logIf('Invalido ' . count($keys) . ' chiavi e ' . count($tags) . ' tags' . ' per un totale di ' . count($allEvents) . ' events_ID');
+        $this->logIf('Invalido '.count($keys).' chiavi e '.count($tags).' tags'.' per un totale di '.count($allEvents).' events_ID');
 
         if (!empty($keys)) {
             $this->invalidateKeys($keys);
@@ -165,7 +165,7 @@ 
 
         if (!empty($tags)) {
             // Escludo i tag fullpage
-            $tags = array_filter($tags, function ($item) {
+            $tags = array_filter($tags, function($item) {
                 return !str_contains($item, 'fullpage');
             });
             $this->invalidateTags($tags);
@@ -209,7 +209,7 @@ 
                 continue;
             }
             // oppure di default uso Laravel
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
 
             if ($storeName === null) {
                 continue;
@@ -246,7 +246,7 @@ 
             return;
         }
         foreach ($groupByConnection as $connection_name => $arrTags) {
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
             if ($storeName === null) {
                 continue;
             }
@@ -267,13 +267,13 @@ 
         $tagBatchSize = $this->option('tag-batch-size') ?? config('super_cache_invalidate.tag_batch_size');
         $this->tagBatchSize = (int) $tagBatchSize;
         $this->connection_name = $this->option('connection_name') ?? config('super_cache_invalidate.default_connection_name');
-        $this->log_attivo = $this->option('log_attivo') && (int)$this->option('log_attivo') === 1;
+        $this->log_attivo = $this->option('log_attivo') && (int) $this->option('log_attivo') === 1;
         $this->invalidation_window = (int) config('super_cache_invalidate.invalidation_window');
         $lockTimeout = (int) config('super_cache_invalidate.lock_timeout');
 
         // Acquisisco il lock in modo da essere sicura che le esecuzioni non si accavallino
         // $lockValue = $this->helper->acquireShardLock($this->shardId, $this->priority, $lockTimeout, $this->connection_name);
-        $this->logIf('Starting Elaborazione ...' . $this->invalidation_window);
+        $this->logIf('Starting Elaborazione ...'.$this->invalidation_window);
         // if (!$lockValue) {
         //    return;
         // }
@@ -290,6 +290,6 @@ 
             ), 'error');
         }
         $executionTime = (microtime(true) - $startTime) * 1000;
-        $this->logIf('Fine Elaborazione - Tempo di esecuzione: ' . $executionTime . ' millisec.');
+        $this->logIf('Fine Elaborazione - Tempo di esecuzione: '.$executionTime.' millisec.');
     }
 }