Laravoole\Wrapper\SwooleHttpWrapper

Complexity

Total Complexity

17

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	3

Test Coverage

Coverage

90.32%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	start()	0	10	2
A	onRequest()	0	13	4
B	handleStaticFile()	0	28	5
A	endResponse()	0	9	2
A	onWorkerStart()	0	5	1
A	ucHeaders()	0	18	2

<?php
namespace Laravoole\Wrapper;

use swoole_http_server;

use Symfony\Component\HttpFoundation\BinaryFileResponse;

class SwooleHttpWrapper extends Swoole implements ServerInterface
{
    use HttpTrait;

    public function __construct($host, $port)
    {
        $this->server = new swoole_http_server($host, $port);
    }

    public function start()
    {
        if (!empty($this->handler_config)) {
            $this->server->set($this->handler_config);

The method set() does not seem to exist on object<Laravoole\Workerman\Worker>.

        }
        $this->callbacks = array_merge([
            'Request' => [$this, 'onRequest'],
        ], $this->callbacks);
        parent::start();
    }

    public function onWorkerStart($serv, $worker_id)
    {
        parent::onWorkerStart($serv, $worker_id);
        $this->accept_gzip = config('laravoole.base_config.gzip');
    }

    public function onRequest($request, $response)
    {
        // convert request
        $this->ucHeaders($request);
        if (config('laravoole.base_config.deal_with_public')) {
            if ($status = $this->handleStaticFile($request, $response)) {
                return $status;
            }
        }
        // provide response callback
        $illuminateResponse = parent::handleRequest($request);

It seems like you call parent on a different method (handleRequest() instead of onRequest()). Are you sure this is correct? If so, you might want to change this to $this->handleRequest().

        return $this->handleResponse($response, $illuminateResponse, isset($request->header['Accept-Encoding']) ? $request->header['Accept-Encoding'] : '');
    }

    protected function ucHeaders($request)
    {
        // merge headers into server which ar filted by swoole
        // make a new array when php 7 has different behavior on foreach
        $new_header = [];
        $uc_header = [];
        foreach ($request->header as $key => $value) {
            $new_header['http_' . $key] = $value;
            $uc_header[ucwords($key, '-')] = $value;
        }
        $server = array_merge($request->server, $new_header);

        // swoole has changed all keys to lower case
        $server = array_change_key_case($server, CASE_UPPER);
        $request->server = $server;
        $request->header = $uc_header;
        return $request;
    }

    protected function handleStaticFile($request, $response)
    {
        static $public_path;
        if (!$public_path) {
            $app = $this->app;
            $public_path = $app->make('path.public');

        }

        $uri = $request->server['REQUEST_URI'];
        $file = realpath($public_path . $uri);
        if (is_file($file)) {
            if (!strncasecmp($file, $uri, strlen($public_path))) {
                $response->status(403);
                $response->end();
            } else {
                $response->header('Content-Type', get_mime_type($file));
                if (!filesize($file)) {
                    $response->end();
                } else {
                    $response->sendfile($file);
                }
            }
            return true;
        }
        return false;

    }

    public function endResponse($response, $content)
    {
        if (!is_string($content)) {
            $response->sendfile(realpath($content()));
        } else {
            // send content & close
            $response->end($content);
        }
    }

}