Passed
Pull Request — main (#3)
by
unknown
03:04
created
src/Console/ProcessCacheInvalidationEventsCommand.php 1 patch
Spacing   +15 added lines, -15 removed lines patch added patch discarded remove patch
@@ -121,8 +121,8 @@  discard block
 block discarded – undo
121 121
         }
122 122
 
123 123
         // Group events by type and identifier
124
-        $eventsByIdentifier = $events->groupBy(function ($event) {
125
-            return $event->type . ':' . $event->identifier;
124
+        $eventsByIdentifier = $events->groupBy(function($event) {
125
+            return $event->type.':'.$event->identifier;
126 126
         });
127 127
 
128 128
         $batchIdentifiers = [];
@@ -147,7 +147,7 @@  discard block
 block discarded – undo
147 147
             foreach ($eventsGroup as $event) {
148 148
                 $eventAssociations = $associations->where('event_id', '=', $event->id);
149 149
                 foreach ($eventAssociations as $assoc) {
150
-                    $assocKey = $assoc->associated_type . ':' . $assoc->associated_identifier;
150
+                    $assocKey = $assoc->associated_type.':'.$assoc->associated_identifier;
151 151
                     $allIdentifiers[] = $assocKey;
152 152
                 }
153 153
             }
@@ -164,7 +164,7 @@  discard block
 block discarded – undo
164 164
             foreach ($eventsGroup as $event) {
165 165
                 $eventAssociations = $associations->where('event_id', '=', $event->id);
166 166
                 foreach ($eventAssociations as $assoc) {
167
-                    $assocKey = $assoc->associated_type . ':' . $assoc->associated_identifier;
167
+                    $assocKey = $assoc->associated_type.':'.$assoc->associated_identifier;
168 168
                     $associatedIdentifiers[$assocKey] = [
169 169
                         'type' => $assoc->associated_type,
170 170
                         'identifier' => $assoc->associated_identifier,
@@ -239,7 +239,7 @@  discard block
 block discarded – undo
239 239
     protected function getLastInvalidationTimes(array $identifiers): array
240 240
     {
241 241
         // Extract types and identifiers into tuples
242
-        $tuples = array_map(static function ($key) {
242
+        $tuples = array_map(static function($key) {
243 243
             return explode(':', $key, 2);
244 244
         }, $identifiers);
245 245
 
@@ -252,7 +252,7 @@  discard block
 block discarded – undo
252 252
         // Build associative array
253 253
         $lastInvalidationTimes = [];
254 254
         foreach ($records as $record) {
255
-            $key = $record->identifier_type . ':' . $record->identifier;
255
+            $key = $record->identifier_type.':'.$record->identifier;
256 256
             $lastInvalidationTimes[$key] = Carbon::parse($record->last_invalidated);
257 257
         }
258 258
 
@@ -351,10 +351,10 @@  discard block
 block discarded – undo
351 351
             foreach ($batchIdentifiers as $item) {
352 352
                 switch ($item['type']) {
353 353
                     case 'key':
354
-                        $keys[] = $item['identifier'] . '§' . $item['connection_name'];
354
+                        $keys[] = $item['identifier'].'§'.$item['connection_name'];
355 355
                         break;
356 356
                     case 'tag':
357
-                        $tags[] = $item['identifier'] . '§' . $item['connection_name'];
357
+                        $tags[] = $item['identifier'].'§'.$item['connection_name'];
358 358
                         break;
359 359
                 }
360 360
 
@@ -366,10 +366,10 @@  discard block
 block discarded – undo
366 366
                 foreach ($item['associated'] as $assoc) {
367 367
                     switch ($assoc['type']) {
368 368
                         case 'key':
369
-                            $keys[] = $assoc['identifier'] . '§' . $assoc['connection_name'];
369
+                            $keys[] = $assoc['identifier'].'§'.$assoc['connection_name'];
370 370
                             break;
371 371
                         case 'tag':
372
-                            $tags[] = $assoc['identifier'] . '§' . $assoc['connection_name'];
372
+                            $tags[] = $assoc['identifier'].'§'.$assoc['connection_name'];
373 373
                             break;
374 374
                     }
375 375
                 }
@@ -425,7 +425,7 @@  discard block
 block discarded – undo
425 425
             }
426 426
 
427 427
             // oppure di default uso Laravel
428
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
428
+            $storeName = $this->getStoreFromConnectionName($connection_name);
429 429
 
430 430
             if ($storeName === null) {
431 431
                 return;
@@ -461,7 +461,7 @@  discard block
 block discarded – undo
461 461
             return;
462 462
         }
463 463
         foreach ($groupByConnection as $connection_name => $arrTags) {
464
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
464
+            $storeName = $this->getStoreFromConnectionName($connection_name);
465 465
             if ($storeName === null) {
466 466
                 return;
467 467
             }
@@ -477,9 +477,9 @@  discard block
 block discarded – undo
477 477
         $shardId = (int) $this->option('shard');
478 478
         $priority = (int) $this->option('priority');
479 479
         $limit = $this->option('limit') ?? config('super_cache_invalidate.processing_limit');
480
-        $limit = (int)$limit;
480
+        $limit = (int) $limit;
481 481
         $tagBatchSize = $this->option('tag-batch-size') ?? config('super_cache_invalidate.tag_batch_size');
482
-        $tagBatchSize = (int)$tagBatchSize;
482
+        $tagBatchSize = (int) $tagBatchSize;
483 483
         $lockTimeout = (int) config('super_cache_invalidate.lock_timeout');
484 484
         $connection_name = $this->option('connection_name') ?? config('super_cache_invalidate.default_connection_name');
485 485
         /*
@@ -498,7 +498,7 @@  discard block
 block discarded – undo
498 498
         try {
499 499
             $this->processEvents($shardId, $priority, $limit, $tagBatchSize, $connection_name);
500 500
         } catch (\Exception $e) {
501
-            $this->error('Si è verificato un errore in ' . __METHOD__ . ': ' . $e->getMessage() . PHP_EOL . $e->getTraceAsString());
501
+            $this->error('Si è verificato un errore in '.__METHOD__.': '.$e->getMessage().PHP_EOL.$e->getTraceAsString());
502 502
         } finally {
503 503
             $this->helper->releaseShardLock($shardId, $lockValue, $connection_name);
504 504
         }
Please login to merge, or discard this patch.