Laravoole\Wrapper\SwooleFastCGIWrapper

Complexity

Total Complexity

11

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

97.3%

Importance

Changes	1
Bugs	1	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onReceive()	0	4	1
A	requestCallback()	0	4	1
A	sendCallback()	0	4	1
A	onWorkerStart()	0	10	1
A	start()	0	16	3
A	closeCallback()	0	10	3

<?php
namespace Laravoole\Wrapper;

use Garveen\FastCgi\FastCgi;
use swoole_server;

class SwooleFastCGIWrapper extends Swoole implements ServerInterface
{
    protected $max_request = 0;
    protected $request_count = 0;

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

    public function start()
    {
        if (!empty($this->handler_config)) {
            if (isset($this->handler_config['max_request'])) {
                $this->max_request = $this->handler_config['max_request'];
            }
            $this->handler_config['max_request'] = 0;
            $this->server->set($this->handler_config);

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

        }

        $this->callbacks = array_merge([
            'Receive' => [$this, 'onReceive'],
        ], $this->callbacks);

        return parent::start();
    }

    public function onReceive($serv, $fd, $from_id, $data)
    {
        return $this->fastcgi->receive($fd, $data);

The property fastcgi does not exist. Did you maybe forget to declare it?

    }

    public function requestCallback($psrRequest)
    {
        return $this->onPsrRequest($psrRequest);
    }

    public function sendCallback($fd, $payload)
    {
        $this->server->send($fd, $payload);

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

    }

    public function closeCallback($fd)
    {
        $this->server->close($fd);

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

        if ($this->max_request) {
            if ($this->request_count++ > $this->max_request) {
                $this->server->stop(); // @codeCoverageIgnore
            }
        }

    }

    public function onWorkerStart($serv, $worker_id)
    {
        fwrite(STDOUT, "Swoole worker $worker_id starting\n");
        parent::onWorkerStart($serv, $worker_id);
        $this->fastcgi = new FastCgi([$this, 'requestCallback'], [$this, 'sendCallback'], [$this, 'closeCallback'], function ($level, $info) {
            fwrite(STDOUT, "$level $info");
        });
        // override
        config(['laravoole.base_config.deal_with_public' => false]);
    }
}