Response::send() - Code Metrics - swooletw/laravel-swoole - Measure and Improve Code Quality continuously with Scrutinizer

Response::send() A
last analyzed 2022-04-06 07:13 UTC

↳ Parent: Response

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	0
dl	0
loc	4
rs	10
c	0
b	0
f	0

<?php

namespace SwooleTW\Http\Transformers;

use Illuminate\Http\Response as IlluminateResponse;
use Swoole\Http\Response as SwooleResponse;
use Swoole\Http\Request as SwooleRequest;
use Symfony\Component\HttpFoundation\BinaryFileResponse;
use Symfony\Component\HttpFoundation\Response as SymfonyResponse;
use Symfony\Component\HttpFoundation\StreamedResponse;
.
|-- OtherDir
|   |-- Bar.php
|   `-- Foo.php
`-- SomeDir
    `-- Foo.php

class Response
{
    const CHUNK_SIZE = 8192;

    /**
     * @var \Swoole\Http\Response
     */
    protected $swooleResponse;

    /**
     * @var \Swoole\Http\Request
     */
    protected $swooleRequest;

    /**
     * @var \Illuminate\Http\Response
     */
    protected $illuminateResponse;

    /**
     * Make a response.
     *
     * @param $illuminateResponse
     * @param \Swoole\Http\Response $swooleResponse
     * @param \Swoole\Http\Request $swooleRequest
     *
     * @return \SwooleTW\Http\Transformers\Response
     */
    public static function make($illuminateResponse, SwooleResponse $swooleResponse, SwooleRequest $swooleRequest)
    {
        return new static($illuminateResponse, $swooleResponse, $swooleRequest);
    }

    /**
     * Response constructor.
     *
     * @param mixed $illuminateResponse
     * @param \Swoole\Http\Response $swooleResponse
     * @param \Swoole\Http\Request $swooleRequest
     */
    public function __construct($illuminateResponse, SwooleResponse $swooleResponse, SwooleRequest $swooleRequest)
    {
        $this->setIlluminateResponse($illuminateResponse);
        $this->setSwooleResponse($swooleResponse);
        $this->setSwooleRequest($swooleRequest);
    }

    /**
     * Send HTTP headers and content.
     *
     * @throws \InvalidArgumentException
     */
    public function send()
    {
        $this->sendHeaders();
        $this->sendContent();
    }

    /**
     * Send HTTP headers.
     *
     * @throws \InvalidArgumentException
     */
    protected function sendHeaders()
    {
        $illuminateResponse = $this->getIlluminateResponse();

        /* RFC2616 - 14.18 says all Responses need to have a Date */
        if (! $illuminateResponse->headers->has('Date')) {
            $illuminateResponse->setDate(\DateTime::createFromFormat('U', time()));
        }

        // headers
        // allPreserveCaseWithoutCookies() doesn't exist before Laravel 5.3
        $headers = $illuminateResponse->headers->allPreserveCase();
        if (isset($headers['Set-Cookie'])) {
            unset($headers['Set-Cookie']);
        }
        foreach ($headers as $name => $values) {
            foreach ($values as $value) {
                $this->swooleResponse->header($name, $value);
            }
        }

        // status
        $this->swooleResponse->status($illuminateResponse->getStatusCode());

        // cookies
        // $cookie->isRaw() is supported after symfony/http-foundation 3.1
        // and Laravel 5.3, so we can add it back now
        foreach ($illuminateResponse->headers->getCookies() as $cookie) {
            $method = $cookie->isRaw() ? 'rawcookie' : 'cookie';
            $this->swooleResponse->$method(
                $cookie->getName(),
                $cookie->getValue(),
                $cookie->getExpiresTime(),
                $cookie->getPath(),
                $cookie->getDomain(),
                $cookie->isSecure(),
                $cookie->isHttpOnly()
            );
        }
    }

    /**
     * Send HTTP content.
     */
    protected function sendContent()
    {
        $illuminateResponse = $this->getIlluminateResponse();

        if ($illuminateResponse instanceof StreamedResponse && property_exists($illuminateResponse, 'output')) {

            // TODO Add Streamed Response with output
            $this->swooleResponse->end($illuminateResponse->output);
        } elseif ($illuminateResponse instanceof BinaryFileResponse) {

            $this->swooleResponse->sendfile($illuminateResponse->getFile()->getPathname());
        } else {
            $chunkGzip = $this->canGzipContent($illuminateResponse->headers->get('Content-Encoding'));
            $this->sendInChunk($illuminateResponse->getContent(), $chunkGzip);
        }
    }

    /**
     * Send content in chunk
     *
     * @param string $content
     * @param bool $chunkGzip
     */
    protected function sendInChunk($content, $chunkGzip)
    {
        if (strlen($content) <= static::CHUNK_SIZE) {
            $this->swooleResponse->end($content);
            return;
        }

        // Swoole Chunk mode does not support compress by default, this patch only supports gzip
        if ($chunkGzip) {
            $this->swooleResponse->header('Content-Encoding', 'gzip');
            $content = gzencode($content, config('swoole_http.server.options.http_compression_level', 3));
        }

        foreach (str_split($content, static::CHUNK_SIZE) as $chunk) {
            $this->swooleResponse->write($chunk);
        }

        $this->swooleResponse->end();
    }

    /**
     * @param \Swoole\Http\Response $swooleResponse
     *
     * @return \SwooleTW\Http\Transformers\Response
     */
    protected function setSwooleResponse(SwooleResponse $swooleResponse)
    {
        $this->swooleResponse = $swooleResponse;

        return $this;
    }

    /**
     * @return \Swoole\Http\Response
     */
    public function getSwooleResponse()
    {
        return $this->swooleResponse;
    }

    /**
     * @param mixed illuminateResponse
     *
     * @return \SwooleTW\Http\Transformers\Response
     */
    protected function setIlluminateResponse($illuminateResponse)
    {
        if (! $illuminateResponse instanceof SymfonyResponse) {
            $content = (string) $illuminateResponse;
            $illuminateResponse = new IlluminateResponse($content);
        }

        $this->illuminateResponse = $illuminateResponse;

        return $this;
    }

    /**
     * @return \Illuminate\Http\Response
     */
    public function getIlluminateResponse()
    {
        return $this->illuminateResponse;
    }

    /**
     * @param \Swoole\Http\Request $swooleRequest
     *
     * @return \SwooleTW\Http\Transformers\Response
     */
    protected function setSwooleRequest(SwooleRequest $swooleRequest)
    {
        $this->swooleRequest = $swooleRequest;

        return $this;
    }

    /**
     * @return \Swoole\Http\Request
     */
    public function getSwooleRequest()
    {
        return $this->swooleRequest;
    }

    /**
     * @param string $responseContentEncoding
     * @return bool
     */
    protected function canGzipContent($responseContentEncoding)
    {
        return empty($responseContentEncoding) &&
            config('swoole_http.server.options.http_compression', true) &&
            !empty($this->swooleRequest->header['accept-encoding']) &&
            strpos($this->swooleRequest->header['accept-encoding'], 'gzip') !== false &&
            function_exists('gzencode');
    }
}


1			<?php
2
3			namespace SwooleTW\Http\Transformers;
4
5			use Illuminate\Http\Response as IlluminateResponse;
6			use Swoole\Http\Response as SwooleResponse;
7			use Swoole\Http\Request as SwooleRequest;
8			use Symfony\Component\HttpFoundation\BinaryFileResponse;
9			use Symfony\Component\HttpFoundation\Response as SymfonyResponse;
10			use Symfony\Component\HttpFoundation\StreamedResponse;
			0 ignored issues – show Bug introduced 2019-01-13 12:02 UTC by Report Bug Copy Issue Report This use statement conflicts with another class in this namespace, `SwooleTW\Http\Transformers\StreamedResponse`. Consider defining an alias. Let?s assume that you have a directory layout like this: . \|-- OtherDir \| \|-- Bar.php \| `-- Foo.php `-- SomeDir `-- Foo.php and let?s assume the following content of `Bar.php`: // Bar.php namespace OtherDir; use SomeDir\Foo; // This now conflicts the class OtherDir\Foo If both files `OtherDir/Foo.php` and `SomeDir/Foo.php` are loaded in the same runtime, you will see a PHP error such as the following: PHP Fatal error: Cannot use SomeDir\Foo as Foo because the name is already in use in OtherDir/Foo.php However, as `OtherDir/Foo.php` does not necessarily have to be loaded and the error is only triggered if it is loaded before `OtherDir/Bar.php`, this problem might go unnoticed for a while. In order to prevent this error from surfacing, you must import the namespace with a different alias: // Bar.php namespace OtherDir; use SomeDir\Foo as SomeDirFoo; // There is no conflict anymore. Loading history...
11
12			class Response
13			{
14			const CHUNK_SIZE = 8192;
15
16			/**
17			* @var \Swoole\Http\Response
18			*/
19			protected $swooleResponse;
20
21			/**
22			* @var \Swoole\Http\Request
23			*/
24			protected $swooleRequest;
25
26			/**
27			* @var \Illuminate\Http\Response
28			*/
29			protected $illuminateResponse;
30
31			/**
32			* Make a response.
33			*
34			* @param $illuminateResponse
35			* @param \Swoole\Http\Response $swooleResponse
36			* @param \Swoole\Http\Request $swooleRequest
37			*
38			* @return \SwooleTW\Http\Transformers\Response
39			*/
40			public static function make($illuminateResponse, SwooleResponse $swooleResponse, SwooleRequest $swooleRequest)
41			{
42			return new static($illuminateResponse, $swooleResponse, $swooleRequest);
43			}
44
45			/**
46			* Response constructor.
47			*
48			* @param mixed $illuminateResponse
49			* @param \Swoole\Http\Response $swooleResponse
50			* @param \Swoole\Http\Request $swooleRequest
51			*/
52			public function __construct($illuminateResponse, SwooleResponse $swooleResponse, SwooleRequest $swooleRequest)
53			{
54			$this->setIlluminateResponse($illuminateResponse);
55			$this->setSwooleResponse($swooleResponse);
56			$this->setSwooleRequest($swooleRequest);
57			}
58
59			/**
60			* Send HTTP headers and content.
61			*
62			* @throws \InvalidArgumentException
63			*/
64			public function send()
65			{
66			$this->sendHeaders();
67			$this->sendContent();
68			}
69
70			/**
71			* Send HTTP headers.
72			*
73			* @throws \InvalidArgumentException
74			*/
75			protected function sendHeaders()
76			{
77			$illuminateResponse = $this->getIlluminateResponse();
78
79			/* RFC2616 - 14.18 says all Responses need to have a Date */
80			if (! $illuminateResponse->headers->has('Date')) {
81			$illuminateResponse->setDate(\DateTime::createFromFormat('U', time()));
82			}
83
84			// headers
85			// allPreserveCaseWithoutCookies() doesn't exist before Laravel 5.3
86			$headers = $illuminateResponse->headers->allPreserveCase();
87			if (isset($headers['Set-Cookie'])) {
88			unset($headers['Set-Cookie']);
89			}
90			foreach ($headers as $name => $values) {
91			foreach ($values as $value) {
92			$this->swooleResponse->header($name, $value);
93			}
94			}
95
96			// status
97			$this->swooleResponse->status($illuminateResponse->getStatusCode());
98
99			// cookies
100			// $cookie->isRaw() is supported after symfony/http-foundation 3.1
101			// and Laravel 5.3, so we can add it back now
102			foreach ($illuminateResponse->headers->getCookies() as $cookie) {
103			$method = $cookie->isRaw() ? 'rawcookie' : 'cookie';
104			$this->swooleResponse->$method(
105			$cookie->getName(),
106			$cookie->getValue(),
107			$cookie->getExpiresTime(),
108			$cookie->getPath(),
109			$cookie->getDomain(),
110			$cookie->isSecure(),
111			$cookie->isHttpOnly()
112			);
113			}
114			}
115
116			/**
117			* Send HTTP content.
118			*/
119			protected function sendContent()
120			{
121			$illuminateResponse = $this->getIlluminateResponse();
122
123			if ($illuminateResponse instanceof StreamedResponse && property_exists($illuminateResponse, 'output')) {
			0 ignored issues – show introduced 2018-12-17 10:54 UTC by Report Bug Copy Issue Report `$illuminateResponse` is never a sub-type of `Symfony\Component\HttpFoundation\StreamedResponse`. Loading history...
124			// TODO Add Streamed Response with output
125			$this->swooleResponse->end($illuminateResponse->output);
126			} elseif ($illuminateResponse instanceof BinaryFileResponse) {
			0 ignored issues – show introduced 2018-11-20 10:58 UTC by Report Bug Copy Issue Report `$illuminateResponse` is never a sub-type of `Symfony\Component\HttpFo...tion\BinaryFileResponse`. Loading history...
127			$this->swooleResponse->sendfile($illuminateResponse->getFile()->getPathname());
128			} else {
129			$chunkGzip = $this->canGzipContent($illuminateResponse->headers->get('Content-Encoding'));
130			$this->sendInChunk($illuminateResponse->getContent(), $chunkGzip);
131			}
132			}
133
134			/**
135			* Send content in chunk
136			*
137			* @param string $content
138			* @param bool $chunkGzip
139			*/
140			protected function sendInChunk($content, $chunkGzip)
141			{
142			if (strlen($content) <= static::CHUNK_SIZE) {
143			$this->swooleResponse->end($content);
144			return;
145			}
146
147			// Swoole Chunk mode does not support compress by default, this patch only supports gzip
148			if ($chunkGzip) {
149			$this->swooleResponse->header('Content-Encoding', 'gzip');
150			$content = gzencode($content, config('swoole_http.server.options.http_compression_level', 3));
151			}
152
153			foreach (str_split($content, static::CHUNK_SIZE) as $chunk) {
154			$this->swooleResponse->write($chunk);
155			}
156
157			$this->swooleResponse->end();
158			}
159
160			/**
161			* @param \Swoole\Http\Response $swooleResponse
162			*
163			* @return \SwooleTW\Http\Transformers\Response
164			*/
165			protected function setSwooleResponse(SwooleResponse $swooleResponse)
166			{
167			$this->swooleResponse = $swooleResponse;
168
169			return $this;
170			}
171
172			/**
173			* @return \Swoole\Http\Response
174			*/
175			public function getSwooleResponse()
176			{
177			return $this->swooleResponse;
178			}
179
180			/**
181			* @param mixed illuminateResponse
182			*
183			* @return \SwooleTW\Http\Transformers\Response
184			*/
185			protected function setIlluminateResponse($illuminateResponse)
186			{
187			if (! $illuminateResponse instanceof SymfonyResponse) {
188			$content = (string) $illuminateResponse;
189			$illuminateResponse = new IlluminateResponse($content);
190			}
191
192			$this->illuminateResponse = $illuminateResponse;
193
194			return $this;
195			}
196
197			/**
198			* @return \Illuminate\Http\Response
199			*/
200			public function getIlluminateResponse()
201			{
202			return $this->illuminateResponse;
203			}
204
205			/**
206			* @param \Swoole\Http\Request $swooleRequest
207			*
208			* @return \SwooleTW\Http\Transformers\Response
209			*/
210			protected function setSwooleRequest(SwooleRequest $swooleRequest)
211			{
212			$this->swooleRequest = $swooleRequest;
213
214			return $this;
215			}
216
217			/**
218			* @return \Swoole\Http\Request
219			*/
220			public function getSwooleRequest()
221			{
222			return $this->swooleRequest;
223			}
224
225			/**
226			* @param string $responseContentEncoding
227			* @return bool
228			*/
229			protected function canGzipContent($responseContentEncoding)
230			{
231			return empty($responseContentEncoding) &&
232			config('swoole_http.server.options.http_compression', true) &&
233			!empty($this->swooleRequest->header['accept-encoding']) &&
234			strpos($this->swooleRequest->header['accept-encoding'], 'gzip') !== false &&
235			function_exists('gzencode');
236			}
237			}
238

swooletw / laravel-swoole

Response::send() A last analyzed 2022-04-06 07:13 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Response::send() A
last analyzed 2022-04-06 07:13 UTC