CapMousse\ReactRestify\Http\Request

Complexity

Total Complexity

17

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	setContent()	0	4	1
A	getContent()	0	4	1
A	getHeaders()	0	9	1
C	parseData()	0	43	8
A	setData()	0	4	1
A	getData()	0	4	1
A	__get()	0	4	2
A	__set()	0	4	1

<?php

namespace CapMousse\ReactRestify\Http;

use React\Http\Request as ReactHttpRequest;
use CapMousse\ReactRestify\Evenement\EventEmitter;

class Request extends EventEmitter
{
    /** @var \React\Http\Request */
    public $httpRequest;

    /** @var mixed */
    private $content;

    /** @var array */
    private $data = [];

    /**
     * @param ReactHttpRequest $httpRequest
     */
    public function __construct(ReactHttpRequest $httpRequest)
    {
        $this->httpRequest = $httpRequest;
    }

    /**
     * Set the raw data of the request
     * @param mixed $content
     */
    public function setContent($content)
    {
        $this->content = $content;
    }

    /**
     * Set the raw data of the request
     * @return mixed
     */
    public function getContent()
    {
        return $this->content;
    }

    /**
     * Get formated headers
     * @return array
     */
    public function getHeaders()
    {
        $headers = array_change_key_case($this->httpRequest->getHeaders(), CASE_LOWER);
        $headers = array_map(function ($value) {
            return strtolower($value);
        }, $headers);

        return $headers;
    }

    /**
     * Parse request data
     * @return void
     */
    public function parseData()
    {
        $headers = $this->getHeaders();

        if (!in_array($this->httpRequest->getMethod(), ['PUT', 'POST'])) {
            return $this->emit('end');
        }

        $this->httpRequest->on('data', function($data) use ($headers, &$dataResult) {
            $dataResult .= $data;

            if (isset($headers["Content-Length"])) {
                if (strlen($dataResult) == $headers["Content-Length"]) {
                    $this->httpRequest->close();
                }
            } else {
                $this->httpRequest->close();
            }
        });

        $this->httpRequest->on('end', function() use ($headers, &$dataResult) {
            $data = [];

            if ($dataResult === null) return $this->emit('end');

            if (isset($headers['content-type']) && $headers['content-type'] == 'application/json') {
                $jsonData = json_decode($dataResult, true);

                if ($jsonData === null) {
                    $this->emit('error', [json_last_error_msg()]);
                    return;
                } else {
                    $data = $jsonData;
                }
            } else {
                parse_str($dataResult, $data);
            }

            $this->setContent($dataResult);
            $this->setData($data);
            $this->emit('end');            
        });
    }

    /**
     * Set the data array
     * @param array $data array of data
     */
    public function setData($data)
    {
        $this->data = array_merge($data, $this->data);
    }

    /**
     * Get the data array
     * @return array
     */
    public function getData()
    {
        return $this->data;
    }

    public function __get($name)
    {
        return isset($this->data[$name]) ? $this->data[$name] : false;
    }

    public function __set($name, $value)
    {
        $this->data[$name] = $value;
    }
}