BEAR\QueryRepository\RefreshAnnotatedCommand

Complexity

Total Complexity

9

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	command()	0	7	2
A	getUri()	0	6	2
A	request()	0	15	4

<?php

declare(strict_types=1);

namespace BEAR\QueryRepository;

use BEAR\RepositoryModule\Annotation\AbstractCommand;
use BEAR\RepositoryModule\Annotation\Purge;
use BEAR\RepositoryModule\Annotation\Refresh;
use BEAR\Resource\ResourceInterface;
use BEAR\Resource\ResourceObject;
use BEAR\Resource\Uri;
use Override;
use Ray\Aop\MethodInvocation;

use function is_array;
use function uri_template;

final class RefreshAnnotatedCommand implements CommandInterface
{
    public function __construct(
        private readonly QueryRepositoryInterface $repository,
        private readonly ResourceInterface $resource,
    ) {
    }

    #[Override]
    public function command(MethodInvocation $invocation, ResourceObject $ro): void
    {
        $method = $invocation->getMethod();
        $annotations = $method->getAnnotations();
        foreach ($annotations as $annotation) {
            $this->request($ro, $annotation);
        }
    }

    private function getUri(ResourceObject $ro, AbstractCommand $annotation): string
    {
        $body = is_array($ro->body) ? $ro->body : [];
        $query = $body + $ro->uri->query;

        return uri_template($annotation->uri, $query);
    }

    private function request(ResourceObject $ro, object $annotation): void
    {
        if (! $annotation instanceof AbstractCommand) {
            return;
        }

        $uri = new Uri($this->getUri($ro, $annotation));
        if ($annotation instanceof Purge) {
            $this->repository->purge($uri);
        }

        if ($annotation instanceof Refresh) {
            $this->repository->purge($uri);
            $ro = $this->resource->get((string) $uri);
            $this->repository->put($ro);
        }
    }
}