View GitHub Repository fastD

Schedule Inspection
Subscribe

Code Duplication    Length = 7-7 lines in 3 locations

src/Servitization/Server/TCPServer.php 1 location

@@ 42-48 (lines=7) @@
39 
        }
40 
        $data = Json::decode($data);
41 
        $request = new ServerRequest($data['method'], $data['path']);
42 
        if (isset($data['args'])) {
43 
            if ('GET' === $request->getMethod()) {
44 
                $request->withQueryParams($data['args']);
45 
            } else {
46 
                $request->withParsedBody($data['args']);
47 
            }
48 
        }
49 
        $response = app()->handleRequest($request);
50 
        $server->send($fd, (string) $response->getBody());
51 
        app()->shutdown($request, $response);

src/Servitization/Server/WebSocketServer.php 1 location

@@ 37-43 (lines=7) @@
34 
        $data = $frame->data;
35 
        $data = Json::decode($data);
36 
        $request = new ServerRequest($data['method'], $data['path']);
37 
        if (isset($data['args'])) {
38 
            if ('GET' === $request->getMethod()) {
39 
                $request->withQueryParams($data['args']);
40 
            } else {
41 
                $request->withParsedBody($data['args']);
42 
            }
43 
        }
44 
        $response = app()->handleRequest($request);
45 
        $server->push($frame->fd, (string) $response->getBody());
46 
        app()->shutdown($request, $response);

src/Servitization/Server/UDPServer.php 1 location

@@ 36-42 (lines=7) @@
33 
    {
34 
        $data = Json::decode($data);
35 
        $request = new ServerRequest($data['method'], $data['path']);
36 
        if (isset($data['args'])) {
37 
            if ('GET' === $request->getMethod()) {
38 
                $request->withQueryParams($data['args']);
39 
            } else {
40 
                $request->withParsedBody($data['args']);
41 
            }
42 
        }
43 
        $response = app()->handleRequest($request);
44 
        $server->sendto($clientInfo['address'], $clientInfo['port'], (string) $response->getBody());
45 
        app()->shutdown($request, $response);