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/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 +4 added lines, -4 removed lines

@@ -309,7 +309,7 @@ 
 
             DB::table('cache_invalidation_timestamps')
                 //DB::table(DB::raw("`cache_invalidation_timestamps` PARTITION ({$partitionCache_invalidation_timestamps})"))
-              ->updateOrInsert(
+                ->updateOrInsert(
                     ['identifier_type' => $type, 'identifier' => $identifier],
                     ['last_invalidated' => $now]
                 )
@@ -392,9 +392,9 @@ 
                 // Mark event as processed
                 //DB::table(DB::raw("`cache_invalidation_events` PARTITION ({$partitionCache_invalidation_events}, {$partitionCache_invalidation_events_processed})"))
                 DB::table("cache_invalidation_events")
-                  ->whereIn('id', array_column($eventsToUpdate, 'id'))
-                  ->whereIn('partition_key', array_column($eventsToUpdate, 'partition_key'))
-                  ->update(['processed' => 1])
+                    ->whereIn('id', array_column($eventsToUpdate, 'id'))
+                    ->whereIn('partition_key', array_column($eventsToUpdate, 'partition_key'))
+                    ->update(['processed' => 1])
                 ;
                 // Riattiva i controlli
                 DB::statement('SET UNIQUE_CHECKS=1;');

Spacing +16 added lines, -16 removed lines

@@ -100,8 +100,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 = [];
@@ -130,7 +130,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;
                 }
             }
@@ -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;
                     $associatedIdentifiers[$assocKey] = [
                         'type' => $assoc->associated_type,
                         'identifier' => $assoc->associated_identifier,
@@ -222,7 +222,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);
 
@@ -235,7 +235,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);
         }
 
@@ -338,10 +338,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;
             }
 
@@ -353,10 +353,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;
                 }
             }
@@ -406,7 +406,7 @@ 
                 // Rollback transaction on error
                 //DB::rollBack();
                 $attempts++;
-                $this->warn(now()->toDateTimeString() . ": Tentativo $attempts di $maxAttempts: " . $e->getMessage());
+                $this->warn(now()->toDateTimeString().": Tentativo $attempts di $maxAttempts: ".$e->getMessage());
                 // Logica per gestire i tentativi falliti
                 if ($attempts >= $maxAttempts) {
                     // Salta il record dopo il numero massimo di tentativi
@@ -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(now()->toDateTimeString() . ': Si è verificato un errore in ' . __METHOD__ . ': ' . $e->getMessage());
+            $this->error(now()->toDateTimeString().': Si è verificato un errore in '.__METHOD__.': '.$e->getMessage());
         } finally {
             $this->helper->releaseShardLock($shardId, $priority, $lockValue, $connection_name);
         }

src/Helpers/SuperCacheInvalidationHelper.php

Spacing +5 added lines, -5 removed lines

@@ -79,11 +79,11 @@ 
             } catch (\Throwable $e) {
                 //DB::rollBack(); // Annulla la transazione in caso di errore
                 $attempts++;
-                Log::error("SuperCacheInvalidate: impossibile eseguire insert, tentativo $attempts di $maxAttempts: " . $e->getMessage());
+                Log::error("SuperCacheInvalidate: impossibile eseguire insert, tentativo $attempts di $maxAttempts: ".$e->getMessage());
                 // 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());
                 }
             }
         }
@@ -97,9 +97,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) {
@@ -125,7 +125,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);