padosoft / laravel-super-cache-invalidate

src/Console/PruneCacheInvalidationDataCommand.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         }
 
         // Build DROP PARTITION statement
-        $partitionNames = implode(', ', array_map(function ($partition) {
+        $partitionNames = implode(', ', array_map(function($partition) {
             return $partition->PARTITION_NAME;
         }, $partitions));
 

database/migrations/2024_11_20_200800_create_cache_invalidation_events_table.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
             return;
         }
 
-        Schema::create('cache_invalidation_events', function (Blueprint $table) {
+        Schema::create('cache_invalidation_events', function(Blueprint $table) {
             //$table->bigIncrements('id');
             $table->bigInteger('id')->unsigned(); // Definiamo l'ID come bigInteger senza autoincrement sennò la primarykey multipla non funziona
             $table->enum('type', ['key', 'tag'])->comment('Indicates whether the event is for a cache key or tag');

database/migrations/2024_11_20_200802_create_cache_invalidation_event_associations_table.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
         if (Schema::hasTable('cache_invalidation_event_associations')) {
             return;
         }
-        Schema::create('cache_invalidation_event_associations', function (Blueprint $table) {
+        Schema::create('cache_invalidation_event_associations', function(Blueprint $table) {
             //$table->bigIncrements('id');
             $table->bigInteger('id')->unsigned(); // Definiamo l'ID come bigInteger senza autoincrement sennò la primarykey multipla non funziona
             $table->unsignedBigInteger('event_id')->comment('Reference to cache_invalidation_events.id');

database/migrations/2024_11_20_200801_create_cache_invalidation_timestamps_table.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
         if (Schema::hasTable('cache_invalidation_timestamps')) {
             return;
         }
-        Schema::create('cache_invalidation_timestamps', function (Blueprint $table) {
+        Schema::create('cache_invalidation_timestamps', function(Blueprint $table) {
             $table->enum('identifier_type', ['key', 'tag'])->comment('Indicates whether the identifier is a cache key or tag');
             $table->string('identifier')->comment('The cache key or tag');
             $table->dateTime('last_invalidated')->comment('Timestamp of the last invalidation');

src/Helpers/SuperCacheInvalidationHelper.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
      * @param  string       $connection_name The Redis Connection name
      * @return string|false The lock value if acquired, false otherwise
      */
-    public function acquireShardLock(int $shardId, int $lockTimeout, string $connection_name): bool|string
+    public function acquireShardLock(int $shardId, int $lockTimeout, string $connection_name): bool | string
     {
         $lockKey = "shard_lock:$shardId";
         // Il metodo has/exists occupa troppa memoria!!!

src/SuperCacheInvalidateServiceProvider.php

Spacing +5 added lines, -5 removed lines

@@ -16,16 +16,16 @@ 
     {
         // Merge package configuration
         $this->mergeConfigFrom(
-            __DIR__ . '/../config/super_cache_invalidate.php',
+            __DIR__.'/../config/super_cache_invalidate.php',
             'super_cache_invalidate'
         );
 
         // Register the helper as a singleton
-        $this->app->singleton(SuperCacheInvalidationHelper::class, function () {
+        $this->app->singleton(SuperCacheInvalidationHelper::class, function() {
             return new SuperCacheInvalidationHelper();
         });
 
-        $this->app->singleton('super_cache_invalidate', function () {
+        $this->app->singleton('super_cache_invalidate', function() {
             return new SuperCacheInvalidationHelper();
         });
     }
@@ -37,11 +37,11 @@ 
     {
         // Publish configuration
         $this->publishes([
-            __DIR__ . '/../config/super_cache_invalidate.php' => config_path('super_cache_invalidate.php'),
+            __DIR__.'/../config/super_cache_invalidate.php' => config_path('super_cache_invalidate.php'),
         ], 'config');
 
         // Publish migrations
-        $this->loadMigrationsFrom(__DIR__ . '/../database/migrations');
+        $this->loadMigrationsFrom(__DIR__.'/../database/migrations');
         // Register commands
         if ($this->app->runningInConsole()) {
             $this->commands([

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);
         }