kalanis\RemoteRequest\Sockets\Stream

Complexity

Total Complexity

6

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	setContextOptions()	0	4	1
A	remotePointer()	0	29	5

<?php

namespace kalanis\RemoteRequest\Sockets;


use kalanis\RemoteRequest\Interfaces\IConnectionParams;
use kalanis\RemoteRequest\RequestException;


/**
 * Class Stream
 * @package kalanis\RemoteRequest\Sockets
 * Network pointer to the remote server - method Stream
 * Because that little shit cannot set context options to Fsocket; namely devel certs
 */
class Stream extends ASocket
{
    /** @var array<string, string|array<string, string>> */
    protected array $contextOptions = [];

    /**
     * @param array<string, string|array<string, string>> $contextOptions
     * @return $this
     */
    public function setContextOptions(array $contextOptions = []): self
    {
        $this->contextOptions = $contextOptions;
        return $this;
    }

    /**
     * @param IConnectionParams $params
     * @throws RequestException
     * @return resource
     * @codeCoverageIgnore because accessing remote source
     */
    protected function remotePointer(IConnectionParams $params)
    {
        // Make the request to the server
        // If possible, securely post using HTTPS, your PHP server will need to be SSL enabled

        // example array of context options for skipping devel certs
//        $contextOptions = [
//            'ssl' => [
//                'verify_peer' => !DEVEL_ENVIRONMENT, // You could skip all of the trouble by changing this to false, but it's WAY uncool for security reasons. // kecy...
//                'cafile' => '/etc/ssl/certs/cacert.pem',
//                'CN_match' => 'example.com', // Change this to your certificates Common Name (or just comment this line out if not needed)
//                'ciphers' => 'HIGH:!SSLv2:!SSLv3',
//                'disable_compression' => true,
//            ],
//        ];

        $context = stream_context_create($this->contextOptions);
        $link = $params->getSchema() . $params->getHost() . (!empty($params->getPort()) ? ':' . $params->getPort() : '' );
        $timeout = is_null($params->getTimeout()) ? 10.0 : floatval($params->getTimeout()); // do NOT ask - php7 + phpstan

        if (!$filePointer = stream_socket_client($link, $errno, $errStr, $timeout, STREAM_CLIENT_CONNECT, $context)) {
            throw new RequestException($this->getRRLang()->rrSocketCannotConnect());
        }

        if (!is_null($params->getTimeout())) {
            stream_set_timeout($filePointer, intval($params->getTimeout()));
        }

        return $filePointer;
    }
}