Spatie\Crawler\ObserverCollection

Complexity

Total Complexity

17

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addObserver()	0	4	1
A	crawled()	0	10	2
A	crawlFailed()	0	10	2
A	current()	0	4	1
A	offsetGet()	0	4	2
A	offsetSet()	0	8	2
A	offsetExists()	0	4	1
A	offsetUnset()	0	4	1
A	next()	0	4	1
A	key()	0	4	1
A	valid()	0	4	1
A	rewind()	0	4	1

<?php

namespace Spatie\Crawler;

use Iterator;
use ArrayAccess;
use Psr\Http\Message\ResponseInterface;
use GuzzleHttp\Exception\RequestException;

class ObserverCollection implements ArrayAccess, Iterator
{
    /** @var \Spatie\Crawler\CrawlObserver[] */
    protected $observers;

    /** @var int */
    protected $position;

    public function __construct(array $observers = [])
    {
        $this->observers = $observers;
        $this->position = 0;
    }

    public function addObserver(CrawlObserver $observer)
    {
        $this->observers[] = $observer;
    }

    public function crawled(CrawlUrl $crawlUrl, ResponseInterface $response)
    {
        foreach ($this->observers as $crawlObserver) {
            $crawlObserver->crawled(
                $crawlUrl->url,
                $response,
                $crawlUrl->foundOnUrl
            );
        }
    }

    public function crawlFailed(CrawlUrl $crawlUrl, RequestException $exception)
    {
        foreach ($this->observers as $crawlObserver) {
            $crawlObserver->crawlFailed(
                $crawlUrl->url,
                $exception,
                $crawlUrl->foundOnUrl
            );
        }
    }

    public function current()
    {
        return $this->observers[$this->position];
    }

    public function offsetGet($offset)
    {
        return isset($this->observers[$offset]) ? $this->observers[$offset] : null;
    }

    public function offsetSet($offset, $value)
    {
        if (is_null($offset)) {
            $this->observers[] = $value;
        } else {
            $this->observers[$offset] = $value;
        }
    }

    public function offsetExists($offset)
    {
        return isset($this->observers[$offset]);
    }

    public function offsetUnset($offset)
    {
        unset($this->observers[$offset]);
    }

    public function next()
    {
        $this->position++;
    }

    public function key()
    {
        return $this->position;
    }

    public function valid()
    {
        return isset($this->observers[$this->position]);
    }

    public function rewind()
    {
        $this->position = 0;
    }
}