Fructify\Reload\Protocol\WebSocketProtocol

Complexity

Total Complexity

7

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	handshake()	0	8	2
A	initEvent()	0	7	1
A	onData()	0	11	3

<?php
namespace Fructify\Reload\Protocol;

use Fructify\Reload\Application\ServerApplication;
use React\Socket\Connection as SocketConnection;
use Symfony\Component\HttpFoundation;
use Fructify\Reload\Response\Response;
use Symfony\Component\Console\Output\OutputInterface;

class WebSocketProtocol
{
    protected $websocket;
    protected $conn;
    protected $app;

    public function __construct(SocketConnection $conn, ServerApplication $app, HttpFoundation\Request $request)
    {
        $this->app = $app;
        $this->conn = $conn;
        $this->initEvent();
        $this->handshake($request);
        $this->app->getOutput()->writeln(strftime('%T')." - info - Browser connected", OutputInterface::VERBOSITY_VERBOSE);
        new LivereloadProtocol($conn, $app);
    }

    protected function handshake(HttpFoundation\Request $request)
    {
        if (!($handshakeResponse = $this->websocket->handshake($request))) {
            $this->conn->write(new Response('bad protocol', 400), true);

The call to Connection::write() has too many arguments starting with true.

            return;
        }
        $this->conn->write($handshakeResponse);
    }

    protected function initEvent()
    {
        $this->websocket = new WebSocket\WebSocket();
        $this->conn->on('data', function($data){
            $this->onData($data);
        });
    }

    protected function onData($data)
    {
        $frame = $this->websocket->onMessage($data);
        if(!($frame instanceof WebSocket\Frame)) {
            return;
        }
        if(($command = json_decode($frame->getData(), true)) === null){
            return;
        }
        $this->conn->emit('command', array($command));
    }
}