FileCacheStore::putMany() - Code Metrics - Inspection of "Tests for redis added" - silviooosilva/CacheerPHP - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 72c6fa...9344f0 )

by Sílvio

created 2025-03-10 16:42 UTC

FileCacheStore::putMany() A

↳ Parent: FileCacheStore

Complexity

Conditions	2
Paths	2

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	1

Metric	Value
cc	2
eloc	6
c	2
b	0
f	1
nc	2
nop	3
dl	0
loc	9
rs	10

<?php

namespace Silviooosilva\CacheerPhp\CacheStore;

use Silviooosilva\CacheerPhp\Interface\CacheerInterface;
use Silviooosilva\CacheerPhp\CacheStore\CacheManager\FileCacheManager;
use Silviooosilva\CacheerPhp\Exceptions\CacheFileException;
use Silviooosilva\CacheerPhp\Helpers\CacheFileHelper;
use Silviooosilva\CacheerPhp\Utils\CacheLogger;

/**
 * Class FileCacheStore
 * @author Sílvio Silva <https://github.com/silviooosilva>
 * @package Silviooosilva\CacheerPhp
 */
class FileCacheStore implements CacheerInterface
{
    /**
     * @param string $cacheDir
     */
    private string $cacheDir;

    /**
     * @param array $options
     */
    private array $options = [];

    /**
     * @param string $message
     */
    private string $message = '';

    /**
     * @param integer $defaultTTL
     */
    private int $defaultTTL = 3600; // 1 hora por padrão

    /**
     * @param boolean $success
     */
    private bool $success = false;

    /**
     * @param string $lastFlushTimeFile
     */
    private string $lastFlushTimeFile;

    /**
    * @var CacheLogger
    */
    private $logger = null;

    /**
    * @var FileCacheManager
    */
    private FileCacheManager $fileManager;

    public function __construct(array $options = [])
    {
        $this->validateOptions($options);
        $this->fileManager = new FileCacheManager();
        $this->initializeCacheDir($options['cacheDir']);
        $this->defaultTTL = $this->getExpirationTime($options);
        $this->lastFlushTimeFile = "{$this->cacheDir}/last_flush_time";
        $this->handleAutoFlush($options);
        $this->logger = new CacheLogger($options['loggerPath']);
    }

    /**
     * @param string $cacheKey
     * @param string $namespace
     * @param string|int $ttl
     * @return string|null
     */
    public function getCache(string $cacheKey, string $namespace = '', string|int $ttl = 3600)
    {
       
        $ttl = CacheFileHelper::ttl($ttl, $this->defaultTTL);
        $cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
        if ($this->isCacheValid($cacheFile, $ttl)) {
            $cacheData = $this->fileManager->serialize($this->fileManager->readFile($cacheFile), false);

            $this->setMessage("Cache retrieved successfully", true);
            $this->logger->debug("{$this->getMessage()} from file driver.");
            return $cacheData;
        }

        $this->setMessage("cacheFile not found, does not exists or expired", false);
        $this->logger->info("{$this->getMessage()} from file driver.");
        return null;
    }

    /**
     * @param string $cacheKey
     * @param mixed  $cacheData
     * @param string $namespace
     * @param string|int $ttl
     * @return void
     */
    public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string|int $ttl = 3600)
    {
        $cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
        $data = $this->fileManager->serialize($cacheData);

        $this->fileManager->writeFile($cacheFile, $data);
        $this->setMessage("Cache file created successfully", true);

        $this->logger->debug("{$this->getMessage()} from file driver.");
    }

    /**
     * @param array   $items
     * @param string  $namespace
     * @param integer $batchSize
     * @return void
     */
    public function putMany(array $items, string $namespace = '', int $batchSize = 100)
    {
        $processedCount = 0;
        $itemCount = count($items);

        while ($processedCount < $itemCount) {
            $batchItems = array_slice($items, $processedCount, $batchSize);
            $this->processBatchItems($batchItems, $namespace);
            $processedCount += count($batchItems);
        }
    }

    /**
     * @param string $cacheKey
     * @param mixed  $cacheData
     * @param string $namespace
     * @return void
     */
    public function appendCache(string $cacheKey, mixed $cacheData, string $namespace = '')
    {
        $currentCacheFileData = $this->getCache($cacheKey, $namespace);

        if (!$this->isSuccess()) {
            return $this->getMessage();

        }

        $mergedCacheData = CacheFileHelper::arrayIdentifier($currentCacheFileData, $cacheData);


        $this->putCache($cacheKey, $mergedCacheData, $namespace);
        if ($this->isSuccess()) {
            $this->setMessage("Cache updated successfully", true);
            $this->logger->debug("{$this->getMessage()} from file driver.");
        }
    }


    /**
     * @param string $cacheKey
     * @param string $namespace
     * @return bool
     */
    public function has(string $cacheKey, string $namespace = '')
    {
        $cacheData = $this->getCache($cacheKey, $namespace);
        if ($cacheData) {
            $this->setMessage("Cache key: {$cacheKey} exists and it's available! from file driver", true);
        }
        $this->setMessage("Cache key: {$cacheKey} does not exists or it's expired! from file driver", false);
    }

    /**
     * @param string $cacheKey
     * @param string|int $ttl
     * @param string $namespace
     * @return void
     */
    public function renewCache(string $cacheKey, string|int $ttl, string $namespace = '')
    {
        $cacheData = $this->getCache($cacheKey, $namespace);
        if ($cacheData) {
            $this->putCache($cacheKey, $cacheData, $namespace, $ttl);
            $this->setMessage("Cache with key {$cacheKey} renewed successfully", true);
        }
        $this->setMessage("Failed to renew Cache with key {$cacheKey}", false);
        $this->logger->debug("{$this->getMessage()} from file driver.");
    }

    /**
     * @param string $cacheKey
     * @param string $namespace
     * @return void
     */
    public function clearCache(string $cacheKey, string $namespace = '')
    {
        $cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
        if ($this->fileManager->readFile($cacheFile)) {
            $this->fileManager->removeFile($cacheFile);
            $this->setMessage("Cache file deleted successfully!", true);
        } else {
            $this->setMessage("Cache file does not exist!", false);
        }
        $this->logger->debug("{$this->getMessage()} from file driver.");
    }

    /**
     * @return void
     */
    public function flushCache()
    {
        $this->fileManager->clearDirectory($this->cacheDir);
        file_put_contents($this->lastFlushTimeFile, time());
    }

    /**
     * @return string
     */
    public function getMessage()
    {
        return $this->message;
    }

    /**
     * @return boolean
     */
    public function isSuccess()
    {
        return $this->success;
    }

    /**
     * @param array $options
     * @return void
     */
    private function validateOptions(array $options)
    {
        if (!isset($options['cacheDir']) && $options['drive'] === 'file') {
            $this->logger->debug("The 'cacheDir' option is required from file driver.");
            throw CacheFileException::create("The 'cacheDir' option is required.");
        }
        $this->options = $options;
    }

    /**
     * @param string $cacheDir
     * @return void
     */
    private function initializeCacheDir(string $cacheDir)
    {
        $this->cacheDir = realpath($cacheDir) ?: "";
        $this->fileManager->createDirectory($cacheDir);
    }

    /**
     * @param array $options
     * @return integer
     */
    private function getExpirationTime(array $options)
    {
        return isset($options['expirationTime'])
            ? CacheFileHelper::convertExpirationToSeconds($options['expirationTime'])
            : $this->defaultTTL;
    }


    /**
     * @param array $options
     * @return void
     */
    private function handleAutoFlush(array $options)
    {
        if (isset($options['flushAfter'])) {
            $this->scheduleFlush($options['flushAfter']);
        }
    }

    /**
     * @param string $flushAfter
     * @return void
     */
    private function scheduleFlush(string $flushAfter)
    {
        $flushAfterSeconds = CacheFileHelper::convertExpirationToSeconds($flushAfter);
        if ($this->fileManager->readFile($this->lastFlushTimeFile)) {
            $lastFlushTime = $this->fileManager->readFile($this->lastFlushTimeFile);
            if ((time() - (int)$lastFlushTime) >= $flushAfterSeconds) {
                $this->flushCache();
            }
        } else {
            file_put_contents($this->lastFlushTimeFile, time());
        }
    }

    /**
     * @param array  $batchItems
     * @param string $namespace
     * @return void
     */
    private function processBatchItems(array $batchItems, string $namespace)
    {
        foreach ($batchItems as $item) {
            CacheFileHelper::validateCacheItem($item);
            $cacheKey = $item['cacheKey'];
            $cacheData = $item['cacheData'];
            $mergedData = CacheFileHelper::mergeCacheData($cacheData);
            $this->putCache($cacheKey, $mergedData, $namespace);
        }
    }

    /**
     * @param string  $message
     * @param boolean $success
     * @return void
     */
    private function setMessage(string $message, bool $success)
    {
        $this->message = $message;
        $this->success = $success;
    }

    /**
     * @param string $cacheKey
     * @param string $namespace
     * @return string
     */
    private function buildCacheFilePath(string $cacheKey, string $namespace)
    {
        $namespace = $namespace ? md5($namespace) . '/' : '';
        $cacheDir = "{$this->cacheDir}/";

        if (!empty($namespace)) {
            $cacheDir = "{$this->cacheDir}/{$namespace}";
            $this->fileManager->createDirectory($cacheDir);
        }
        return $cacheDir . md5($cacheKey) . ".cache";
    }

    /**
     * @param string  $cacheFile
     * @param integer $ttl
     * @return boolean
     */
    private function isCacheValid(string $cacheFile, int $ttl)
    {
        return file_exists($cacheFile) && (filemtime($cacheFile) > (time() - $ttl));
    }
}


1			<?php
2
3			namespace Silviooosilva\CacheerPhp\CacheStore;
4
5			use Silviooosilva\CacheerPhp\Interface\CacheerInterface;
6			use Silviooosilva\CacheerPhp\CacheStore\CacheManager\FileCacheManager;
7			use Silviooosilva\CacheerPhp\Exceptions\CacheFileException;
8			use Silviooosilva\CacheerPhp\Helpers\CacheFileHelper;
9			use Silviooosilva\CacheerPhp\Utils\CacheLogger;
10
11			/**
12			* Class FileCacheStore
13			* @author Sílvio Silva <https://github.com/silviooosilva>
14			* @package Silviooosilva\CacheerPhp
15			*/
16			class FileCacheStore implements CacheerInterface
17			{
18			/**
19			* @param string $cacheDir
20			*/
21			private string $cacheDir;
22
23			/**
24			* @param array $options
25			*/
26			private array $options = [];
27
28			/**
29			* @param string $message
30			*/
31			private string $message = '';
32
33			/**
34			* @param integer $defaultTTL
35			*/
36			private int $defaultTTL = 3600; // 1 hora por padrão
37
38			/**
39			* @param boolean $success
40			*/
41			private bool $success = false;
42
43			/**
44			* @param string $lastFlushTimeFile
45			*/
46			private string $lastFlushTimeFile;
47
48			/**
49			* @var CacheLogger
50			*/
51			private $logger = null;
52
53			/**
54			* @var FileCacheManager
55			*/
56			private FileCacheManager $fileManager;
57
58			public function __construct(array $options = [])
59			{
60			$this->validateOptions($options);
61			$this->fileManager = new FileCacheManager();
62			$this->initializeCacheDir($options['cacheDir']);
63			$this->defaultTTL = $this->getExpirationTime($options);
64			$this->lastFlushTimeFile = "{$this->cacheDir}/last_flush_time";
65			$this->handleAutoFlush($options);
66			$this->logger = new CacheLogger($options['loggerPath']);
67			}
68
69			/**
70			* @param string $cacheKey
71			* @param string $namespace
72			* @param string\|int $ttl
73			* @return string\|null
74			*/
75			public function getCache(string $cacheKey, string $namespace = '', string\|int $ttl = 3600)
76			{
77
78			$ttl = CacheFileHelper::ttl($ttl, $this->defaultTTL);
79			$cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
80			if ($this->isCacheValid($cacheFile, $ttl)) {
81			$cacheData = $this->fileManager->serialize($this->fileManager->readFile($cacheFile), false);
82
83			$this->setMessage("Cache retrieved successfully", true);
84			$this->logger->debug("{$this->getMessage()} from file driver.");
85			return $cacheData;
86			}
87
88			$this->setMessage("cacheFile not found, does not exists or expired", false);
89			$this->logger->info("{$this->getMessage()} from file driver.");
90			return null;
91			}
92
93			/**
94			* @param string $cacheKey
95			* @param mixed $cacheData
96			* @param string $namespace
97			* @param string\|int $ttl
98			* @return void
99			*/
100			public function putCache(string $cacheKey, mixed $cacheData, string $namespace = '', string\|int $ttl = 3600)
101			{
102			$cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
103			$data = $this->fileManager->serialize($cacheData);
104
105			$this->fileManager->writeFile($cacheFile, $data);
106			$this->setMessage("Cache file created successfully", true);
107
108			$this->logger->debug("{$this->getMessage()} from file driver.");
109			}
110
111			/**
112			* @param array $items
113			* @param string $namespace
114			* @param integer $batchSize
115			* @return void
116			*/
117			public function putMany(array $items, string $namespace = '', int $batchSize = 100)
118			{
119			$processedCount = 0;
120			$itemCount = count($items);
121
122			while ($processedCount < $itemCount) {
123			$batchItems = array_slice($items, $processedCount, $batchSize);
124			$this->processBatchItems($batchItems, $namespace);
125			$processedCount += count($batchItems);
126			}
127			}
128
129			/**
130			* @param string $cacheKey
131			* @param mixed $cacheData
132			* @param string $namespace
133			* @return void
134			*/
135			public function appendCache(string $cacheKey, mixed $cacheData, string $namespace = '')
136			{
137			$currentCacheFileData = $this->getCache($cacheKey, $namespace);
138
139			if (!$this->isSuccess()) {
140			return $this->getMessage();
			0 ignored issues – show Bug Best Practice introduced 2025-02-28 04:17 UTC by Report Bug Copy Issue Report The expression `return $this->getMessage()` returns the type `string` which is incompatible with the documented return type `void`. Loading history...
141			}
142
143			$mergedCacheData = CacheFileHelper::arrayIdentifier($currentCacheFileData, $cacheData);
144
145
146			$this->putCache($cacheKey, $mergedCacheData, $namespace);
147			if ($this->isSuccess()) {
148			$this->setMessage("Cache updated successfully", true);
149			$this->logger->debug("{$this->getMessage()} from file driver.");
150			}
151			}
152
153
154			/**
155			* @param string $cacheKey
156			* @param string $namespace
157			* @return bool
158			*/
159			public function has(string $cacheKey, string $namespace = '')
160			{
161			$cacheData = $this->getCache($cacheKey, $namespace);
162			if ($cacheData) {
163			$this->setMessage("Cache key: {$cacheKey} exists and it's available! from file driver", true);
164			}
165			$this->setMessage("Cache key: {$cacheKey} does not exists or it's expired! from file driver", false);
166			}
167
168			/**
169			* @param string $cacheKey
170			* @param string\|int $ttl
171			* @param string $namespace
172			* @return void
173			*/
174			public function renewCache(string $cacheKey, string\|int $ttl, string $namespace = '')
175			{
176			$cacheData = $this->getCache($cacheKey, $namespace);
177			if ($cacheData) {
178			$this->putCache($cacheKey, $cacheData, $namespace, $ttl);
179			$this->setMessage("Cache with key {$cacheKey} renewed successfully", true);
180			}
181			$this->setMessage("Failed to renew Cache with key {$cacheKey}", false);
182			$this->logger->debug("{$this->getMessage()} from file driver.");
183			}
184
185			/**
186			* @param string $cacheKey
187			* @param string $namespace
188			* @return void
189			*/
190			public function clearCache(string $cacheKey, string $namespace = '')
191			{
192			$cacheFile = $this->buildCacheFilePath($cacheKey, $namespace);
193			if ($this->fileManager->readFile($cacheFile)) {
194			$this->fileManager->removeFile($cacheFile);
195			$this->setMessage("Cache file deleted successfully!", true);
196			} else {
197			$this->setMessage("Cache file does not exist!", false);
198			}
199			$this->logger->debug("{$this->getMessage()} from file driver.");
200			}
201
202			/**
203			* @return void
204			*/
205			public function flushCache()
206			{
207			$this->fileManager->clearDirectory($this->cacheDir);
208			file_put_contents($this->lastFlushTimeFile, time());
209			}
210
211			/**
212			* @return string
213			*/
214			public function getMessage()
215			{
216			return $this->message;
217			}
218
219			/**
220			* @return boolean
221			*/
222			public function isSuccess()
223			{
224			return $this->success;
225			}
226
227			/**
228			* @param array $options
229			* @return void
230			*/
231			private function validateOptions(array $options)
232			{
233			if (!isset($options['cacheDir']) && $options['drive'] === 'file') {
234			$this->logger->debug("The 'cacheDir' option is required from file driver.");
235			throw CacheFileException::create("The 'cacheDir' option is required.");
236			}
237			$this->options = $options;
238			}
239
240			/**
241			* @param string $cacheDir
242			* @return void
243			*/
244			private function initializeCacheDir(string $cacheDir)
245			{
246			$this->cacheDir = realpath($cacheDir) ?: "";
247			$this->fileManager->createDirectory($cacheDir);
248			}
249
250			/**
251			* @param array $options
252			* @return integer
253			*/
254			private function getExpirationTime(array $options)
255			{
256			return isset($options['expirationTime'])
257			? CacheFileHelper::convertExpirationToSeconds($options['expirationTime'])
258			: $this->defaultTTL;
259			}
260
261
262			/**
263			* @param array $options
264			* @return void
265			*/
266			private function handleAutoFlush(array $options)
267			{
268			if (isset($options['flushAfter'])) {
269			$this->scheduleFlush($options['flushAfter']);
270			}
271			}
272
273			/**
274			* @param string $flushAfter
275			* @return void
276			*/
277			private function scheduleFlush(string $flushAfter)
278			{
279			$flushAfterSeconds = CacheFileHelper::convertExpirationToSeconds($flushAfter);
280			if ($this->fileManager->readFile($this->lastFlushTimeFile)) {
281			$lastFlushTime = $this->fileManager->readFile($this->lastFlushTimeFile);
282			if ((time() - (int)$lastFlushTime) >= $flushAfterSeconds) {
283			$this->flushCache();
284			}
285			} else {
286			file_put_contents($this->lastFlushTimeFile, time());
287			}
288			}
289
290			/**
291			* @param array $batchItems
292			* @param string $namespace
293			* @return void
294			*/
295			private function processBatchItems(array $batchItems, string $namespace)
296			{
297			foreach ($batchItems as $item) {
298			CacheFileHelper::validateCacheItem($item);
299			$cacheKey = $item['cacheKey'];
300			$cacheData = $item['cacheData'];
301			$mergedData = CacheFileHelper::mergeCacheData($cacheData);
302			$this->putCache($cacheKey, $mergedData, $namespace);
303			}
304			}
305
306			/**
307			* @param string $message
308			* @param boolean $success
309			* @return void
310			*/
311			private function setMessage(string $message, bool $success)
312			{
313			$this->message = $message;
314			$this->success = $success;
315			}
316
317			/**
318			* @param string $cacheKey
319			* @param string $namespace
320			* @return string
321			*/
322			private function buildCacheFilePath(string $cacheKey, string $namespace)
323			{
324			$namespace = $namespace ? md5($namespace) . '/' : '';
325			$cacheDir = "{$this->cacheDir}/";
326
327			if (!empty($namespace)) {
328			$cacheDir = "{$this->cacheDir}/{$namespace}";
329			$this->fileManager->createDirectory($cacheDir);
330			}
331			return $cacheDir . md5($cacheKey) . ".cache";
332			}
333
334			/**
335			* @param string $cacheFile
336			* @param integer $ttl
337			* @return boolean
338			*/
339			private function isCacheValid(string $cacheFile, int $ttl)
340			{
341			return file_exists($cacheFile) && (filemtime($cacheFile) > (time() - $ttl));
342			}
343			}
344

silviooosilva / CacheerPHP

Push — main ( 72c6fa...9344f0 )

FileCacheStore::putMany() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like