Nkey\LinkCheck\LinkCheckProvider

Complexity

Total Complexity

16

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

89.36%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	setOutput()	0	4	1
A	check()	0	21	4
B	extractAndCheckUrls()	0	26	6
A	checkSameSiteUrl()	0	14	4

<?php
/**
 * This file is part of Nkey/LinkCheck package
 * 
 * @package Nkey\LinkCheck
 */
namespace Nkey\LinkCheck;

use Generics\Client\HttpClientFactory;
use Generics\Socket\Url;
use Generics\Streams\StandardOutputStream;
use Generics\Streams\HttpStream;
use Generics\Util\UrlParser;
use Generics\Streams\OutputStream;

/**
 * This class provides the link checking functionality.
 * 
 * @author Maik Greubel <greubel@nkey.de>
 */
class LinkCheckProvider
{

    /**
     *
     * @var HttpStream
     */
    private $httpClient;

    /**
     *
     * @var OutputStream
     */
    private $output;

    /**
     *
     * @var Url
     */
    private $url;

    /**
     * Create a new instance of LinkCheckProvider
     * 
     * @param Url $url
     *            The url to check
     */
    public function __construct(Url $url)
    {
        $this->httpClient = HttpClientFactory::get($url);
        $this->output = new StandardOutputStream();
        $this->url = $url;
    }
    
    /**
     * Override the standard output stream using a custom output stream instance
     * 
     * @param OutputStream $stream
     */
    public function setOutput(OutputStream $stream)
    {
        $this->output = $stream;
    }

    /**
     * Perform check
     * - Retrieve the contents of url
     * - Extract all anchor links
     * - Check all anchor links for existance (response code < 400)
     *
     * @param array $options
     *            The options for check ('recursive' => perform a recursive check of all same-site-links)
     */
    public function check(array $options = array())
    {
        $this->httpClient->request('GET');
        
        if ($this->httpClient->getResponseCode() != 200) {
            $this->output->write("Invalid response code " . $this->httpClient->getResponseCode());
            return;
        }
        
        $response = "";
        $size = $this->httpClient->getPayload()->count();
        if (isset($this->httpClient->getHeaders()['Content-Length'])) {
            $size = $this->httpClient->getHeaders()['Content-Length'];
        }
        
        while ($this->httpClient->getPayload()->ready()) {
            $response .= $this->httpClient->getPayload()->read($size);
        }
        
        $this->extractAndCheckUrls($response, $options);
    }

    private function extractAndCheckUrls(string $response, array $options)
    {
        $matches = [];
        
        if (preg_match_all('#<a href="([^\"]*)">#', $response, $matches)) {
            array_shift($matches);
            $matches = $matches[0];
        }
        
        if (count($matches) == 0) {
            return;
        }
        
        foreach ($matches as $match) {
            if (substr($match, 0, 4) != 'http') {
                $match = sprintf("%s://%s:%d%s", $this->url->getScheme(), $this->url->getAddress(), $this->url->getPort(), $match);
            }
            $url = UrlParser::parseUrl($match);
            
            $this->output->write($url);
            if ($url->getAddress() == $this->url->getAddress()) {
                $this->checkSameSiteurl($url, $options);
            }
            $this->output->write("\n");
        }
    }

    private function checkSameSiteUrl(Url $url, array $options)
    {
        if (isset($options['recursive']) && $options['recursive'] == true) {
            $subProvider = new LinkCheckProvider($url);
            $subProvider->check($options);
        } else {
            $http = HttpClientFactory::get($url);
            $http->setTimeout(10);
            $http->request('HEAD');
            if ($http->getResponseCode() < 400) {
                $this->output->write(" OK");
            }
        }
    }
}