Laravoole\Wrapper\WorkermanFastCGIWrapper

Complexity

Total Complexity

7

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	start()	0	5	1
A	onWorkerStart()	0	8	1
A	onReceive()	0	5	1
A	requestCallback()	0	4	1
A	sendCallback()	0	4	1
A	closeCallback()	0	4	1

<?php
namespace Laravoole\Wrapper;

use Laravoole\Workerman\Worker;
use Garveen\FastCgi\FastCgi;

class WorkermanFastCGIWrapper extends Workerman implements ServerInterface
{
    public function __construct($host, $port)
    {
        parent::__construct($host, $port);
        $this->server = new Worker("tcp://{$host}:{$port}");
    }

    public function start()
    {
        $this->on('Receive', [$this, 'onReceive']);
        return parent::start();
    }

    public function onWorkerStart($worker)
    {
        $worker->log("Workerman worker {$worker->id} starting\n");
        parent::onWorkerStart($worker);
        $this->fastcgi = new FastCgi([$this, 'requestCallback'], [$this, 'sendCallback'], [$this, 'closeCallback'], function($level, $info) use ($worker) {

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

            $worker->log("$level $info");
        });
    }

    public function onReceive($connection, $data)
    {
        $this->connections[$connection->id]['connection'] = $connection;

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

        return $this->fastcgi->receive($connection->id, $data);
    }

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

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

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

}