silviooosilva / CacheerPHP

src/CacheStore/ArrayCacheStore.php

Indentation +317 added lines, -317 removed lines

@@ -13,117 +13,117 @@ 
 class ArrayCacheStore implements CacheerInterface
 {
 
-  /**
-  * @param array $arrayStore
-  */
-  private array $arrayStore = [];
-
-  /**
-   * @var boolean
-   */
-  private bool $success = false;
-
-  /**
-   * @var string
-   */
-  private string $message = '';
-
-  /**
-   * @var ?CacheLogger
-   */
-  private ?CacheLogger $logger = null;
-
-  /**
-   * @var array<string, array<string,bool>>
-   */
-  private array $tags = [];
-
-  /**
-   * ArrayCacheStore constructor.
-   * 
-   * @param string $logPath
-   */
-  public function __construct(string $logPath)
-  {
+    /**
+     * @param array $arrayStore
+     */
+    private array $arrayStore = [];
+
+    /**
+     * @var boolean
+     */
+    private bool $success = false;
+
+    /**
+     * @var string
+     */
+    private string $message = '';
+
+    /**
+     * @var ?CacheLogger
+     */
+    private ?CacheLogger $logger = null;
+
+    /**
+     * @var array<string, array<string,bool>>
+     */
+    private array $tags = [];
+
+    /**
+     * ArrayCacheStore constructor.
+     * 
+     * @param string $logPath
+     */
+    public function __construct(string $logPath)
+    {
     $this->logger = new CacheLogger($logPath);
-  }
-
-  /**
-   * Appends data to an existing cache item.
-   * 
-   * @param string $cacheKey
-   * @param mixed  $cacheData
-   * @param string $namespace
-   * @return bool
-   */
-  public function appendCache(string $cacheKey, mixed $cacheData, string $namespace = ''): bool
-  {
-      $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
-
-      if (!$this->has($cacheKey, $namespace)) {
-          $this->setMessage("cacheData can't be appended, because doesn't exist or expired", false);
-          $this->logger->debug("{$this->getMessage()} from array driver.");
-          return false;
-      }
-
-      $this->arrayStore[$arrayStoreKey]['cacheData'] = serialize($cacheData);
-      $this->setMessage("Cache appended successfully", true);
-      return true;
-  }
-
-  /**
-   * Builds a unique key for the array store.
-   * 
-   * @param string $cacheKey
-   * @param string $namespace
-   * @return string
-   */
-  private function buildArrayKey(string $cacheKey, string $namespace = ''): string
-  {
+    }
+
+    /**
+     * Appends data to an existing cache item.
+     * 
+     * @param string $cacheKey
+     * @param mixed  $cacheData
+     * @param string $namespace
+     * @return bool
+     */
+    public function appendCache(string $cacheKey, mixed $cacheData, string $namespace = ''): bool
+    {
+        $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
+
+        if (!$this->has($cacheKey, $namespace)) {
+            $this->setMessage("cacheData can't be appended, because doesn't exist or expired", false);
+            $this->logger->debug("{$this->getMessage()} from array driver.");
+            return false;
+        }
+
+        $this->arrayStore[$arrayStoreKey]['cacheData'] = serialize($cacheData);
+        $this->setMessage("Cache appended successfully", true);
+        return true;
+    }
+
+    /**
+     * Builds a unique key for the array store.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @return string
+     */
+    private function buildArrayKey(string $cacheKey, string $namespace = ''): string
+    {
     return !empty($namespace) ? ($namespace . ':' . $cacheKey) : $cacheKey;
-  }
-
-  /**
-   * Clears a specific cache item.
-   * 
-   * @param string $cacheKey
-   * @param string $namespace
-   * @return void
-   */
-  public function clearCache(string $cacheKey, string $namespace = ''): void
-  {
+    }
+
+    /**
+     * Clears a specific cache item.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @return void
+     */
+    public function clearCache(string $cacheKey, string $namespace = ''): void
+    {
     $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
     unset($this->arrayStore[$arrayStoreKey]);
     $this->setMessage("Cache cleared successfully", true);
     $this->logger->debug("{$this->getMessage()} from array driver.");
-  }
-
-  /**
-   * Decrements a cache item by a specified amount.
-   * 
-   * @param string $cacheKey
-   * @param int $amount
-   * @param string $namespace
-   * @return bool
-   */
-  public function decrement(string $cacheKey, int $amount = 1, string $namespace = ''): bool
-  {
+    }
+
+    /**
+     * Decrements a cache item by a specified amount.
+     * 
+     * @param string $cacheKey
+     * @param int $amount
+     * @param string $namespace
+     * @return bool
+     */
+    public function decrement(string $cacheKey, int $amount = 1, string $namespace = ''): bool
+    {
     return $this->increment($cacheKey, ($amount * -1), $namespace);
-  }
-
-  /**
-   * Flushes all cache items.
-   * 
-   * @return void
-   */
-  public function flushCache(): void
-  {
+    }
+
+    /**
+     * Flushes all cache items.
+     * 
+     * @return void
+     */
+    public function flushCache(): void
+    {
     unset($this->arrayStore);
     $this->arrayStore = [];
     $this->tags = [];
     $this->setMessage("Cache flushed successfully", true);
     $this->logger->debug("{$this->getMessage()} from array driver.");
-  }
+    }
 
     /**
      * Stores a cache item permanently.
@@ -132,234 +132,234 @@ 
      * @param mixed $cacheData
      * @return void
      */
-  public function forever(string $cacheKey, mixed $cacheData): void
-  {
+    public function forever(string $cacheKey, mixed $cacheData): void
+    {
     $this->putCache($cacheKey, $cacheData, ttl: 31536000 * 1000);
     $this->setMessage($this->getMessage(), $this->isSuccess());
-  }
-
-  /**
-   * Retrieves a single cache item.
-   * 
-   * @param string $cacheKey
-   * @param string $namespace
-   * @param int|string $ttl
-   * @return mixed
-   */
-  public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600): mixed
-  {
+    }
+
+    /**
+     * Retrieves a single cache item.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @param int|string $ttl
+     * @return mixed
+     */
+    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600): mixed
+    {
     $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
 
     if (!$this->has($cacheKey, $namespace)) {
-      $this->handleCacheNotFound();
-      return false;
+        $this->handleCacheNotFound();
+        return false;
     }
 
     $cacheData = $this->arrayStore[$arrayStoreKey];
     if ($this->isExpired($cacheData)) {
-      $this->handleCacheExpired($arrayStoreKey);
-      return false;
+        $this->handleCacheExpired($arrayStoreKey);
+        return false;
     }
 
     $this->setMessage("Cache retrieved successfully", true);
     $this->logger->debug("{$this->getMessage()} from array driver.");
     return $this->serialize($cacheData['cacheData'], false);
-  }
-
-  /**
-   * Verify if the cache is expired.
-   * 
-   * @param array $cacheData
-   * @return bool
-   */
-  private function isExpired(array $cacheData): bool
-  {
+    }
+
+    /**
+     * Verify if the cache is expired.
+     * 
+     * @param array $cacheData
+     * @return bool
+     */
+    private function isExpired(array $cacheData): bool
+    {
     $expirationTime = $cacheData['expirationTime'] ?? 0;
     $now = time();
     return $expirationTime !== 0 && $now >= $expirationTime;
-  }
-
-  /**
-   * Handles the case when cache data is not found.
-   * 
-   * @return void
-   */
-  private function handleCacheNotFound(): void
-  {
+    }
+
+    /**
+     * Handles the case when cache data is not found.
+     * 
+     * @return void
+     */
+    private function handleCacheNotFound(): void
+    {
     $this->setMessage("cacheData not found, does not exists or expired", false);
     $this->logger->debug("{$this->getMessage()} from array driver.");
-  }
-
-  /**
-   * Handles the case when cache data has expired.
-   * 
-   * @param string $arrayStoreKey
-   * @return void
-   */
-  private function handleCacheExpired(string $arrayStoreKey): void
-  {
+    }
+
+    /**
+     * Handles the case when cache data has expired.
+     * 
+     * @param string $arrayStoreKey
+     * @return void
+     */
+    private function handleCacheExpired(string $arrayStoreKey): void
+    {
     $parts = explode(':', $arrayStoreKey, 2);
     if (count($parts) === 2) {
-      list($np, $key) = $parts;
+        list($np, $key) = $parts;
     } else {
-      $np = '';
-      $key = $arrayStoreKey;
+        $np = '';
+        $key = $arrayStoreKey;
     }
     $this->clearCache($key, $np);
     $this->setMessage("cacheKey: {$key} has expired.", false);
     $this->logger->debug("{$this->getMessage()} from array driver.");
-  }
-
-  /**
-   * Gets all items in a specific namespace.
-   * 
-   * @param string $namespace
-   * @return array
-   */
-  public function getAll(string $namespace = ''): array
-  {
+    }
+
+    /**
+     * Gets all items in a specific namespace.
+     * 
+     * @param string $namespace
+     * @return array
+     */
+    public function getAll(string $namespace = ''): array
+    {
     $results = [];
     foreach ($this->arrayStore as $key => $data) {
-      if (str_starts_with($key, $namespace . ':') || empty($namespace)) {
+        if (str_starts_with($key, $namespace . ':') || empty($namespace)) {
         $results[$key] = $this->serialize($data['cacheData'], false);
-      }
+        }
     }
     return $results;
-  }
-
-  /**
-   * Retrieves multiple cache items by their keys.
-   * 
-   * @param array $cacheKeys
-   * @param string $namespace
-   * @param string|int $ttl
-   * @return array
-   */
-  public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600): array
-  {
+    }
+
+    /**
+     * Retrieves multiple cache items by their keys.
+     * 
+     * @param array $cacheKeys
+     * @param string $namespace
+     * @param string|int $ttl
+     * @return array
+     */
+    public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600): array
+    {
     $results = [];
     foreach ($cacheKeys as $cacheKey) {
-      $results[$cacheKey] = $this->getCache($cacheKey, $namespace, $ttl);
+        $results[$cacheKey] = $this->getCache($cacheKey, $namespace, $ttl);
     }
     return $results;
-  }
-
-  /**
-   * Checks if a cache item exists.
-   * 
-   * @param string $cacheKey
-   * @param string $namespace
-   * @return bool
-   */
-  public function has(string $cacheKey, string $namespace = ''): bool
-  {
+    }
+
+    /**
+     * Checks if a cache item exists.
+     * 
+     * @param string $cacheKey
+     * @param string $namespace
+     * @return bool
+     */
+    public function has(string $cacheKey, string $namespace = ''): bool
+    {
     $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
     $exists = isset($this->arrayStore[$arrayStoreKey]) && time() < $this->arrayStore[$arrayStoreKey]['expirationTime'];
 
     $this->setMessage(
-      $exists ? "Cache key: {$cacheKey} exists and it's available!" : "Cache key: {$cacheKey} does not exist or it's expired!",
-      $exists
+        $exists ? "Cache key: {$cacheKey} exists and it's available!" : "Cache key: {$cacheKey} does not exist or it's expired!",
+        $exists
     );
     $this->logger->debug("{$this->getMessage()} from array driver.");
 
     return $exists;
-  }
-
-  /**
-   * Increments a cache item by a specified amount.
-   * 
-   * @param string $cacheKey
-   * @param int $amount
-   * @param string $namespace
-   * @return bool
-   */
-  public function increment(string $cacheKey, int $amount = 1, string $namespace = ''): bool
-  {
+    }
+
+    /**
+     * Increments a cache item by a specified amount.
+     * 
+     * @param string $cacheKey
+     * @param int $amount
+     * @param string $namespace
+     * @return bool
+     */
+    public function increment(string $cacheKey, int $amount = 1, string $namespace = ''): bool
+    {
     $cacheData = $this->getCache($cacheKey, $namespace);
 
     if(!empty($cacheData) && is_numeric($cacheData)) {
-      $this->putCache($cacheKey, (int)($cacheData + $amount), $namespace);
-      $this->setMessage($this->getMessage(), $this->isSuccess());
-      return true;
+        $this->putCache($cacheKey, (int)($cacheData + $amount), $namespace);
+        $this->setMessage($this->getMessage(), $this->isSuccess());
+        return true;
     }
 
     return false;
-  }
-
-  /**
-   * Checks if the operation was successful.
-   * 
-   * @return boolean
-   */
-  public function isSuccess(): bool
-  {
+    }
+
+    /**
+     * Checks if the operation was successful.
+     * 
+     * @return boolean
+     */
+    public function isSuccess(): bool
+    {
     return $this->success;
-  }
-
-  /**
-   * Gets the last message.
-   * 
-   * @return string
-   */
-  public function getMessage(): string
-  {
+    }
+
+    /**
+     * Gets the last message.
+     * 
+     * @return string
+     */
+    public function getMessage(): string
+    {
     return $this->message;
-  }
-
-  /**
-   * Stores an item in the cache with a specific TTL.
-   * 
-   * @param string $cacheKey
-   * @param mixed $cacheData
-   * @param string $namespace
-   * @param int|string $ttl
-   * @return bool
-   */
-  public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int|string $ttl = 3600): bool
-  {
+    }
+
+    /**
+     * Stores an item in the cache with a specific TTL.
+     * 
+     * @param string $cacheKey
+     * @param mixed $cacheData
+     * @param string $namespace
+     * @param int|string $ttl
+     * @return bool
+     */
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int|string $ttl = 3600): bool
+    {
     $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
 
     $this->arrayStore[$arrayStoreKey] = [
-      'cacheData' => serialize($cacheData),
-      'expirationTime' => time() + $ttl
+        'cacheData' => serialize($cacheData),
+        'expirationTime' => time() + $ttl
     ];
 
     $this->setMessage("Cache stored successfully", true);
     $this->logger->debug("{$this->getMessage()} from Array driver.");
     return true;
-  }
-
-  /**
-   * Stores multiple items in the cache in batches.
-   * 
-   * @param array $items
-   * @param string $namespace
-   * @param int $batchSize
-   * @return void
-   */
-  public function putMany(array $items, string $namespace = '', int $batchSize = 100): void
-  {
+    }
+
+    /**
+     * Stores multiple items in the cache in batches.
+     * 
+     * @param array $items
+     * @param string $namespace
+     * @param int $batchSize
+     * @return void
+     */
+    public function putMany(array $items, string $namespace = '', int $batchSize = 100): void
+    {
     $chunks = array_chunk($items, $batchSize, true);
 
     foreach ($chunks as $chunk) {
-      foreach ($chunk as $key => $data) {
-          $this->putCache($data['cacheKey'], $data['cacheData'], $namespace);
+        foreach ($chunk as $key => $data) {
+            $this->putCache($data['cacheKey'], $data['cacheData'], $namespace);
+        }
         }
-      }
     $this->setMessage("{$this->getMessage()}", $this->isSuccess());
     $this->logger->debug("{$this->getMessage()} from Array driver.");
-  }
-
-  /**
-   * Renews the expiration time of a cache item.
-   * 
-   * @param string $cacheKey
-   * @param string|int $ttl
-   * @param string $namespace
-   * @return void
-   */
-  public function renewCache(string $cacheKey, int|string $ttl = 3600, string $namespace = ''): void
-  {
+    }
+
+    /**
+     * Renews the expiration time of a cache item.
+     * 
+     * @param string $cacheKey
+     * @param string|int $ttl
+     * @param string $namespace
+     * @return void
+     */
+    public function renewCache(string $cacheKey, int|string $ttl = 3600, string $namespace = ''): void
+    {
     $arrayStoreKey = $this->buildArrayKey($cacheKey, $namespace);
 
     if (isset($this->arrayStore[$arrayStoreKey])) {
@@ -367,78 +367,78 @@ 
         $this->arrayStore[$arrayStoreKey]['expirationTime'] = time() + $ttlSeconds;
         $this->setMessage("cacheKey: {$cacheKey} renewed successfully", true);
         $this->logger->debug("{$this->getMessage()} from array driver.");
-      }
-  }
-
-  /**
-   * Sets a message and its success status.
-   * 
-   * @param string  $message
-   * @param boolean $success
-   * @return void
-   */
-  private function setMessage(string $message, bool $success): void
-  {
+        }
+    }
+
+    /**
+     * Sets a message and its success status.
+     * 
+     * @param string  $message
+     * @param boolean $success
+     * @return void
+     */
+    private function setMessage(string $message, bool $success): void
+    {
     $this->message = $message;
     $this->success = $success;
-  }
-
-  /**
-   * Serializes or unserializes data based on the flag.
-   * 
-   * @param mixed $data
-   * @param bool $serialize
-   * @return mixed
-   */
-  private function serialize(mixed $data, bool $serialize = true): mixed
-  {
+    }
+
+    /**
+     * Serializes or unserializes data based on the flag.
+     * 
+     * @param mixed $data
+     * @param bool $serialize
+     * @return mixed
+     */
+    private function serialize(mixed $data, bool $serialize = true): mixed
+    {
     return $serialize ? serialize($data) : unserialize($data);
-  }
-
-  /**
-   * Associates one or more keys to a tag.
-   *
-   * @param string $tag
-   * @param string ...$keys
-   * @return bool
-   */
-  public function tag(string $tag, string ...$keys): bool
-  {
+    }
+
+    /**
+     * Associates one or more keys to a tag.
+     *
+     * @param string $tag
+     * @param string ...$keys
+     * @return bool
+     */
+    public function tag(string $tag, string ...$keys): bool
+    {
     if (!isset($this->tags[$tag])) {
-      $this->tags[$tag] = [];
+        $this->tags[$tag] = [];
     }
     foreach ($keys as $key) {
-      // Accept either raw key or "namespace:key"
-      $arrayStoreKey = (str_contains($key, ':')) ? $key : $this->buildArrayKey($key, '');
-      $this->tags[$tag][$arrayStoreKey] = true;
+        // Accept either raw key or "namespace:key"
+        $arrayStoreKey = (str_contains($key, ':')) ? $key : $this->buildArrayKey($key, '');
+        $this->tags[$tag][$arrayStoreKey] = true;
     }
     $this->setMessage("Tagged successfully", true);
     $this->logger?->debug("{$this->getMessage()} from array driver.");
     return true;
-  }
-
-  /**
-   * Flushes all keys associated with a tag.
-   *
-   * @param string $tag
-   * @return void
-   */
-  public function flushTag(string $tag): void
-  {
+    }
+
+    /**
+     * Flushes all keys associated with a tag.
+     *
+     * @param string $tag
+     * @return void
+     */
+    public function flushTag(string $tag): void
+    {
     $keys = array_keys($this->tags[$tag] ?? []);
     foreach ($keys as $arrayStoreKey) {
-      // Recover original key/namespace combination
-      $parts = explode(':', $arrayStoreKey, 2);
-      if (count($parts) === 2) {
+        // Recover original key/namespace combination
+        $parts = explode(':', $arrayStoreKey, 2);
+        if (count($parts) === 2) {
         [$np, $key] = $parts;
-      } else {
+        } else {
         $np = '';
         $key = $arrayStoreKey;
-      }
-      $this->clearCache($key, $np);
+        }
+        $this->clearCache($key, $np);
     }
     unset($this->tags[$tag]);
     $this->setMessage("Tag flushed successfully", true);
     $this->logger?->debug("{$this->getMessage()} from array driver.");
-  }
+    }
 }

src/Interface/CacheerInterface.php

Spacing +3 added lines, -3 removed lines

@@ -52,7 +52,7 @@ 
      * @param string|int $ttl Lifetime in seconds (default: 3600)
      * @return mixed Returns the cached data or null if not found
      */
-    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600);
+    public function getCache(string $cacheKey, string $namespace = '', string | int $ttl = 3600);
 
     /**
      * Retrieves multiple cache items by their keys.
@@ -62,7 +62,7 @@ 
      * @param string|int $ttl Lifetime in seconds (default: 3600)
      * @return CacheDataFormatter|mixed Returns a formatter with the retrieved items
      */
-    public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600);
+    public function getMany(array $cacheKeys, string $namespace = '', string | int $ttl = 3600);
 
     /**
      * Checks if a cache item exists.
@@ -82,7 +82,7 @@ 
      * @param string|int $ttl Lifetime in seconds (default: 3600)
      * @return bool True on success, false on failure
      */
-    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int|string $ttl = 3600);
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int | string $ttl = 3600);
 
     /**
      * Stores multiple items in the cache.

src/Interface/CacheReadStoreInterface.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
      * @param string|int $ttl
      * @return mixed
      */
-    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600);
+    public function getCache(string $cacheKey, string $namespace = '', string | int $ttl = 3600);
 
     /**
      * Retrieves multiple cache items by their keys.
@@ -22,7 +22,7 @@ 
      * @param string|int $ttl
      * @return mixed
      */
-    public function getMany(array $cacheKeys, string $namespace = '', string|int $ttl = 3600);
+    public function getMany(array $cacheKeys, string $namespace = '', string | int $ttl = 3600);
 
     /**
      * Gets all items in a specific namespace.

src/Interface/CacheWriteStoreInterface.php

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
      * @param int|string $ttl
      * @return mixed
      */
-    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int|string $ttl = 3600);
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', int | string $ttl = 3600);
 
     /**
      * Stores multiple items in the cache.
@@ -59,7 +59,7 @@ 
      * @param string $namespace
      * @return mixed
      */
-    public function renewCache(string $cacheKey, int|string $ttl, string $namespace = '');
+    public function renewCache(string $cacheKey, int | string $ttl, string $namespace = '');
 
     /**
      * Retrieves the last operation message.

src/CacheStore/RedisCacheStore.php

Spacing +11 added lines, -11 removed lines

@@ -61,11 +61,11 @@ 
         $this->redis = RedisCacheManager::connect();
         $logger = new CacheLogger($logPath);
 
-        $namespace = !empty($options['namespace']) ? (string) $options['namespace'] : '';
+        $namespace = !empty($options['namespace']) ? (string)$options['namespace'] : '';
         $defaultTTL = null;
 
         if (!empty($options['expirationTime'])) {
-            $defaultTTL = (int) CacheFileHelper::convertExpirationToSeconds((string) $options['expirationTime']);
+            $defaultTTL = (int)CacheFileHelper::convertExpirationToSeconds((string)$options['expirationTime']);
         }
 
         $this->keyspace = new RedisKeyspace($namespace, $defaultTTL);
@@ -74,7 +74,7 @@ 
 
         // Auto-flush support
         $lastFlushFile = FlushHelper::pathFor(CacheStoreType::REDIS, $namespace ?: 'default');
-        $this->flusher = new GenericFlusher($lastFlushFile, function () {
+        $this->flusher = new GenericFlusher($lastFlushFile, function() {
             $this->flushCache();
         });
         $this->flusher->handleAutoFlush($options);
@@ -168,7 +168,7 @@ 
      */
     public function flushTag(string $tag): void
     {
-        $this->tagIndex->flush($tag, function (string $cacheKey, string $namespace): void {
+        $this->tagIndex->flush($tag, function(string $cacheKey, string $namespace): void {
             $this->clearCache($cacheKey, $namespace);
         });
     }
@@ -181,7 +181,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);
@@ -234,7 +234,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) {
@@ -313,14 +313,14 @@ 
      * @param string|int|null $ttl
      * @return Status|null
      */
-    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string|int $ttl = 3600): ?Status
+    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string | int $ttl = 3600): ?Status
     {
         $cacheFullKey = $this->buildKey($cacheKey, $namespace);
         $serializedData = CacheRedisHelper::serialize($cacheData);
 
         $ttlToUse = $this->keyspace->resolveTTL($ttl);
 
-        $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) {
@@ -343,7 +343,7 @@ 
     public function putMany(array $items, string $namespace = '', int $batchSize = 100): void
     {
         $writer = new RedisBatchWriter($batchSize);
-        $writer->write($items, $namespace, function (string $cacheKey, mixed $cacheData, string $ns): void {
+        $writer->write($items, $namespace, function(string $cacheKey, mixed $cacheData, string $ns): void {
             $this->putCache($cacheKey, $cacheData, $ns);
         });
     }
@@ -357,7 +357,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);
@@ -385,7 +385,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/CacheStore/Support/RedisKeyspace.php

Spacing +4 added lines, -4 removed lines

@@ -53,18 +53,18 @@
      * 
      * @return int|null
      */
-    public function resolveTTL(string|int|null $ttl): ?int
+    public function resolveTTL(string | int | null $ttl): ?int
     {
         $ttlToUse = $ttl;
 
-        if ($this->defaultTTL !== null && ($ttl === null || (int) $ttl === 3600)) {
+        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);
         }
 
-        return $ttlToUse === null ? null : (int) $ttlToUse;
+        return $ttlToUse === null ? null : (int)$ttlToUse;
     }
 }

src/CacheStore/Support/RedisTagIndex.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
         $setKey = $this->keyspace->tagKey($tag);
         $added = 0;
         foreach ($keys as $key) {
-            $added += (int) $this->redis->sadd($setKey, [$key]);
+            $added += (int)$this->redis->sadd($setKey, [$key]);
         }
 
         $this->status->record('Tagged successfully', true);

src/CacheStore/DatabaseCacheStore.php

Spacing +14 added lines, -14 removed lines

@@ -64,11 +64,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(CacheStoreType::DATABASE, $table);
-        $this->flusher = new GenericFlusher($lastFlushFile, function () {
+        $this->flusher = new GenericFlusher($lastFlushFile, function() {
             $this->flushCache();
         });
         $this->flusher->handleAutoFlush($options);
@@ -106,7 +106,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);
@@ -122,7 +122,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);
@@ -191,7 +191,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) {
@@ -231,7 +231,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) {
@@ -321,17 +321,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;
         }
@@ -366,7 +366,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'];
@@ -383,7 +383,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) {
@@ -431,10 +431,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;
         }
@@ -453,7 +453,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;
         }

src/CacheStore/CacheManager/GenericFlusher.php

Spacing +4 added lines, -4 removed lines

@@ -50,7 +50,7 @@ 
         if (!isset($options['flushAfter'])) {
             return;
         }
-        $this->scheduleFlush((string) $options['flushAfter']);
+        $this->scheduleFlush((string)$options['flushAfter']);
     }
 
     /**
@@ -59,14 +59,14 @@ 
      */
     private function scheduleFlush(string $flushAfter): void
     {
-        $flushAfterSeconds = (int) CacheFileHelper::convertExpirationToSeconds($flushAfter);
+        $flushAfterSeconds = (int)CacheFileHelper::convertExpirationToSeconds($flushAfter);
 
         if (!file_exists($this->lastFlushTimeFile)) {
             $this->writeTimestamp(time());
             return;
         }
 
-        $lastFlushTime = (int) @file_get_contents($this->lastFlushTimeFile);
+        $lastFlushTime = (int)@file_get_contents($this->lastFlushTimeFile);
 
         if ((time() - $lastFlushTime) >= $flushAfterSeconds) {
             $this->flushCache();
@@ -82,7 +82,7 @@ 
      */
     private function writeTimestamp(int $timestamp): void
     {
-        $result = @file_put_contents($this->lastFlushTimeFile, (string) $timestamp, LOCK_EX);
+        $result = @file_put_contents($this->lastFlushTimeFile, (string)$timestamp, LOCK_EX);
         if ($result === false) {
             throw new \RuntimeException("Failed to write flush timestamp to {$this->lastFlushTimeFile}");
         }