padosoft / laravel-super-cache-invalidate

src/Console/ProcessCacheInvalidationEventsCommand.php

Indentation +9 added lines, -9 removed lines

@@ -135,9 +135,9 @@ 
         //retrive associated identifiers related to fetched event id
         // Per le chiavi/tag associati non filtro per connection_name, potrebbero esserci associazioni anche in altri database
         $associations = DB::table('cache_invalidation_event_associations')
-                          ->whereIn('event_id', $eventIds)
-                          ->get()
-                          ->groupBy('event_id')
+                            ->whereIn('event_id', $eventIds)
+                            ->get()
+                            ->groupBy('event_id')
         ;
 
         // Prepare list of all identifiers to fetch last invalidation times
@@ -321,10 +321,10 @@ 
         foreach ($identifiers as $key) {
             [$type, $identifier] = explode(':', $key, 2);
             DB::table('cache_invalidation_timestamps')
-              ->updateOrInsert(
-                  ['identifier_type' => $type, 'identifier' => $identifier],
-                  ['last_invalidated' => $now]
-              )
+                ->updateOrInsert(
+                    ['identifier_type' => $type, 'identifier' => $identifier],
+                    ['last_invalidated' => $now]
+                )
             ;
         }
     }
@@ -391,8 +391,8 @@ 
 
             // Mark events as processed
             DB::table('cache_invalidation_events')
-              ->whereIn('id', $eventsToUpdate)
-              ->update(['processed' => 1])
+                ->whereIn('id', $eventsToUpdate)
+                ->update(['processed' => 1])
             ;
 
             // Commit transaction

Spacing +15 added lines, -15 removed lines

@@ -121,8 +121,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 = [];
@@ -147,7 +147,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;
                 }
             }
@@ -164,7 +164,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,
@@ -239,7 +239,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);
 
@@ -252,7 +252,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);
         }
 
@@ -351,10 +351,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;
                 }
 
@@ -366,10 +366,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;
                     }
                 }
@@ -425,7 +425,7 @@ 
             }
 
             // oppure di default uso Laravel
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
 
             if ($storeName === null) {
                 return;
@@ -461,7 +461,7 @@ 
             return;
         }
         foreach ($groupByConnection as $connection_name => $arrTags) {
-            $storeName =  $this->getStoreFromConnectionName($connection_name);
+            $storeName = $this->getStoreFromConnectionName($connection_name);
             if ($storeName === null) {
                 return;
             }
@@ -477,9 +477,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');
         /*
@@ -498,7 +498,7 @@ 
         try {
             $this->processEvents($shardId, $priority, $limit, $tagBatchSize, $connection_name);
         } catch (\Exception $e) {
-            $this->error('Si è verificato un errore in ' . __METHOD__ . ': ' . $e->getMessage() . PHP_EOL . $e->getTraceAsString());
+            $this->error('Si è verificato un errore in '.__METHOD__.': '.$e->getMessage().PHP_EOL.$e->getTraceAsString());
         } finally {
             $this->helper->releaseShardLock($shardId, $lockValue, $connection_name);
         }