GarethEllis\Tldr\Cache\StashAdapter

Complexity

Total Complexity

8

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	2
A	readFromCache()	0	17	3
A	writeToCache()	0	6	1
A	deleteFromCache()	0	7	1
A	flushCache()	0	4	1

<?php
declare(strict_types=1);

namespace GarethEllis\Tldr\Cache;

use GarethEllis\Tldr\Cache\Exception\InvalidCacheDriverException;
use GarethEllis\Tldr\Fetcher\Exception\PageNotFoundException;
use GarethEllis\Tldr\Page\TldrPage;
use Stash\Driver\Ephemeral;
use Stash\Pool;

class StashAdapter implements CacheAdapterInterface
{
    /**
     * @var Pool
     */
    private $pool;

    /**
     * CacheReader constructor.
     */
    public function __construct(Pool $pool)
    {
        if ($pool->getDriver() instanceof Ephemeral) {
            throw new InvalidCacheDriverException("Ephemeral cannot be used as a cache driver in this app");
        }
        $this->pool = $pool;
    }

    public function readFromCache(String $platform, String $pageName): TldrPage
    {
        $item = $this->pool->getItem($platform . "/" . $pageName);
        $page = $item->get();

        if ($item->isMiss()) {

            $item = $this->pool->getItem("common/" . $pageName);
            $page = $item->get();

            if ($item->isMiss()) {
                throw new PageNotFoundException();
            }
        }

        return $page;
    }

    public function writeToCache(TldrPage $page)
    {
        $item = $this->pool->getItem($page->getPlatform() . "/" . $page->getName());
        $item->lock();
        $item->set($page);
    }

    public function deleteFromCache(String $platform, String $pageName)
    {
        $item = $this->pool->getItem($platform . "/" . $pageName);
        $item->clear();
        $item = $this->pool->getItem("common/" . $pageName);
        $item->clear();
    }


    /**
     * Flush the stash cache
     *
     * @return void
     */
    public function flushCache()
    {
        $this->pool->flush();
    }
}