@@ -121,8 +121,8 @@ discard block |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 |
||
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 | } |