silviooosilva / CacheerPHP

src/CacheStore/RedisCacheStore.php

Spacing +11 added lines, -11 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);
@@ -164,7 +164,7 @@ 
         $added = 0;
         foreach ($keys as $key) {
             // Accept either raw key or "namespace:key"
-            $added += (int) $this->redis->sadd($setKey, [$key]);
+            $added += (int)$this->redis->sadd($setKey, [$key]);
         }
         $this->setMessage("Tagged successfully", true);
         $this->logger->debug("{$this->getMessage()} from redis driver.");
@@ -202,7 +202,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);
@@ -257,7 +257,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) {
@@ -357,7 +357,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);
@@ -368,10 +368,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) {
@@ -413,7 +413,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);
@@ -444,7 +444,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/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.");
-  }
+    }
 }