Yiisoft\VarDumper\Handler\StreamHandler

Complexity

Total Complexity

11

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Test Coverage

Coverage

57.58%

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	withEncoder()	0	5	1
A	writeToStream()	0	3	1
A	initializeStream()	0	10	3
A	__construct()	0	8	3
A	handle()	0	18	3

<?php

declare(strict_types=1);

namespace Yiisoft\VarDumper\Handler;

use RuntimeException;
use Yiisoft\VarDumper\HandlerInterface;

final class StreamHandler implements HandlerInterface
{
    /**
     * @var callable
     */
    private $encoder;
    /**
     * @var null|resource
     */
    private $stream = null;

    public function __construct(
        private $uri = 'udp://127.0.0.1:8890'
    ) {
        if (!is_string($this->uri) && !is_resource($this->uri)) {

The condition is_resource($this->uri) is always false.

The condition is_string($this->uri) is always false.

            throw new \InvalidArgumentException(
                sprintf(
                    'Argument $uri must be a string or a resource, "%s" given.',
                    gettype($this->uri)
                )
            );
        }
    }

    /**
     * Sends encode with {@see \json_encode()} function $variable to a UDP socket.
     */
    public function handle(mixed $variable, int $depth, bool $highlight = false): void
    {
        $data = ($this->encoder ?? 'json_encode')($variable);
        if (!is_string($data)) {
            throw new RuntimeException(
                sprintf(
                    'Encoder must return a string, %s returned.',
                    gettype($data)
                )
            );
        }

        $this->initializeStream();

        if (!$this->writeToStream($data)) {
            $this->initializeStream();

            $this->writeToStream($data);
        }
    }

    public function withEncoder(callable $encoder): HandlerInterface
    {
        $new = clone $this;
        $new->encoder = $encoder;
        return $new;
    }

    private function initializeStream(): void
    {
        if (is_string($this->uri)) {

The condition is_string($this->uri) is always false.

            $this->stream = fsockopen($this->uri);
        } else {
            $this->stream = $this->uri;

It seems like $this->uri of type mixed is incompatible with the declared type null|resource of property $stream.

        }

        if (!is_resource($this->stream)) {

The condition is_resource($this->stream) is always false.

            throw new RuntimeException('Cannot initialize a stream.');
        }
    }

    private function writeToStream(bool|string $data): bool
    {
        return @fwrite($this->stream, $data) !== false;

It seems like $data can also be of type boolean; however, parameter $data of fwrite() does only seem to accept string, maybe add an additional type check?

    }
}