Seasx\SeasLogger\Kafka\Socket\SocketIO

Complexity

Total Complexity

15

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	check()	0	3	1
A	send()	0	12	4
A	close()	0	3	1
A	recv()	0	4	1
B	createConnection()	0	23	7
A	reconnect()	0	3	1

<?php
declare(strict_types=1);

namespace Seasx\SeasLogger\Kafka\Socket;

use Co;
use Co\Socket;
use Exception;

/**
 * Class SocketIO
 * @package Seasx\SeasLogger\Kafka\Socket
 */
class SocketIO
{
    /** @var bool */
    private $recv = false;
    /** @var Socket */
    private $connection;
    /** @var array */
    private $config = [];

    /**
     * @param string $data
     * @param float $timeout
     * @return int
     * @throws Exception
     */
    public function send(string $data, float $timeout = -1): int
    {
        $ln = strlen($data);
        while ($data && $ln > 0) {
            $result = $this->connection->sendAll($data, $timeout);

Are you sure the assignment to $result is correct as $this->connection->sendAll($data, $timeout) targeting Swoole\Coroutine\Socket::sendAll() seems to always return null.

            if ($result === false) {
                $this->reconnect();
            }
            $data = substr($data, $result);
        }
        $this->recv = false;
        return $ln;
    }

    /**
     * @throws Exception
     */
    public function reconnect(): void
    {
        $this->createConnection();
    }

    /**
     * @param array $config
     * @throws Exception
     */
    public function createConnection(array $config = []): void
    {
        !empty($config) && ($this->config = $config);
        $client = new Socket(AF_INET, SOCK_STREAM, 0);
        list($host, $port) = explode(':', $this->config['uri']);
        $maxRetry = $this->config['retry'];
        $reconnectCount = 0;
        while (true) {
            $isConnect = $this->config['timeout'] ? $client->connect($host, (int)$port,

Are you sure the usage of $client->connect($host, (int)$port, $this->config['timeout']) targeting Swoole\Coroutine\Socket::connect() seems to always return null.

                $this->config['timeout']) : $client->connect($host, (int)$port);

Are you sure the usage of $client->connect($host, (int)$port) targeting Swoole\Coroutine\Socket::connect() seems to always return null.

            if (!$isConnect) {
                $reconnectCount++;
                if ($maxRetry > 0 && $reconnectCount >= $maxRetry) {
                    $error = sprintf('Service connect fail error=%s host=%s port=%s', socket_strerror($client->errCode),
                        $host, $port);
                    throw new Exception($error);
                }
                Co::sleep($this->config['sleep']);
            } else {
                break;
            }
        }
        $this->connection = $client;
    }

    /**
     * @param int $length
     * @param float $timeout
     * @return string
     */
    public function recv(int $length = 65535, float $timeout = -1): string
    {
        $data = $this->connection->recvAll($length, $timeout);

Are you sure the assignment to $data is correct as $this->connection->recvAll($length, $timeout) targeting Swoole\Coroutine\Socket::recvAll() seems to always return null.

        return $data;

The expression return $data returns the type null which is incompatible with the type-hinted return string.

    }

    /**
     * @return bool
     */
    public function check(): bool
    {
        return $this->connection->errCode === 0;
    }

    /**
     * @return bool
     */
    public function close(): bool
    {
        return $this->connection->close();

Are you sure the usage of $this->connection->close() targeting Swoole\Coroutine\Socket::close() seems to always return null.

The expression return $this->connection->close() returns the type null which is incompatible with the type-hinted return boolean.

    }
}