TreeHouse\IoBundle\Scrape\EventListener\ScrapeLoggingSubscriber

Complexity

Total Complexity

8

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	9

Test Coverage

Coverage

31.43%

Importance

Changes	3
Bugs	1	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getSubscribedEvents()	0	11	1
A	onItemSuccess()	0	4	1
A	onItemSkipped()	0	5	1
A	onItemFailed()	0	5	1
A	onScrapeNextUrl()	0	4	1
A	onRateLimitReached()	0	5	1
A	onScrapeUrlNotOk()	0	9	1

<?php

namespace TreeHouse\IoBundle\Scrape\EventListener;

use GuzzleHttp\Psr7\Response;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use TreeHouse\Feeder\Event\FailedItemModificationEvent;
use TreeHouse\Feeder\FeedEvents;
use TreeHouse\IoBundle\Scrape\Event\FailedItemEvent;
use TreeHouse\IoBundle\Scrape\Event\RateLimitEvent;
use TreeHouse\IoBundle\Scrape\Event\ScrapeResponseEvent;
use TreeHouse\IoBundle\Scrape\Event\ScrapeUrlEvent;
use TreeHouse\IoBundle\Scrape\Event\SkippedItemEvent;
use TreeHouse\IoBundle\Scrape\Event\SuccessItemEvent;
use TreeHouse\IoBundle\Scrape\ScraperEvents;

class ScrapeLoggingSubscriber implements EventSubscriberInterface
{
    /**
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * @param LoggerInterface $logger
     */
    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    /**
     * @inheritdoc
     */
    public static function getSubscribedEvents()
    {
        return [
            ScraperEvents::ITEM_SUCCESS => 'onItemSuccess',
            ScraperEvents::ITEM_FAILED => 'onItemFailed',
            ScraperEvents::ITEM_SKIPPED => 'onItemSkipped',
            ScraperEvents::SCRAPE_NEXT_URL => 'onScrapeNextUrl',
            ScraperEvents::RATE_LIMIT_REACHED => 'onRateLimitReached',
            ScraperEvents::SCRAPE_URL_NOT_OK => 'onScrapeUrlNotOk',
        ];
    }

    /**
     * @param SuccessItemEvent $event
     */
    public function onItemSuccess(SuccessItemEvent $event)
    {
        $this->logger->info(sprintf('✎  updated: %s', (string) $event->getItem()));
    }

    /**
     * @param SkippedItemEvent $event
     */
    public function onItemSkipped(SkippedItemEvent $event)
    {
        $this->logger->info(sprintf('#  skipped: %s', (string) $event->getItem()));
        $this->logger->debug(sprintf('    reason: %s', $event->getReason()));
    }

    /**
     * @param FailedItemEvent $event
     */
    public function onItemFailed(FailedItemEvent $event)
    {
        $this->logger->warning(sprintf('✘   failed: %s', (string) $event->getItem()));
        $this->logger->debug(sprintf('    reason: %s', $event->getReason()));
    }

    /**
     * @param ScrapeUrlEvent $event
     */
    public function onScrapeNextUrl(ScrapeUrlEvent $event)
    {
        $this->logger->debug(sprintf('⇒  next url: %s', (string) $event->getUrl()));
    }

    /**
     * @param RateLimitEvent $event
     */
    public function onRateLimitReached(RateLimitEvent $event)
    {
        $seconds = $event->getRetryDate()->getTimestamp() - time();
        $this->logger->debug(sprintf('Rate limit reached, try again after %d seconds', $seconds));
    }

    /**
     * @param ScrapeResponseEvent $event
     */
    public function onScrapeUrlNotOk(ScrapeResponseEvent $event)
    {
        $response = $event->getResponse();

        $code = $response->getStatusCode();
        $text = (new Response($code))->getReasonPhrase();

        $this->logger->debug(sprintf('Server replied with response %d (%s)', $code, $text));
    }
}