silviooosilva / CacheerPHP

src/CacheStore/CacheManager/GenericFlusher.php

Spacing +6 added lines, -6 removed lines

@@ -33,7 +33,7 @@ 
     public function flushCache(): void
     {
         ($this->flushCallback)();
-        @file_put_contents($this->lastFlushTimeFile, (string) time());
+        @file_put_contents($this->lastFlushTimeFile, (string)time());
     }
 
     /**
@@ -46,7 +46,7 @@ 
         if (!isset($options['flushAfter'])) {
             return;
         }
-        $this->scheduleFlush((string) $options['flushAfter']);
+        $this->scheduleFlush((string)$options['flushAfter']);
     }
 
     /**
@@ -55,18 +55,18 @@ 
      */
     private function scheduleFlush(string $flushAfter): void
     {
-        $flushAfterSeconds = (int) CacheFileHelper::convertExpirationToSeconds($flushAfter);
+        $flushAfterSeconds = (int)CacheFileHelper::convertExpirationToSeconds($flushAfter);
 
         if (!file_exists($this->lastFlushTimeFile)) {
-            @file_put_contents($this->lastFlushTimeFile, (string) time());
+            @file_put_contents($this->lastFlushTimeFile, (string)time());
             return;
         }
 
-        $lastFlushTime = (int) @file_get_contents($this->lastFlushTimeFile);
+        $lastFlushTime = (int)@file_get_contents($this->lastFlushTimeFile);
 
         if ((time() - $lastFlushTime) >= $flushAfterSeconds) {
             $this->flushCache();
-            @file_put_contents($this->lastFlushTimeFile, (string) time());
+            @file_put_contents($this->lastFlushTimeFile, (string)time());
         }
     }
 }

src/CacheStore/RedisCacheStore.php

Spacing +10 added lines, -10 removed lines

@@ -61,17 +61,17 @@ 
         
         // OptionBuilder support
         if (!empty($options['namespace'])) {
-            $this->namespace = (string) $options['namespace'];
+            $this->namespace = (string)$options['namespace'];
         }
 
         // Default TTL from options
         if (!empty($options['expirationTime'])) {
-            $this->defaultTTL = (int) CacheFileHelper::convertExpirationToSeconds((string) $options['expirationTime']);
+            $this->defaultTTL = (int)CacheFileHelper::convertExpirationToSeconds((string)$options['expirationTime']);
         }
 
         // Auto-flush support
         $lastFlushFile = FlushHelper::pathFor('redis', $this->namespace ?: 'default');
-        $this->flusher = new GenericFlusher($lastFlushFile, function () {
+        $this->flusher = new GenericFlusher($lastFlushFile, function() {
             $this->flushCache();
         });
         $this->flusher->handleAutoFlush($options);
@@ -159,7 +159,7 @@ 
      * @param string|int $ttl
      * @return mixed
      */
-    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600): mixed
+    public function getCache(string $cacheKey, string $namespace = '', string | int $ttl = 3600): mixed
     {
         $fullCacheKey = $this->buildKey($cacheKey, $namespace);
         $cacheData = $this->redis->get($fullCacheKey);
@@ -214,7 +214,7 @@ 
      * @param string|int $ttl
      * @return array
      */
-    public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600): array
+    public function getMany(array $cacheKeys, string $namespace = '', string | int $ttl = 3600): array
     {
         $results = [];
         foreach ($cacheKeys as $cacheKey) {
@@ -314,7 +314,7 @@ 
      * @param string|int|null $ttl
      * @return Status|null
      */
-    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string|int|null $ttl = null): ?Status
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string | int | null $ttl = null): ?Status
     {
         $cacheFullKey = $this->buildKey($cacheKey, $namespace);
         $serializedData = CacheRedisHelper::serialize($cacheData);
@@ -325,10 +325,10 @@ 
             $ttlToUse = $this->defaultTTL;
         }
         if (is_string($ttlToUse)) {
-            $ttlToUse = (int) CacheFileHelper::convertExpirationToSeconds($ttlToUse);
+            $ttlToUse = (int)CacheFileHelper::convertExpirationToSeconds($ttlToUse);
         }
 
-        $result = $ttlToUse ? $this->redis->setex($cacheFullKey, (int) $ttlToUse, $serializedData)
+        $result = $ttlToUse ? $this->redis->setex($cacheFullKey, (int)$ttlToUse, $serializedData)
                             : $this->redis->set($cacheFullKey, $serializedData);
 
         if ($result) {
@@ -370,7 +370,7 @@ 
      * @return void
      * @throws CacheRedisException
      */
-    public function renewCache(string $cacheKey, string|int $ttl, string $namespace = ''): void
+    public function renewCache(string $cacheKey, string | int $ttl, string $namespace = ''): void
     {
         $cacheFullKey = $this->buildKey($cacheKey, $namespace);
         $dump = $this->getDump($cacheFullKey);
@@ -401,7 +401,7 @@ 
      * @return bool
      * @throws CacheRedisException
      */
-    private function restoreKey(string $fullKey, string|int $ttl, mixed $dump): bool
+    private function restoreKey(string $fullKey, string | int $ttl, mixed $dump): bool
     {
         try {
             $this->redis->restore($fullKey, $ttl * 1000, $dump, 'REPLACE');

src/Support/TimeBuilder.php

Indentation +36 added lines, -36 removed lines

@@ -12,24 +12,24 @@ 
 class TimeBuilder
 {
     
-  /** @param Closure $callback */
-  private Closure $callback;
+    /** @param Closure $callback */
+    private Closure $callback;
 
-  /** @var mixed */
-  private $builder = null;
+    /** @var mixed */
+    private $builder = null;
 
-  /**
-  * TimeBuilder constructor.
-  * @param Closure $callback
-  * @param mixed $builder
-  *
-  * @return void
-  */
-  public function __construct(Closure $callback, $builder)
-  {
+    /**
+     * TimeBuilder constructor.
+     * @param Closure $callback
+     * @param mixed $builder
+     *
+     * @return void
+     */
+    public function __construct(Closure $callback, $builder)
+    {
     $this->callback = $callback;
     $this->builder = $builder;
-  }
+    }
 
     /**
      * Sets the time in seconds.
@@ -37,10 +37,10 @@ 
      * @param int $seconds
      * @return mixed
      */
-  public function second(int $seconds)
-  {
+    public function second(int $seconds)
+    {
     return $this->setTime($seconds, "seconds");
-  }
+    }
 
     /**
      * Sets the time in minutes.
@@ -48,10 +48,10 @@ 
      * @param int $minutes
      * @return mixed
      */
-  public function minute(int $minutes)
-  {
+    public function minute(int $minutes)
+    {
     return $this->setTime($minutes, "minutes");
-  }
+    }
 
     /**
      * Sets the time in hours.
@@ -59,10 +59,10 @@ 
      * @param int $hours
      * @return mixed
      */
-  public function hour(int $hours)
-  {
+    public function hour(int $hours)
+    {
     return $this->setTime($hours, "hours");
-  }
+    }
 
     /**
      * Sets the time in days.
@@ -70,10 +70,10 @@ 
      * @param int $days
      * @return mixed
      */
-  public function day(int $days)
-  {
+    public function day(int $days)
+    {
     return $this->setTime($days, "days");
-  }
+    }
 
     /**
      * Sets the time in weeks.
@@ -81,10 +81,10 @@ 
      * @param int $weeks
      * @return mixed
      */
-  public function week(int $weeks)
-  {
+    public function week(int $weeks)
+    {
     return $this->setTime($weeks, "weeks");
-  }
+    }
 
     /**
      * Sets the time in months.
@@ -92,10 +92,10 @@ 
      * @param int $months
      * @return mixed
      */
-  public function month(int $months)
-  {
+    public function month(int $months)
+    {
     return $this->setTime($months, "months");
-  }
+    }
 
 
     /**
@@ -105,10 +105,10 @@ 
      * @param string $unit
      * @return mixed
      */
-  private function setTime(int $value, string $unit)
-  {
-   ($this->callback)("{$value} {$unit}");
+    private function setTime(int $value, string $unit)
+    {
+    ($this->callback)("{$value} {$unit}");
     return $this->builder;
-  }
+    }
 
 }

src/Repositories/CacheDatabaseRepository.php

Indentation +53 added lines, -53 removed lines

@@ -64,11 +64,11 @@ 
     }
 
     /**
-    * Retrieves cache data from the database.
-    * 
-    * @param string $cacheKey
-    * @param string $namespace
-    * @return mixed
+     * Retrieves cache data from the database.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @return mixed
      */
     public function retrieve(string $cacheKey, string $namespace = ''): mixed
     {
@@ -113,10 +113,10 @@ 
     }
 
     /**
-    * Get Update query based on the database driver.
-    *
-    * @return string
-    */
+     * Get Update query based on the database driver.
+     *
+     * @return string
+     */
     private function getUpdateQueryWithDriver(): string
     {
         $driver = $this->connection->getAttribute(PDO::ATTR_DRIVER_NAME);
@@ -127,10 +127,10 @@ 
     }
 
     /**
-    * Get Delete query based on the database driver.
-    * 
-    * @return string
-    */
+     * Get Delete query based on the database driver.
+     * 
+     * @return string
+     */
     private function getDeleteQueryWithDriver(): string
     {
         $driver = $this->connection->getAttribute(PDO::ATTR_DRIVER_NAME);
@@ -141,13 +141,13 @@ 
     }
 
     /**
-    * Updates an existing cache item in the database.
-    * 
-    * @param string $cacheKey
-    * @param mixed  $cacheData
-    * @param string $namespace
-    * @return bool
-    */
+     * Updates an existing cache item in the database.
+     * 
+     * @param string $cacheKey
+     * @param mixed  $cacheData
+     * @param string $namespace
+     * @return bool
+     */
     public function update(string $cacheKey, mixed $cacheData, string $namespace = ''): bool
     {
         $query = $this->getUpdateQueryWithDriver();
@@ -161,12 +161,12 @@ 
     }
 
     /**
-    * Clears a specific cache item from the database.
-    * 
-    * @param string $cacheKey
-    * @param string $namespace
-    * @return bool
-    */
+     * Clears a specific cache item from the database.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @return bool
+     */
     public function clear(string $cacheKey, string $namespace = ''): bool
     {
         $query = $this->getDeleteQueryWithDriver();
@@ -179,10 +179,10 @@ 
     }
 
     /**
-    * Gets the query to renew the expiration time of a cache item based on the database driver.
-    *  
-    * @return string
-    */
+     * Gets the query to renew the expiration time of a cache item based on the database driver.
+     *  
+     * @return string
+     */
     private function getRenewExpirationQueryWithDriver(): string
     {
         $driver = $this->connection->getAttribute(PDO::ATTR_DRIVER_NAME);
@@ -197,13 +197,13 @@ 
     }
 
     /**
-    * Checks if a cache item is valid based on its key, namespace, and current time.
-    * 
-    * @param string $cacheKey
-    * @param string $namespace
-    * @param string $currentTime
-    * @return bool
-    */
+     * Checks if a cache item is valid based on its key, namespace, and current time.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @param string $currentTime
+     * @return bool
+     */
     private function hasValidCache(string $cacheKey, string $namespace, string $currentTime): bool
     {
         $stmt = $this->connection->prepare(
@@ -219,13 +219,13 @@ 
     }
 
     /**
-    * Renews the expiration time of a cache item.
-    * 
-    * @param string $cacheKey
-    * @param string|int $ttl
-    * @param string $namespace
-    * @return bool
-    */
+     * Renews the expiration time of a cache item.
+     * 
+     * @param string $cacheKey
+     * @param string|int $ttl
+     * @param string $namespace
+     * @return bool
+     */
     public function renew(string $cacheKey, string|int $ttl, string $namespace = ''): bool
     {
         $currentTime = date('Y-m-d H:i:s');
@@ -245,10 +245,10 @@ 
     }
 
     /**
-    * Flushes all cache items from the database.
-    * 
-    * @return bool
-    */
+     * Flushes all cache items from the database.
+     * 
+     * @return bool
+     */
     public function flush(): bool
     {
         return $this->connection->exec("DELETE FROM {$this->table}") !== false;
@@ -267,11 +267,11 @@ 
     }
 
     /**
-    * Gets the current date and time based on the database driver.
-    * 
-    * @param string $driver
-    * @return string
-    */
+     * Gets the current date and time based on the database driver.
+     * 
+     * @param string $driver
+     * @return string
+     */
     private function getCurrentDateTime(string $driver): string
     {
         return ($driver === 'sqlite') ? "DATETIME('now', 'localtime')" : "NOW()";

tests/Unit/MigrationManagerDynamicTableTest.php

Indentation +15 added lines, -15 removed lines

@@ -7,26 +7,26 @@ 
 
 class MigrationManagerDynamicTableTest extends TestCase
 {
-  private ?PDO $pdo = null;
-  private string $table;
+    private ?PDO $pdo = null;
+    private string $table;
 
-  protected function setUp(): void
-  {
+    protected function setUp(): void
+    {
     $this->pdo = Connect::getInstance();
     $this->table = uniqid('mm_custom_table_');
     // Ensure clean start
     $this->pdo->exec("DROP TABLE IF EXISTS {$this->table}");
-  }
+    }
 
-  protected function tearDown(): void
-  {
+    protected function tearDown(): void
+    {
     if ($this->pdo) {
-      $this->pdo->exec("DROP TABLE IF EXISTS {$this->table}");
+        $this->pdo->exec("DROP TABLE IF EXISTS {$this->table}");
+    }
     }
-  }
 
-  public function test_migrate_creates_custom_table()
-  {
+    public function test_migrate_creates_custom_table()
+    {
     MigrationManager::migrate($this->pdo, $this->table);
 
     // Verify table exists (SQLite check)
@@ -50,13 +50,13 @@ 
     $stmt->execute();
     $row = $stmt->fetch(PDO::FETCH_ASSOC);
     $this->assertEquals(['a' => 1], unserialize($row['cacheData']));
-  }
+    }
 
-  public function test_default_constant_table_exists()
-  {
+    public function test_default_constant_table_exists()
+    {
     // With boot autoload, the default CACHEER_TABLE should be created via Connect::getInstance()
     $stmt = $this->pdo->query("SELECT name FROM sqlite_master WHERE type='table' AND name = 'cacheer_table'");
     $row = $stmt->fetch(PDO::FETCH_ASSOC);
     $this->assertNotFalse($row);
-  }
+    }
 }

src/CacheStore/DatabaseCacheStore.php

Spacing +14 added lines, -14 removed lines

@@ -62,11 +62,11 @@ 
         MigrationManager::migrate($pdo, $table);
 
         if (!empty($options['expirationTime'])) {
-            $this->defaultTTL = (int) CacheFileHelper::convertExpirationToSeconds((string) $options['expirationTime']);
+            $this->defaultTTL = (int)CacheFileHelper::convertExpirationToSeconds((string)$options['expirationTime']);
         }
 
         $lastFlushFile = FlushHelper::pathFor('db', $table);
-        $this->flusher = new GenericFlusher($lastFlushFile, function () {
+        $this->flusher = new GenericFlusher($lastFlushFile, function() {
             $this->flushCache();
         });
         $this->flusher->handleAutoFlush($options);
@@ -104,7 +104,7 @@ 
     public function clearCache(string $cacheKey, string $namespace = ''): void
     {
         $data = $this->cacheRepository->clear($cacheKey, $namespace);
-        if($data) {
+        if ($data) {
             $this->setMessage("Cache deleted successfully!", true);
         } else {
             $this->setMessage("Cache does not exists!", false);
@@ -120,7 +120,7 @@ 
      */
     public function flushCache(): void
     {
-        if($this->cacheRepository->flush()){
+        if ($this->cacheRepository->flush()) {
             $this->setMessage("Flush finished successfully", true);
         } else {
             $this->setMessage("Something went wrong. Please, try again.", false);
@@ -138,7 +138,7 @@ 
      * @param string|int $ttl
      * @return mixed
      */
-    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600): mixed
+    public function getCache(string $cacheKey, string $namespace = '', string | int $ttl = 3600): mixed
     {
         $cacheData = $this->retrieveCache($cacheKey, $namespace);
         if ($cacheData) {
@@ -178,7 +178,7 @@ 
      * @param string|int $ttl
      * @return array
      */
-    public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600): array
+    public function getMany(array $cacheKeys, string $namespace = '', string | int $ttl = 3600): array
     {
         $cacheData = [];
         foreach ($cacheKeys as $cacheKey) {
@@ -268,17 +268,17 @@ 
      * @param string|int $ttl
      * @return bool
      */
-    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string|int $ttl = 3600): bool
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string | int $ttl = 3600): bool
     {
         $ttlToUse = $ttl;
         if ($this->defaultTTL !== null && ($ttl === null || (int)$ttl === 3600)) {
             $ttlToUse = $this->defaultTTL;
         }
         if (is_string($ttlToUse)) {
-            $ttlToUse = (int) CacheFileHelper::convertExpirationToSeconds($ttlToUse);
+            $ttlToUse = (int)CacheFileHelper::convertExpirationToSeconds($ttlToUse);
         }
 
-        if($this->storeCache($cacheKey, $cacheData, $namespace, $ttlToUse)){
+        if ($this->storeCache($cacheKey, $cacheData, $namespace, $ttlToUse)) {
             $this->logger->debug("{$this->getMessage()} from database driver.");
             return true;
         }
@@ -313,7 +313,7 @@ 
      */
     private function processBatchItems(array $batchItems, string $namespace): void
     {
-        foreach($batchItems as $item) {
+        foreach ($batchItems as $item) {
             CacheDatabaseHelper::validateCacheItem($item);
             $cacheKey = $item['cacheKey'];
             $cacheData = $item['cacheData'];
@@ -330,7 +330,7 @@ 
      * @param string $namespace
      * @return bool
      */
-    private function renew(string $cacheKey, string|int $ttl = 3600, string $namespace = ''): bool
+    private function renew(string $cacheKey, string | int $ttl = 3600, string $namespace = ''): bool
     {
         $cacheData = $this->getCache($cacheKey, $namespace);
         if ($cacheData) {
@@ -378,10 +378,10 @@ 
      * @param string|int $ttl
      * @return bool
      */
-    private function storeCache(string $cacheKey, mixed $cacheData, string $namespace = '', string|int $ttl = 3600): bool
+    private function storeCache(string $cacheKey, mixed $cacheData, string $namespace = '', string | int $ttl = 3600): bool
     {
         $data = $this->cacheRepository->store($cacheKey, $cacheData, $namespace, $ttl);
-        if($data) {
+        if ($data) {
             $this->setMessage("Cache Stored Successfully", true);
             return true;
         }
@@ -400,7 +400,7 @@ 
     private function updateCache(string $cacheKey, mixed $cacheData, string $namespace = ''): bool
     {
         $data = $this->cacheRepository->update($cacheKey, $cacheData, $namespace);
-        if($data) {
+        if ($data) {
             $this->setMessage("Cache updated successfully.", true);
             return true;
         }