Silviooosilva\CacheerPhp\CacheStore\CacheManager\FileCacheFlusher

Complexity

Total Complexity

7

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	scheduleFlush()	0	14	3
A	handleAutoFlush()	0	4	2
A	__construct()	0	5	1
A	flushCache()	0	4	1

<?php

namespace Silviooosilva\CacheerPhp\CacheStore\CacheManager;

use Silviooosilva\CacheerPhp\Helpers\CacheFileHelper;

/**
 * Class FileCacheFlusher
 * @author Sílvio Silva <https://github.com/silviooosilva>
 * @package Silviooosilva\CacheerPhp
 */
class FileCacheFlusher
{
    /**
    * @var FileCacheManager
    */
    private FileCacheManager $fileManager;

    /**
    * @var string $cacheDir
    */
    private string $cacheDir;

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

    /**
     * FileCacheFlusher constructor.
     *
     * @param FileCacheManager $fileManager
     * @param string $cacheDir
     */
    public function __construct(FileCacheManager $fileManager, string $cacheDir)
    {
        $this->fileManager = $fileManager;
        $this->cacheDir = $cacheDir;
        $this->lastFlushTimeFile = "$cacheDir/last_flush_time";
    }

    /**
    * Flushes all cache items and updates the last flush timestamp.
    *
    * @return void
    */
    public function flushCache()
    {
        $this->fileManager->clearDirectory($this->cacheDir);
        file_put_contents($this->lastFlushTimeFile, time());
    }

    /**
    * Handles the auto-flush functionality based on options.
    *
    * @param array $options
    * @return void
    */
    public function handleAutoFlush(array $options)
    {
        if (isset($options['flushAfter'])) {
            $this->scheduleFlush($options['flushAfter']);
        }
    }

    /**
    * Schedules a flush operation based on the provided interval.
    *
    * @param string $flushAfter
    * @return void
    */
    private function scheduleFlush(string $flushAfter)
    {
        $flushAfterSeconds = CacheFileHelper::convertExpirationToSeconds($flushAfter);

        if (!$this->fileManager->fileExists($this->lastFlushTimeFile)) {
            $this->fileManager->writeFile($this->lastFlushTimeFile, time());
            return;
        }

        $lastFlushTime = (int) $this->fileManager->readFile($this->lastFlushTimeFile);

        if ((time() - $lastFlushTime) >= $flushAfterSeconds) {
            $this->flushCache();
            $this->fileManager->writeFile($this->lastFlushTimeFile, time());
        }
    }
}