VDB\Spider\StatsHandler

Complexity

Total Complexity

12

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes	4
Bugs	0	Features	1

12 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	10	1
A	setSpiderId()	0	4	1
A	getSpiderId()	0	4	1
A	addToQueued()	0	4	1
A	addToPersisted()	0	4	1
A	addToFiltered()	0	4	1
A	addToFailed()	0	4	1
A	getQueued()	0	4	1
A	getPersisted()	0	4	1
A	getFiltered()	0	4	1
A	getFailed()	0	4	1
A	toString()	0	16	1

<?php
/**
 * @author Matthijs van den Bos <matthijs@vandenbos.org>
 * @copyright 2013 Matthijs van den Bos
 */

namespace VDB\Spider;

use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\EventDispatcher\GenericEvent;
use VDB\Uri\UriInterface;

use VDB\Spider\Event\SpiderEvents;

class StatsHandler implements EventSubscriberInterface
{
    protected $spiderId;

    protected $persisted = array();

    protected $queued = array();

    protected $filtered = array();

    protected $failed = array();

    public static function getSubscribedEvents()
    {
        return array(
            SpiderEvents::SPIDER_CRAWL_FILTER_POSTFETCH => 'addToFiltered',
            SpiderEvents::SPIDER_CRAWL_FILTER_PREFETCH => 'addToFiltered',
            SpiderEvents::SPIDER_CRAWL_POST_ENQUEUE => 'addToQueued',
            SpiderEvents::SPIDER_CRAWL_RESOURCE_PERSISTED => 'addToPersisted',
            SpiderEvents::SPIDER_CRAWL_ERROR_REQUEST => 'addToFailed'
        );
    }

    public function setSpiderId($spiderId)
    {
        $this->spiderId = $spiderId;
    }

    public function getSpiderId()
    {
        return $this->spiderId;
    }

    public function addToQueued(GenericEvent $event)
    {
        $this->queued[] = $event->getArgument('uri');
    }

    public function addToPersisted(GenericEvent $event)
    {
        $this->persisted[] = $event->getArgument('uri');
    }

    public function addToFiltered(GenericEvent $event)
    {
        $this->filtered[] = $event->getArgument('uri');
    }

    public function addToFailed(GenericEvent $event)
    {
        $this->failed[$event->getArgument('uri')->toString()] = $event->getArgument('message');
    }

    /**
     * @return UriInterface[]
     */
    public function getQueued()
    {
        return $this->queued;
    }

    /**
     * @return UriInterface[]
     */
    public function getPersisted()
    {
        return $this->persisted;
    }

    /**
     * @return Filterable[]
     */
    public function getFiltered()
    {
        return $this->filtered;
    }

    /**
     * @return array of form array($uriString, $reason)
     */
    public function getFailed()
    {
        return $this->failed;
    }

    public function toString()
    {
        $spiderId = $this->getSpiderId();
        $queued = $this->getQueued();
        $filtered = $this->getFiltered();
        $failed = $this->getFailed();

        $string = '';

        $string .= "\n\nSPIDER ID: " . $spiderId;
        $string .= "\n  ENQUEUED:  " . count($queued);
        $string .= "\n  SKIPPED:   " . count($filtered);
        $string .= "\n  FAILED:    " . count($failed);

        return $string;
    }
}