Spiral\Cache\Storage\FileStorage

Complexity

Total Complexity

26

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

<?php
final class FileStorage implements CacheInterface
{
    use InteractsWithTime;

    public function __construct(
        private readonly FilesInterface $files,
        private readonly string $path,
        private readonly int $ttl = 2_592_000

A parse error occurred: Syntax error, unexpected T_STRING, expecting ')' on line 18 at column 37

    ) {
    }

    public function get(string $key, mixed $default = null): mixed
    {
        return $this->getPayload($key)['value'] ?? $default;
    }

    public function set(string $key, mixed $value, null|int|\DateInterval|\DateTimeInterface $ttl = null): bool
    {
        return $this->files->write(
            $this->makePath($key),
            $this->ttlToTimestamp($ttl) . \serialize($value),
            null,
            true
        );
    }

    public function delete(string $key): bool
    {
        if ($this->has($key)) {
            return $this->files->delete($this->makePath($key));
        }

        return false;
    }

    public function clear(): bool
    {
        if (!$this->files->isDirectory($this->path)) {
            return false;
        }

        $this->files->deleteDirectory($this->path);

        return true;
    }

    public function getMultiple(iterable $keys, mixed $default = null): iterable
    {
        $result = [];

        foreach ($keys as $key) {
            $result[$key] = $this->get($key, $default);
        }

        return $result;
    }

    public function setMultiple(iterable $values, null|int|\DateInterval|\DateTimeInterface $ttl = null): bool
    {
        $state = null;

        foreach ($values as $key => $value) {
            $result = $this->set($key, $value, $ttl);
            $state = \is_null($state) ? $result : $result && $state;
        }

        return $state ?: false;
    }

    public function deleteMultiple(iterable $keys): bool
    {
        $state = null;
        foreach ($keys as $key) {
            $result = $this->delete($key);
            $state = \is_null($state) ? $result : $result && $state;
        }

        return $state ?: false;
    }

    public function has(string $key): bool
    {
        return $this->files->exists($this->makePath($key));
    }

    /**
     * Make the full path for the given cache key.
     */
    protected function makePath(string $key): string
    {
        $parts = \array_slice(\str_split($hash = \sha1($key), 2), 0, 2);

        return $this->path . '/' . \implode('/', $parts) . '/' . $hash;
    }

    /**
     * Retrieve an item and expiry time from the cache by key.
     */
    protected function getPayload(string $key): array
    {
        $path = $this->makePath($key);

        try {
            $expire = (int) \substr(
                $contents = $this->files->read($path),
                0,
                10
            );
        } catch (FileNotFoundException) {
            return $this->makeEmptyPayload();
        }

        if (\time() >= $expire) {
            $this->delete($key);

            return $this->makeEmptyPayload();
        }

        try {
            $data = \unserialize(\substr($contents, 10));
        } catch (\Exception) {
            $this->delete($key);

            return $this->makeEmptyPayload();
        }

        $time = $expire - \time();

        return ['value' => $data, 'timestamp' => $time];
    }

    /**
     * Make a default empty payload for the cache.
     */
    protected function makeEmptyPayload(): array
    {
        return ['value' => null, 'timestamp' => null];
    }