padosoft / laravel-super-cache-invalidate

src/Console/ProcessCacheInvalidationEventsCommand.php

Spacing +14 added lines, -14 removed lines

@@ -72,7 +72,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
@@ -80,7 +80,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;
         }
@@ -89,7 +89,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) {
@@ -99,12 +99,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;
@@ -124,7 +124,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;
             });
         }
@@ -143,15 +143,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);
@@ -196,7 +196,7 @@ 
                 continue;
             }
             // oppure di default uso Laravel
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
 
             if ($storeName === null) {
                 continue;
@@ -233,7 +233,7 @@ 
             return;
         }
         foreach ($groupByConnection as $connection_name => $arrTags) {
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
             if ($storeName === null) {
                 continue;
             }
@@ -254,13 +254,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;
         //}
@@ -279,6 +279,6 @@ 
             // $this->helper->releaseShardLock($this->shardId, $this->priority, $lockValue, $this->connection_name);
         }
         $executionTime = (microtime(true) - $startTime) * 1000;
-        $this->logIf('Fine Elaborazione - Tempo di esecuzione: ' . $executionTime . ' millisec.');
+        $this->logIf('Fine Elaborazione - Tempo di esecuzione: '.$executionTime.' millisec.');
     }
 }