Chemaclass\StockTicker\Domain\Notifier\Notifier

Complexity

Total Complexity

11

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Test Coverage

Coverage

92.59%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	matchConditions()	0	17	4
A	notify()	0	18	4
A	__construct()	0	6	1
A	sendNotification()	0	4	2

<?php

declare(strict_types=1);

namespace Chemaclass\StockTicker\Domain\Notifier;

use Chemaclass\StockTicker\Domain\Crawler\CrawlResult;
use Chemaclass\StockTicker\Domain\Notifier\Policy\PolicyGroup;
use Chemaclass\StockTicker\Domain\WriteModel\Quote;

use function get_class;
use function is_int;

final class Notifier implements NotifierInterface
{
    private NotifierPolicy $policy;

    /** @var ChannelInterface[] */
    private array $channels;

    public function __construct(
        NotifierPolicy $policy,
        ChannelInterface ...$channels,
    ) {
        $this->policy = $policy;
        $this->channels = $channels;
    }

    public function notify(CrawlResult $crawlResult): NotifyResult
    {
        $result = new NotifyResult();

        foreach ($this->policy->groupedBySymbol() as $symbol => $policyGroup) {
            $quote = $crawlResult->getQuote($symbol);
            $conditionNames = $this->matchConditions($policyGroup, $quote);

            if (!empty($conditionNames)) {
                $result->add($quote, $conditionNames);
            }
        }

        if (!$result->isEmpty()) {
            $this->sendNotification($result);
        }

        return $result;
    }

    private function matchConditions(PolicyGroup $policyGroup, Quote $quote): array
    {
        $conditionNames = [];

        foreach ($policyGroup->conditions() as $conditionName => $callablePolicy) {
            if (!$callablePolicy($quote)) {
                continue;
            }

            if (is_int($conditionName)) {
                $conditionName = get_class($callablePolicy);
            }

            $conditionNames[] = $conditionName;
        }

        return $conditionNames;
    }

    private function sendNotification(NotifyResult $result): void
    {
        foreach ($this->channels as $channel) {
            $channel->send($result);
        }
    }
}