Chemaclass\StockTicker\Infrastructure\Command\CrawlCommand

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	16	1
A	printCrawResult()	0	14	3
A	createStockTickerFacade()	0	4	1
A	execute()	0	19	2

<?php

declare(strict_types=1);

namespace Chemaclass\StockTicker\Infrastructure\Command;

use Chemaclass\StockTicker\Domain\Crawler\CrawlResult;
use Chemaclass\StockTicker\StockTickerConfig;
use Chemaclass\StockTicker\StockTickerFacade;
use Chemaclass\StockTicker\StockTickerFactory;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

final class CrawlCommand extends Command
{
    private const DEFAULT_MAX_NEWS_TO_FETCH = 2;

    protected function configure(): void
    {
        $this
            ->setName('crawl')
            ->setDescription('It crawls the websites and fetch their latest news')
            ->addArgument(
                'symbols',
                InputArgument::IS_ARRAY|InputArgument::REQUIRED,
                'Which stock symbols do you want to crawl?'
            )
            ->addOption(
                'maxNews',
                'm',
                InputArgument::OPTIONAL,
                'Which stock symbols do you want to crawl?',
                self::DEFAULT_MAX_NEWS_TO_FETCH
            );
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $symbols = (array) $input->getArgument('symbols');

        $txt = sprintf('Crawling stock %s...', implode(', ', $symbols));
        $output->writeln($txt);
        $facade = $this->createStockTickerFacade();

        $crawlResult = $facade->crawlStock($symbols, (int) $input->getOption('maxNews'));

        if ($crawlResult->isEmpty()) {
            $output->writeln('Nothing new here...');

            return Command::FAILURE;
        }

        $this->printCrawResult($output, $crawlResult);

        return Command::SUCCESS;
    }

    private function createStockTickerFacade(): StockTickerFacade
    {
        return new StockTickerFacade(
            new StockTickerFactory(new StockTickerConfig())
        );
    }

    private function printCrawResult(OutputInterface $output, CrawlResult $crawlResult): void
    {
        $output->writeln('~~~~~~~~~~~~~~~~~~~~~~~~~~');
        $output->writeln('~~~~~~ Crawl result ~~~~~~');
        $output->writeln('~~~~~~~~~~~~~~~~~~~~~~~~~~');

        foreach ($crawlResult->getCompaniesGroupedBySymbol() as $symbol => $quote) {
            $output->writeln($symbol);

            foreach ($quote->toArray() as $key => $value) {
                $output->writeln(sprintf('# %s => %s', $key, json_encode($value)));
            }

            $output->writeln('');
        }
    }
}