Padawan\Framework\Application\Socket\HttpOutput

Complexity

Total Complexity

10

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	defaultHeaders()	0	6	1
A	writeHead()	0	5	1
A	write()	0	11	3
A	writeln()	0	7	2
A	disconnect()	0	9	2

<?php

namespace Padawan\Framework\Application\Socket;

use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Output\NullOutput;
use React\Http\Response;
use React\Promise;

/**
 * Class HttpOutput
 */
class HttpOutput extends NullOutput
{
    public function __construct(Response $client)
    {
        $this->client = $client;
    }

    public function defaultHeaders()
    {
        $this->writeHead(200, [
            'Content-Type' => 'application/json'
        ]);
    }

    public function writeHead($status, $headers = [])
    {
        $this->isHeadWritten = true;
        return $this->client->writeHead($status, $headers);
    }

    public function write($message, $newline = false, $options = 0)
    {
        if (!$this->isHeadWritten) {
            $this->defaultHeaders();
        }
        if (is_array($message)) {
            $message = implode("\n", $message);
        }
        $this->client->end($message);
        return Promise\resolve();
    }

    public function writeln($message, $options = 0)
    {
        if (!$this->isHeadWritten) {
            $this->defaultHeaders();
        }
        return $this->client->write($message . "\n");
    }

    public function disconnect()
    {
        if (!$this->isHeadWritten) {
            $this->defaultHeaders();
        }
        return Promise\resolve()->then(function() {
            $this->client->end();
        });
    }

    private $client;
    private $isHeadWritten = false;
}