FastD\Servitization\Server\WebSocketServer

Complexity

Total Complexity

4

Size/Duplication

Total Lines	32
Duplicated Lines	21.88 %

Coupling/Cohesion

Components	0
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	doMessage()	7	21	4

<?php
/**
 * @author    jan huang <bboyjanhuang@gmail.com>
 * @copyright 2016
 *
 * @see      https://www.github.com/janhuang
 * @see      http://www.fast-d.cn/
 */

namespace FastD\Servitization\Server;

use FastD\Http\ServerRequest;
use FastD\Packet\Json;
use FastD\Servitization\OnWorkerStart;
use FastD\Swoole\Server\WebSocket;
use swoole_server;
use swoole_websocket_frame;

/**
 * Class WebSocketServer.
 */
class WebSocketServer extends WebSocket
{
    use OnWorkerStart;

    /**
     * @param swoole_server          $server
     * @param swoole_websocket_frame $frame
     *
     * @return mixed
     */
    public function doMessage(swoole_server $server, swoole_websocket_frame $frame)
    {
        $data = $frame->data;
        $data = Json::decode($data);
        $request = new ServerRequest($data['method'], $data['path']);
        if (isset($data['args'])) {

This code seems to be duplicated across your project.

            if ('GET' === $request->getMethod()) {
                $request->withQueryParams($data['args']);

$data['args'] is of type string, but the function expects a array.

            } else {
                $request->withParsedBody($data['args']);

$data['args'] is of type string, but the function expects a null|array|object.

            }
        }
        try {
            $response = app()->handleRequest($request);
        } catch (\Exception $e) {
            $response = app()->handleException($e);
        }
        $server->push($frame->fd, (string) $response->getBody());

        return 0;
    }
}