Carpenstar\ByBitAPI\Core\Objects\WebSockets\WebSocketsPublicChannel

Complexity

Total Complexity

8

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
B	execute()	0	69	7

<?php

namespace Carpenstar\ByBitAPI\Core\Objects\WebSockets;

use Carpenstar\ByBitAPI\Core\Auth\Credentials;
use Carpenstar\ByBitAPI\Core\Objects\ExceptionResponse;
use Carpenstar\ByBitAPI\Core\Objects\WebSockets\Entity\WebSocketConnectionResponse;
use Workerman\Worker;

The type Workerman\Worker was not found. Maybe you did not declare it correctly or list all dependencies?

use Workerman\Connection\AsyncTcpConnection;

The type Workerman\Connection\AsyncTcpConnection was not found. Maybe you did not declare it correctly or list all dependencies?

use Carpenstar\ByBitAPI\Core\Builders\ResponseDtoBuilder;
use Carpenstar\ByBitAPI\Core\Interfaces\IResponseDataInterface;
use Carpenstar\ByBitAPI\Core\Interfaces\IChannelHandlerInterface;
use Carpenstar\ByBitAPI\Core\Interfaces\IWebSocketArgumentInterface;
use Carpenstar\ByBitAPI\Core\Interfaces\IWebSocketsChannelInterface;
use Workerman\Lib\Timer;

The type Workerman\Lib\Timer was not found. Maybe you did not declare it correctly or list all dependencies?

abstract class WebSocketsPublicChannel implements IWebSocketsChannelInterface
{
    public const CHANNEL_ACCESS = 'public';
    protected string $hostStream;
    protected array $topic;
    protected string $operation;
    protected string $streamType;
    protected Worker $worker;
    protected IChannelHandlerInterface $callback;
    protected IResponseDataInterface $response;

    public function __construct(
        IWebSocketArgumentInterface $argument,
        Credentials $credentials,
        IChannelHandlerInterface $callback
    ) {
        $this->worker = new Worker();
        $this->streamType = $argument->getStreamType();
        $this->topic = $argument->getTopic();
        $this->operation = $this->getOperation();

The method getOperation() does not exist on Carpenstar\ByBitAPI\Core\Objects\WebSockets\WebSocketsPublicChannel.

        $this->hostStream = $credentials->getHost();
        $this->callback = $callback;
    }

    /**
     * @return void
     */
    public function execute(): void
    {
        $this->worker->onWorkerStart = function () {

            $connection = new AsyncTcpConnection($this->hostStream.'/'.self::CHANNEL_ACCESS.'/'.$this->streamType);
            $connection->transport = 'ssl';

            $heartbeatTimerId = Timer::add(20, function() use ($connection) {
                $connection->send(json_encode(["op" => "ping"]));
            });

            /**
             * Обработка соединения
             *
             * @param $connection
             * @return void
             */
            $connection->onConnect = function ($connection) use (&$heartbeatTimerId) {

The import $heartbeatTimerId is not used and could be removed.

                $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic]));
            };

            $callback = $this->callback;

            /**
             * Обработка сообщений
             *
             * @param $connection
             * @param $message
             * @return void
             * @throws \Exception
             */
            $connection->onMessage = function ($connection, $message) use ($callback) {
                $message = json_decode($message, true);
                $responseDto = $this->getResponseClassname($this->streamType);

                if (isset($message['success']) && !$message['success']) {
                    $responseDto = ExceptionResponse::class;
                } else if (isset($message['success']) && $message['success']) {
                    $responseDto = WebSocketConnectionResponse::class;
                }

                $dtoMessage = ResponseDtoBuilder::make($responseDto, $message);

                switch ($responseDto) {
                    case WebSocketConnectionResponse::class:
                        $callback->connectionHandle($dtoMessage, $connection);
                        break;
                    case ExceptionResponse::class:
                        $callback->apiExceptionHandler($dtoMessage, $connection);
                        break;
                    default:
                        $callback->handle($dtoMessage, $connection);
                }
            };

            /**
             * При закрытии соединения удаляем таймер
             *
             * @param $connection
             * @return void
             */
            $this->worker->onClose = function ($connection) use (&$heartbeatTimerId) {
                Timer::del($heartbeatTimerId);
            };

            $connection->connect();
        };

        Worker::runAll();
    }
}