whm\Smoke\Scanner\Scanner

Complexity

Total Complexity

12

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	7
Bugs	1	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getStatus()	0	4	1
A	__construct()	0	11	1
B	scan()	0	29	5
B	checkResponse()	0	28	5

<?php

namespace whm\Smoke\Scanner;

use Ivory\HttpAdapter\HttpAdapterInterface;
use phmLabs\Components\Annovent\Dispatcher;
use phmLabs\Components\Annovent\Event\Event;
use whm\Smoke\Extensions\SmokeResponseRetriever\Retriever\Retriever;
use whm\Smoke\Http\Response;
use whm\Smoke\Rules\ValidationFailedException;

class Scanner
{
    const ERROR = 'error';
    const PASSED = 'passed';

    private $rules;
    private $eventDispatcher;

    private $responseRetriever;

    private $status = 0;

    public function __construct(array $rules, HttpAdapterInterface $client, Dispatcher $eventDispatcher, Retriever $responseRetriever)
    {
        $eventDispatcher->simpleNotify('Scanner.Init', array('rules' => $rules, 'httpClient' => $client, 'dispatcher' => $eventDispatcher));

        $this->rules = $rules;
        $this->eventDispatcher = $eventDispatcher;

        $this->responseRetriever = $responseRetriever;

        $this->eventDispatcher->simpleNotify('Scanner.Init.ResponseRetriever', array('responseRetriever' => $this->responseRetriever));
    }

    public function scan()
    {
        $this->eventDispatcher->simpleNotify('Scanner.Scan.Begin');

        while (($response = $this->responseRetriever->next()) && !$this->eventDispatcher->notifyUntil(new Event('Scanner.Scan.isStopped'))) {

            // this is the url filter
            if ($this->eventDispatcher->notifyUntil(new Event('Scanner.ProcessHtml.isFiltered', array('uri' => $response->getUri())))) {
                continue;
            }

            $resultArray = $this->checkResponse($response);

            $result = new Result($response->getUri(),
                $resultArray['type'],
                $response,
                '',
                $resultArray['time']);

            if ($result->isFailure()) {
                $result->setMessages($resultArray['messages']);
                $this->status = 1;
            }

            $this->eventDispatcher->simpleNotify('Scanner.Scan.Validate', array('result' => $result));
        }

        $this->eventDispatcher->simpleNotify('Scanner.Scan.Finish');
    }

    public function getStatus()
    {
        return $this->status;
    }

    private function checkResponse(Response $response)
    {
        $messages = [];

        $startTime = microtime(true);
        foreach ($this->rules as $name => $rule) {
            if ($this->eventDispatcher->notifyUntil(new Event('Scanner.CheckResponse.isFiltered', array('ruleName' => $name, 'rule' => $rule, 'response' => $response)))) {
                continue;
            }
            try {
                $rule->validate($response);
            } catch (ValidationFailedException $e) {
                $messages[$name] = $e->getMessage();
            }
        }
        $endTime = microtime(true);

        // calculate time in seconds
        $time = round(($endTime - $startTime) * 1000, 5);

        if (count($messages) > 0) {
            $resultArray = ['messages' => $messages, 'time' => $time, 'type' => self::ERROR];
        } else {
            $resultArray = ['messages' => [], 'time' => $time, 'type' => self::PASSED];
        }

        return $resultArray;
    }
}