Connection::broadcast() - Code Metrics - Inspection of "Dev server" - yiisoft/yii-debug - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#225)

by Dmitriy

created 2023-09-07 16:47 UTC

Connection::broadcast() A

↳ Parent: Connection

Complexity

Conditions	4
Paths	6

Size

Total Lines	17
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	4
eloc	13
c	1
b	0
f	0
nc	6
nop	1
dl	0
loc	17
rs	9.8333

<?php

/** @noinspection PhpComposerExtensionStubsInspection */

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\DevServer;

use Closure;
use RuntimeException;
use Socket;
use Throwable;

final class Connection
{
    public const DEFAULT_SOCKET_DIR = '/tmp/var-dumper';
    public const DEFAULT_SOCKET_URL = '/tmp/var-dumper-%d.sock';

    public function __construct(
        private Socket $socket,
    ) {
    }

    public static function create(): self
    {
        $socket = socket_create(AF_UNIX, SOCK_DGRAM, 0);

        return new self(
            $socket,
            /** @scrutinizer ignore-type */ $socket,
        );
    }

    public function bind(): void
    {
        $n = random_int(0, PHP_INT_MAX);
        $file = sprintf(self::DEFAULT_SOCKET_URL, $n);
        if (!socket_bind($this->socket, $file)) {
            $socket_last_error = socket_last_error($this->socket);

            throw new RuntimeException(
                sprintf(
                    'An error occurred while reading the socket. "socket_last_error" returned %d: "%s".',
                    $socket_last_error,
                    socket_strerror($socket_last_error),
                ),
            );
        }
    }

    public function broadcast(string $data): void
    {
        $files = glob(self::DEFAULT_SOCKET_DIR . '-*.sock', GLOB_NOSORT);
        //echo 'Files: ' . implode(', ', $files) . "\n";
        foreach ($files as $file) {
            $socket = socket_create(AF_UNIX, SOCK_DGRAM, 0);
            if (!@socket_connect($socket, $file)) {
                @unlink($file);
                /** @scrutinizer ignore-unhandled */ @unlink($file);
                continue;
            }
            try {
                socket_send($socket, $data, strlen($data), 0);
            } catch (Throwable $e) {
                unlink($file);
                throw $e;
            } finally {
                socket_close($socket);
            }
        }
    }

    public function close(): void
    {
        @socket_getsockname($this->socket, $path);
        /** @scrutinizer ignore-unhandled */ @socket_getsockname($this->socket, $path);
        @socket_close($this->socket);
        /** @scrutinizer ignore-unhandled */ @socket_close($this->socket);
        @unlink($path);
        /** @scrutinizer ignore-unhandled */ @unlink($path);
    }

    public function read(Closure $onSuccess, ?Closure $onError = null): \Generator
    {
        while (true) {
            if (!socket_recvfrom($this->socket, $buffer, 32768, MSG_DONTWAIT, $ip, $port)) {
                $socket_last_error = socket_last_error($this->socket);
                if ($socket_last_error === 35) {
                    continue;
                }
                $this->close();
                if ($onError !== null) {
                    yield $onError($socket_last_error);
                    break;
                }
                throw new RuntimeException(
                    sprintf(
                        'An error occurred while reading the socket. socket_last_error returned %d: "%s".',
                        $socket_last_error,
                        socket_strerror($socket_last_error)
                    ),
                );
            }
            yield $onSuccess($buffer, $ip, $port);
        }
    }
}


yiisoft / yii-debug

Pull Request — master (#225)

Connection::broadcast() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like