padosoft / laravel-super-cache-invalidate

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()->index()->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 +14 added lines, -14 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);
@@ -205,7 +205,7 @@ 
                 continue;
             }
             // oppure di default uso Laravel
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
 
             if ($storeName === null) {
                 continue;
@@ -242,7 +242,7 @@ 
             return;
         }
         foreach ($groupByConnection as $connection_name => $arrTags) {
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
             if ($storeName === null) {
                 continue;
             }
@@ -263,13 +263,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;
         // }
@@ -286,6 +286,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.');
     }
 }