Carno\HTTP\Powered\Swoole\Chips\Http

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	http()	0	56	6

<?php
/**
 * SW client http
 * User: moyo
 * Date: 2018/7/2
 * Time: 3:25 PM
 */

namespace Carno\HTTP\Powered\Swoole\Chips;

use Carno\HTTP\Standard\Response;
use Carno\HTTP\Standard\Streams\Form;
use Psr\Http\Message\RequestInterface as Request;
use Swoole\Http\Client as SWHClient;

The type Swoole\Http\Client was not found. Maybe you did not declare it correctly or list all dependencies?

trait Http
{
    /**
     * @param Request $request
     * @return array
     */
    private function http(Request $request) : array
    {
        /**
         * @var SWHClient $http
         */

        $http = $this->http;

        // -- request init

        $http->setMethod($request->getMethod());

        // -- net sender

        $executor = function ($fn) use ($http, $request) {
            $uri = $this->getUriPath($request->getUri());

It seems like getUriPath() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            $stream = $request->getBody();

            if ($stream instanceof Form) {
                foreach ($stream->files() as $name => $file) {
                    $http->addFile($file->path(), $name);
                }
                $http->post($uri, $stream->data(), $fn);
                return;
            }

            if ($stream->getSize() > 0) {
                $http->setData((string)$stream);
            }

            $http->execute($uri, $fn);
        };

        // -- net receiver

        $receiver = function (SWHClient $c) use ($request) {
            $code = $c->statusCode;
            $headers = (array)$c->headers;
            $response = $c->body;

            // reset cli headers !!
            foreach (array_keys($c->headers ?? []) as $k) {
                unset($c->headers[$k]);
            }

            if ($code > 0) {
                return new Response($code, $headers, $response);
            }

            $this->throwing($request, $c);

It seems like throwing() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        };

        // -- packing

        return [$executor, $receiver];
    }
}