Cobak78\RancherApi\Clients\WSClient

Complexity

Total Complexity

1

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	socketConnect()	0	21	1

<?php

namespace Cobak78\RancherApi\Clients;

use Ratchet\Client\WebSocket;
use Ratchet\RFC6455\Messaging\Message;

/**
 * Class WSClient
 * @package Cobak78\RancherApi\Clients
 */
class WSClient
{

    /**
     * @param string $wsUrl
     * @param string $token
     */
    public function socketConnect(string $wsUrl, string $token)
    {
        /** @var $conn WebSocket */
        \Ratchet\Client\connect($wsUrl . '?token=' . $token)
            ->then(function($conn) {

                /** @var $msg Message */
                $conn->on('message', function($msg) use ($conn) {

                    $msg = base64_decode($msg->getPayload());

                    echo "Received: {$msg}\n";

                    $conn->close();
                });

            }, function ($e) {

                echo "Could not connect: {$e->getMessage()}\n";
            });
    }

}