SimpleSAML\Module\monitor\TestCase\Network\ConnectUri

Complexity

Total Complexity

9

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUri()	0	3	1
A	setContext()	0	3	1
A	setTimeout()	0	3	1
A	invokeTest()	0	30	3
A	initialize()	0	21	3

<?php

declare(strict_types=1);

namespace SimpleSAML\Module\monitor\TestCase\Network;

use SimpleSAML\Assert\Assert;
use SimpleSAML\Module\monitor\State;
use SimpleSAML\Module\monitor\TestData;
use SimpleSAML\Module\monitor\TestResult;

use function ini_get;
use function intval;
use function is_null;
use function is_resource;
use function openssl_x509_parse;
use function stream_context_get_params;
use function stream_socket_client;

final class ConnectUri extends \SimpleSAML\Module\monitor\TestCaseFactory
{
    /** @var integer */
    private int $timeout;

    /** @var resource */
    private $context;

    /** @var string */
    private string $uri;


    /**
     * @param \SimpleSAML\Module\monitor\TestData $testData
     *
     * @return void
     */
    protected function initialize(TestData $testData): void
    {
        $uri = $testData->getInputItem('uri');
        $context = $testData->getInputItem('context');

        if (is_null($context)) {
            $context = stream_context_create();
        }

        $timeout = $testData->getInputItem('timeout');
        $timeout = is_null($timeout) ? intval(ini_get("default_socket_timeout")) : $timeout;

        Assert::string($uri);
        Assert::resource($context);
        Assert::integer($timeout);

        $this->setUri($uri);

It seems like $uri can also be of type null; however, parameter $uri of SimpleSAML\Module\monitor\TestCase\Network\ConnectUri::setUri() does only seem to accept string, maybe add an additional type check?

        $this->setContext($context);
        $this->setTimeout($timeout);

        parent::initialize($testData);
    }


    /**
     * @param string $uri
     *
     * @return void
     */
    private function setUri(string $uri): void
    {
        $this->uri = $uri;
    }


    /**
     * @param resource $context
     *
     * @return void
     */
    private function setContext($context): void
    {
        $this->context = $context;
    }


    /**
     * @param integer $timeout
     *
     * @return void
     */
    private function setTimeout(int $timeout): void
    {
        $this->timeout = $timeout;
    }


    /**
     * @return void
     */
    public function invokeTest(): void
    {
        list($errno, $errstr) = [0, ''];
        $connection = stream_socket_client(
            $this->uri,
            $errno,
            $errstr,
            $this->timeout,
            STREAM_CLIENT_CONNECT,
            $this->context
        );

        $testResult = new TestResult('Network connection', $this->uri);

        if (is_resource($connection)) {
            $params = stream_context_get_params($connection);

            $testResult->addOutput($connection, 'connection');
            if (isset($params['options']['ssl']['peer_certificate'])) {
                $certData = openssl_x509_parse($params['options']['ssl']['peer_certificate']);
                $testResult->addOutput($certData, 'certData');
            }
            $testResult->setState(State::OK);
            $testResult->setMessage('Connection established');
        } else {
            $testResult->setState(State::ERROR);
            $testResult->setMessage($errstr . ' (' . $errno . ')');
        }

        $this->setTestResult($testResult);
    }
}