Cycle\Schema\Provider\SimpleCacheSchemaProvider

Complexity

Total Complexity

11

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	write()	0	3	1
A	withConfig()	0	5	1
A	config()	0	4	1
A	clear()	0	10	3
A	__construct()	0	3	1
A	read()	0	13	4

<?php

declare(strict_types=1);

namespace Cycle\Schema\Provider;

use Cycle\Schema\Provider\Exception\SchemaProviderException;
use Psr\SimpleCache\CacheInterface;

final class SimpleCacheSchemaProvider implements SchemaProviderInterface
{
    public const DEFAULT_KEY = 'Cycle-ORM-Schema';

    /**
     * @var non-empty-string

The doc comment non-empty-string at position 0 could not be parsed: Unknown type name 'non-empty-string' at position 0 in non-empty-string.

     */
    private string $key = self::DEFAULT_KEY;

    public function __construct(
        private CacheInterface $cache
    ) {
    }

    /**
     * Create a configuration array for the {@see self::withConfig()} method.
     * @param non-empty-string $key

The doc comment non-empty-string at position 0 could not be parsed: Unknown type name 'non-empty-string' at position 0 in non-empty-string.

     */
    public static function config(string $key): array
    {
        return [
            'key' => $key,
        ];
    }

    public function withConfig(array $config): self
    {
        $new = clone $this;
        $new->key = $config['key'] ?? self::DEFAULT_KEY;
        return $new;
    }

    public function read(?SchemaProviderInterface $nextProvider = null): ?array
    {
        $schema = $this->cache->get($this->key);

        if ($schema !== null || $nextProvider === null) {
            return $schema;
        }

        $schema = $nextProvider->read();
        if ($schema !== null) {
            $this->write($schema);
        }
        return $schema;
    }

    public function clear(): bool
    {
        if (!$this->cache->has($this->key)) {
            return true;
        }
        $result = $this->cache->delete($this->key);
        if ($result === false) {
            throw new SchemaProviderException(\sprintf('Unable to delete `%s` from cache.', $this->key));
        }
        return true;
    }

    private function write(array $schema): bool
    {
        return $this->cache->set($this->key, $schema);
    }
}