BEAR\QueryRepository\CacheInterceptor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	invoke()	0	33	7
A	triggerWarning()	0	5	1

<?php

declare(strict_types=1);

namespace BEAR\QueryRepository;

use BEAR\QueryRepository\Exception\LogicException;
use BEAR\QueryRepository\Exception\RuntimeException;
use BEAR\Resource\ResourceObject;
use Ray\Aop\MethodInterceptor;
use Ray\Aop\MethodInvocation;
use Throwable;

use function assert;
use function get_class;
use function sprintf;
use function trigger_error;

use const E_USER_WARNING;

class CacheInterceptor implements MethodInterceptor
{
    /** @var QueryRepositoryInterface */
    private $repository;

    public function __construct(
        QueryRepositoryInterface $repository
    ) {
        $this->repository = $repository;
    }

    /**
     * {@inheritdoc}
     */
    public function invoke(MethodInvocation $invocation)
    {
        $ro = $invocation->getThis();
        assert($ro instanceof ResourceObject);
        try {
            $stored = $this->repository->get($ro->uri);
        } catch (LogicException $e) {
            throw $e;
        } catch (Throwable $e) {
            $this->triggerWarning($e);

            return $invocation->proceed();
        }

        if ($stored) {
            [$ro->uri, $ro->code, $ro->headers, $ro->body, $ro->view] = $stored;

            return $ro;
        }

        /** @psalm-suppress MixedAssignment */
        $ro = $invocation->proceed();
        assert($ro instanceof ResourceObject);
        try {
            $ro->code === 200 ? $this->repository->put($ro) : $this->repository->purge($ro->uri);
        } catch (LogicException $e) {
            throw $e;
        } catch (Throwable $e) {
            $this->triggerWarning($e);
        }

        return $ro;
    }

    /**
     * Trigger warning
     *
     * When the cache server is down, it will issue a warning rather than an exception to continue service.
     */
    private function triggerWarning(Throwable $e): void
    {
        $message = sprintf('%s: %s in %s:%s', get_class($e), $e->getMessage(), $e->getFile(), $e->getLine());
        trigger_error($message, E_USER_WARNING);
    }
}