padosoft / laravel-super-cache-invalidate

src/Console/ProcessCacheInvalidationEventsCommand.php

Spacing +15 added lines, -15 removed lines

@@ -122,8 +122,8 @@ 
         }
 
         // Group events by type and identifier
-        $eventsByIdentifier = $events->groupBy(function ($event) {
-            return $event->type . ':' . $event->identifier;
+        $eventsByIdentifier = $events->groupBy(function($event) {
+            return $event->type.':'.$event->identifier;
         });
 
         $batchIdentifiers = [];
@@ -148,7 +148,7 @@ 
             foreach ($eventsGroup as $event) {
                 $eventAssociations = $associations->where('event_id', '=', $event->id);
                 foreach ($eventAssociations as $assoc) {
-                    $assocKey = $assoc->associated_type . ':' . $assoc->associated_identifier;
+                    $assocKey = $assoc->associated_type.':'.$assoc->associated_identifier;
                     $allIdentifiers[] = $assocKey;
                 }
             }
@@ -165,7 +165,7 @@ 
             foreach ($eventsGroup as $event) {
                 $eventAssociations = $associations->where('event_id', '=', $event->id);
                 foreach ($eventAssociations as $assoc) {
-                    $assocKey = $assoc->associated_type . ':' . $assoc->associated_identifier;
+                    $assocKey = $assoc->associated_type.':'.$assoc->associated_identifier;
                     $associatedIdentifiers[$assocKey] = [
                         'type' => $assoc->associated_type,
                         'identifier' => $assoc->associated_identifier,
@@ -240,7 +240,7 @@ 
     protected function getLastInvalidationTimes(array $identifiers): array
     {
         // Extract types and identifiers into tuples
-        $tuples = array_map(static function ($key) {
+        $tuples = array_map(static function($key) {
             return explode(':', $key, 2);
         }, $identifiers);
 
@@ -253,7 +253,7 @@ 
         // Build associative array
         $lastInvalidationTimes = [];
         foreach ($records as $record) {
-            $key = $record->identifier_type . ':' . $record->identifier;
+            $key = $record->identifier_type.':'.$record->identifier;
             $lastInvalidationTimes[$key] = Carbon::parse($record->last_invalidated);
         }
 
@@ -356,10 +356,10 @@ 
                 foreach ($batchIdentifiers 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;
                     }
 
@@ -371,10 +371,10 @@ 
                     foreach ($item['associated'] as $assoc) {
                         switch ($assoc['type']) {
                             case 'key':
-                                $keys[] = $assoc['identifier'] . '§' . $assoc['connection_name'];
+                                $keys[] = $assoc['identifier'].'§'.$assoc['connection_name'];
                                 break;
                             case 'tag':
-                                $tags[] = $assoc['identifier'] . '§' . $assoc['connection_name'];
+                                $tags[] = $assoc['identifier'].'§'.$assoc['connection_name'];
                                 break;
                         }
                     }
@@ -438,7 +438,7 @@ 
             }
 
             // oppure di default uso Laravel
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
 
             if ($storeName === null) {
                 return;
@@ -475,7 +475,7 @@ 
             return;
         }
         foreach ($groupByConnection as $connection_name => $arrTags) {
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
             if ($storeName === null) {
                 return;
             }
@@ -491,9 +491,9 @@ 
         $shardId = (int) $this->option('shard');
         $priority = (int) $this->option('priority');
         $limit = $this->option('limit') ?? config('super_cache_invalidate.processing_limit');
-        $limit = (int)$limit;
+        $limit = (int) $limit;
         $tagBatchSize = $this->option('tag-batch-size') ?? config('super_cache_invalidate.tag_batch_size');
-        $tagBatchSize = (int)$tagBatchSize;
+        $tagBatchSize = (int) $tagBatchSize;
         $lockTimeout = (int) config('super_cache_invalidate.lock_timeout');
         $connection_name = $this->option('connection_name') ?? config('super_cache_invalidate.default_connection_name');
         /*
@@ -512,7 +512,7 @@ 
         try {
             $this->processEvents($shardId, $priority, $limit, $tagBatchSize, $connection_name);
         } catch (\Throwable $e) {
-            $this->error('Si è verificato un errore in ' . __METHOD__ . ': ' . $e->getMessage());
+            $this->error('Si è verificato un errore in '.__METHOD__.': '.$e->getMessage());
         } finally {
             $this->helper->releaseShardLock($shardId, $priority, $lockValue, $connection_name);
         }

src/Helpers/SuperCacheInvalidationHelper.php

Spacing +4 added lines, -4 removed lines

@@ -75,7 +75,7 @@ 
                 // 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());
                 }
             }
         }
@@ -89,9 +89,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) {
@@ -117,7 +117,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);