StockTickerFactory::createMarketWatchSiteCrawler() - Code Metrics - Inspection of "Add marketwatch crawler" - Chemaclass/stock-ticker - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#6)

by Jesús

created 2020-12-30 17:10 UTC

StockTickerFactory::createMarketWatchSiteCrawler() A

↳ Parent: StockTickerFactory

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	2
dl	0
loc	4
ccs	0
cts	4
cp	0
rs	10
c	1
b	0
f	0
cc	1
nc	1
nop	1
crap	2

<?php

declare(strict_types=1);

namespace Chemaclass\StockTicker;

use Chemaclass\StockTicker\Domain\Crawler\Mapper\CrawledInfoMapper;
use Chemaclass\StockTicker\Domain\Crawler\Mapper\CrawledInfoMapperInterface;
use Chemaclass\StockTicker\Domain\Crawler\QuoteCrawler;
use Chemaclass\StockTicker\Domain\Crawler\QuoteCrawlerInterface;
use Chemaclass\StockTicker\Domain\Crawler\Site\Barrons;
use Chemaclass\StockTicker\Domain\Crawler\Site\Barrons\BarronsSiteCrawler;
use Chemaclass\StockTicker\Domain\Crawler\Site\FinanceYahoo\FinanceYahooSiteCrawler;
use Chemaclass\StockTicker\Domain\Crawler\Site\FinanceYahoo\JsonExtractor;
use Chemaclass\StockTicker\Domain\Crawler\Site\MarketWatch;
use Chemaclass\StockTicker\Domain\Crawler\Site\MarketWatch\MarketWatchSiteCrawler;
use Chemaclass\StockTicker\Domain\Crawler\Site\Shared\NewsNormalizer;
use Chemaclass\StockTicker\Domain\Crawler\SiteCrawlerInterface;
use Chemaclass\StockTicker\Domain\Notifier\Channel\Email\EmailChannel;
use Chemaclass\StockTicker\Domain\Notifier\Channel\Slack\HttpSlackClient;
use Chemaclass\StockTicker\Domain\Notifier\Channel\Slack\SlackChannel;
use Chemaclass\StockTicker\Domain\Notifier\Channel\TwigTemplateGenerator;
use Chemaclass\StockTicker\Domain\Notifier\ChannelInterface;
use Chemaclass\StockTicker\Domain\Notifier\Notifier;
use Chemaclass\StockTicker\Domain\Notifier\NotifierInterface;
use Chemaclass\StockTicker\Domain\Notifier\NotifierPolicy;
use Chemaclass\StockTicker\Domain\WriteModel\Quote;
use DateTimeZone;
use Symfony\Component\HttpClient\HttpClient;
use Symfony\Component\Mailer\Bridge\Google\Transport\GmailSmtpTransport;
use Symfony\Component\Mailer\Mailer;
use Twig\Environment;
use Twig\Extension\DebugExtension;
use Twig\Loader\FilesystemLoader;

final class StockTickerFactory implements StockTickerFactoryInterface
{
    private const URLS = 'URLS';

    private StockTickerConfigInterface $config;

    public function __construct(StockTickerConfigInterface $config)
    {
        $this->config = $config;
    }

    public function createQuoteCrawler(SiteCrawlerInterface ...$siteCrawlers): QuoteCrawlerInterface
    {
        return new QuoteCrawler(
            HttpClient::create(),
            $this->createCrawledInfoMapper(),
            ...$siteCrawlers
        );
    }

    public function createNotifier(NotifierPolicy $policy, ChannelInterface ...$channels): NotifierInterface
    {
        return new Notifier($policy, ...$channels);
    }

    /**
     * @return Domain\Crawler\SiteCrawlerInterface[]
     */
    public function createSiteCrawlers(int $maxNewsToFetch): array
    {
        return [
            $this->createFinanceYahooSiteCrawler($maxNewsToFetch),
            $this->createBarronsSiteCrawler($maxNewsToFetch),
            $this->createMarketWatchSiteCrawler($maxNewsToFetch),
        ];
    }

    /**
     * @return ChannelInterface[]
     */
    public function createChannels(array $channelNames): array
    {
        $flipped = array_flip($channelNames);
        $channels = [];

        if (isset($flipped[EmailChannel::class])) {
            $channels[] = $this->createEmailChannel();
        }

        if (isset($flipped[SlackChannel::class])) {
            $channels[] = $this->createSlackChannel();
        }

        return $channels;
    }

    private function createCrawledInfoMapper(): CrawledInfoMapperInterface
    {
        return new CrawledInfoMapper(function (array $info): array {
            $info[Quote::URL] = $info[self::URLS][0];

            return $info;
        });
    }

    private function createFinanceYahooSiteCrawler(int $maxNewsToFetch): FinanceYahooSiteCrawler
    {
        return new FinanceYahooSiteCrawler([
            Quote::COMPANY_NAME => new JsonExtractor\QuoteSummaryStore\CompanyName(),
            Quote::REGULAR_MARKET_PRICE => new JsonExtractor\QuoteSummaryStore\RegularMarketPrice(),
            Quote::CURRENCY => new JsonExtractor\QuoteSummaryStore\Currency(),
            Quote::REGULAR_MARKET_CHANGE => new JsonExtractor\QuoteSummaryStore\RegularMarketChange(),
            Quote::REGULAR_MARKET_CHANGE_PERCENT => new JsonExtractor\QuoteSummaryStore\RegularMarketChangePercent(),
            Quote::MARKET_CAP => new JsonExtractor\QuoteSummaryStore\MarketCap(),
            Quote::LAST_TREND => new JsonExtractor\QuoteSummaryStore\RecommendationTrend(),
            Quote::LATEST_NEWS => new JsonExtractor\StreamStore\News($this->createNewsNormalizer($maxNewsToFetch)),
filter:
    dependency_paths: ["lib/*"]
            self::URLS => new JsonExtractor\RouteStore\ExternalUrl(),
        ]);
    }

    private function createNewsNormalizer(int $maxNewsToFetch): NewsNormalizer
    {
        return new NewsNormalizer(new DateTimeZone('Europe/Berlin'), $maxNewsToFetch);
    }

    private function createBarronsSiteCrawler(int $maxNewsToFetch): BarronsSiteCrawler
    {
        return new BarronsSiteCrawler([
            Quote::LATEST_NEWS => new Barrons\HtmlCrawler\News($this->createNewsNormalizer($maxNewsToFetch)),
        ]);
    }

    private function createMarketWatchSiteCrawler(int $maxNewsToFetch): MarketWatchSiteCrawler
    {
        return new MarketWatchSiteCrawler([
            Quote::LATEST_NEWS => new MarketWatch\HtmlCrawler\News($this->createNewsNormalizer($maxNewsToFetch)),
        ]);
    }

    private function createEmailChannel(string $templateName = 'email.twig'): EmailChannel
    {
        return new EmailChannel(
            $this->config->getToAddress(),
            new Mailer(new GmailSmtpTransport(
                $this->config->getMailerUsername(),
                $this->config->getMailerPassword()
            )),
            new TwigTemplateGenerator(
                $this->createTwigEnvironment(),
                $templateName
            )
        );
    }

    private function createSlackChannel(string $templateName = 'slack.twig'): SlackChannel
    {
        return new SlackChannel(
            $this->config->getSlackDestinyChannelId(),
            new HttpSlackClient(HttpClient::create([
                'auth_bearer' => $this->config->getSlackBotUserOauthAccessToken(),
            ])),
            new TwigTemplateGenerator(
                $this->createTwigEnvironment(),
                $templateName
            )
        );
    }

    private function createTwigEnvironment(): Environment
    {
        $loader = new FilesystemLoader($this->config->getTemplatesDir());
        $isDebug = $this->config->isDebug();
        $twig = new Environment($loader, ['debug' => $isDebug]);

        if ($isDebug) {
            $twig->addExtension(new DebugExtension());
        }

        return $twig;
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Chemaclass\StockTicker;
6
7		use Chemaclass\StockTicker\Domain\Crawler\Mapper\CrawledInfoMapper;
8		use Chemaclass\StockTicker\Domain\Crawler\Mapper\CrawledInfoMapperInterface;
9		use Chemaclass\StockTicker\Domain\Crawler\QuoteCrawler;
10		use Chemaclass\StockTicker\Domain\Crawler\QuoteCrawlerInterface;
11		use Chemaclass\StockTicker\Domain\Crawler\Site\Barrons;
12		use Chemaclass\StockTicker\Domain\Crawler\Site\Barrons\BarronsSiteCrawler;
13		use Chemaclass\StockTicker\Domain\Crawler\Site\FinanceYahoo\FinanceYahooSiteCrawler;
14		use Chemaclass\StockTicker\Domain\Crawler\Site\FinanceYahoo\JsonExtractor;
15		use Chemaclass\StockTicker\Domain\Crawler\Site\MarketWatch;
16		use Chemaclass\StockTicker\Domain\Crawler\Site\MarketWatch\MarketWatchSiteCrawler;
17		use Chemaclass\StockTicker\Domain\Crawler\Site\Shared\NewsNormalizer;
18		use Chemaclass\StockTicker\Domain\Crawler\SiteCrawlerInterface;
19		use Chemaclass\StockTicker\Domain\Notifier\Channel\Email\EmailChannel;
20		use Chemaclass\StockTicker\Domain\Notifier\Channel\Slack\HttpSlackClient;
21		use Chemaclass\StockTicker\Domain\Notifier\Channel\Slack\SlackChannel;
22		use Chemaclass\StockTicker\Domain\Notifier\Channel\TwigTemplateGenerator;
23		use Chemaclass\StockTicker\Domain\Notifier\ChannelInterface;
24		use Chemaclass\StockTicker\Domain\Notifier\Notifier;
25		use Chemaclass\StockTicker\Domain\Notifier\NotifierInterface;
26		use Chemaclass\StockTicker\Domain\Notifier\NotifierPolicy;
27		use Chemaclass\StockTicker\Domain\WriteModel\Quote;
28		use DateTimeZone;
29		use Symfony\Component\HttpClient\HttpClient;
30		use Symfony\Component\Mailer\Bridge\Google\Transport\GmailSmtpTransport;
31		use Symfony\Component\Mailer\Mailer;
32		use Twig\Environment;
33		use Twig\Extension\DebugExtension;
34		use Twig\Loader\FilesystemLoader;
35
36		final class StockTickerFactory implements StockTickerFactoryInterface
37		{
38		private const URLS = 'URLS';
39
40	4	private StockTickerConfigInterface $config;
41
42	4	public function __construct(StockTickerConfigInterface $config)
43	4	{
44		$this->config = $config;
45	4	}
46
47	4	public function createQuoteCrawler(SiteCrawlerInterface ...$siteCrawlers): QuoteCrawlerInterface
48	4	{
49	4	return new QuoteCrawler(
50	4	HttpClient::create(),
51		$this->createCrawledInfoMapper(),
52		...$siteCrawlers
53		);
54	2	}
55
56	2	public function createNotifier(NotifierPolicy $policy, ChannelInterface ...$channels): NotifierInterface
57		{
58		return new Notifier($policy, ...$channels);
59		}
60
61		/**
62	4	* @return Domain\Crawler\SiteCrawlerInterface[]
63		*/
64		public function createSiteCrawlers(int $maxNewsToFetch): array
65	4	{
66	4	return [
67		$this->createFinanceYahooSiteCrawler($maxNewsToFetch),
68		$this->createBarronsSiteCrawler($maxNewsToFetch),
69		$this->createMarketWatchSiteCrawler($maxNewsToFetch),
70		];
71		}
72
73	2	/**
74		* @return ChannelInterface[]
75	2	*/
76	2	public function createChannels(array $channelNames): array
77		{
78	2	$flipped = array_flip($channelNames);
79		$channels = [];
80
81		if (isset($flipped[EmailChannel::class])) {
82	2	$channels[] = $this->createEmailChannel();
83		}
84
85		if (isset($flipped[SlackChannel::class])) {
86	2	$channels[] = $this->createSlackChannel();
87		}
88
89	4	return $channels;
90		}
91	4
92	4	private function createCrawledInfoMapper(): CrawledInfoMapperInterface
93		{
94	4	return new CrawledInfoMapper(function (array $info): array {
95	4	$info[Quote::URL] = $info[self::URLS][0];
96
97		return $info;
98	4	});
99		}
100	4
101	4	private function createFinanceYahooSiteCrawler(int $maxNewsToFetch): FinanceYahooSiteCrawler
102	4	{
103	4	return new FinanceYahooSiteCrawler([
104	4	Quote::COMPANY_NAME => new JsonExtractor\QuoteSummaryStore\CompanyName(),
105	4	Quote::REGULAR_MARKET_PRICE => new JsonExtractor\QuoteSummaryStore\RegularMarketPrice(),
106	4	Quote::CURRENCY => new JsonExtractor\QuoteSummaryStore\Currency(),
107	4	Quote::REGULAR_MARKET_CHANGE => new JsonExtractor\QuoteSummaryStore\RegularMarketChange(),
108	4	Quote::REGULAR_MARKET_CHANGE_PERCENT => new JsonExtractor\QuoteSummaryStore\RegularMarketChangePercent(),
109	4	Quote::MARKET_CAP => new JsonExtractor\QuoteSummaryStore\MarketCap(),
110		Quote::LAST_TREND => new JsonExtractor\QuoteSummaryStore\RecommendationTrend(),
111		Quote::LATEST_NEWS => new JsonExtractor\StreamStore\News($this->createNewsNormalizer($maxNewsToFetch)),
		0 ignored issues – show Bug introduced 2020-12-15 16:58 UTC by Report Bug Copy Issue Report The type `Chemaclass\StockTicker\D...ractor\StreamStore\News` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
112		self::URLS => new JsonExtractor\RouteStore\ExternalUrl(),
113	4	]);
114		}
115	4
116		private function createNewsNormalizer(int $maxNewsToFetch): NewsNormalizer
117		{
118	4	return new NewsNormalizer(new DateTimeZone('Europe/Berlin'), $maxNewsToFetch);
119		}
120	4
121	4	private function createBarronsSiteCrawler(int $maxNewsToFetch): BarronsSiteCrawler
122		{
123		return new BarronsSiteCrawler([
124		Quote::LATEST_NEWS => new Barrons\HtmlCrawler\News($this->createNewsNormalizer($maxNewsToFetch)),
125		]);
126		}
127
128		private function createMarketWatchSiteCrawler(int $maxNewsToFetch): MarketWatchSiteCrawler
129		{
130		return new MarketWatchSiteCrawler([
131		Quote::LATEST_NEWS => new MarketWatch\HtmlCrawler\News($this->createNewsNormalizer($maxNewsToFetch)),
132		]);
133		}
134
135		private function createEmailChannel(string $templateName = 'email.twig'): EmailChannel
136		{
137		return new EmailChannel(
138		$this->config->getToAddress(),
139		new Mailer(new GmailSmtpTransport(
140		$this->config->getMailerUsername(),
141		$this->config->getMailerPassword()
142		)),
143		new TwigTemplateGenerator(
144		$this->createTwigEnvironment(),
145		$templateName
146		)
147		);
148		}
149
150		private function createSlackChannel(string $templateName = 'slack.twig'): SlackChannel
151		{
152		return new SlackChannel(
153		$this->config->getSlackDestinyChannelId(),
154		new HttpSlackClient(HttpClient::create([
155		'auth_bearer' => $this->config->getSlackBotUserOauthAccessToken(),
156		])),
157		new TwigTemplateGenerator(
158		$this->createTwigEnvironment(),
159		$templateName
160		)
161		);
162		}
163
164		private function createTwigEnvironment(): Environment
165		{
166		$loader = new FilesystemLoader($this->config->getTemplatesDir());
167		$isDebug = $this->config->isDebug();
168		$twig = new Environment($loader, ['debug' => $isDebug]);
169
170		if ($isDebug) {
171		$twig->addExtension(new DebugExtension());
172		}
173
174		return $twig;
175		}
176		}
177

Chemaclass / stock-ticker

Pull Request — master (#6)

StockTickerFactory::createMarketWatchSiteCrawler() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like