PersonalGalaxy\RSS\Handler\FetchSubscriptionHandler

Complexity

Total Complexity

2

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	__invoke()	0	18	1

<?php
declare(strict_types = 1);

namespace PersonalGalaxy\RSS\Handler;

use PersonalGalaxy\RSS\{
    Command\FetchSubscription,
    Repository\SubscriptionRepository,
    Repository\ArticleRepository,
    Entity\Article,
};
use Innmind\Crawler\Crawler;
use Innmind\Http\{
    Message\Request\Request,
    Message\Method\Method,
    ProtocolVersion\ProtocolVersion,
};

final class FetchSubscriptionHandler
{
    private $subscriptions;
    private $articles;
    private $crawler;

    public function __construct(
        SubscriptionRepository $subscriptions,
        ArticleRepository $articles,
        Crawler $crawler
    ) {
        $this->subscriptions = $subscriptions;
        $this->articles = $articles;
        $this->crawler = $crawler;
    }

    public function __invoke(FetchSubscription $wished): void
    {
        $subscription = $this->subscriptions->get($wished->identity());
        $resource = $this->crawler->execute(new Request(
            $subscription->location(),
            new Method(Method::GET),
            new ProtocolVersion(2, 0)
        ));
        $resource
            ->attributes()
            ->get('articles')

'articles' of type string is incompatible with the type Innmind\Immutable\T expected by parameter $key of Innmind\Immutable\MapInterface::get().

            ->content()
            ->filter(function(Article $article): bool {
                return !$this->articles->has($article->link());
            })
            ->foreach(function(Article $article) use ($subscription): void {
                $article->bindTo($subscription->identity());
                $this->articles->add($article);
            });
    }
}