Carpenstar\ByBitAPI\Core\Objects\WebSockets\WebSocketsPublicChannel

Complexity

Total Complexity

8

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
B	execute()	0	42	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;

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';
            $connection->onConnect = function ($connection) {
                $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic]));
            };

            $callback = $this->callback;

            $connection->onMessage = function ($connection, $message) use ($callback) {
                $message = json_decode($message, true);

                // Default DTO
                $responseDto = $this->getResponseClassname();

                if (isset($message['success']) && !$message['success']) {
                    // If api return exception data
                    $responseDto = ExceptionResponse::class;
                } else if (isset($message['success']) && $message['success']) {
                    // If stream return connection data
                    $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);
                }
            };
            $connection->connect();
        };

        Worker::runAll();
    }
}