Resta\Client\ClientHttpManager

Complexity

Total Complexity

18

Size/Duplication

Total Lines	173
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getMethod()	0	3	1
B	resolve()	0	29	7
B	inputVars()	0	98	9

<?php


namespace Resta\Client;


use Resta\Contracts\ApplicationContracts;

use Resta\Foundation\ApplicationProvider;


class ClientHttpManager extends ApplicationProvider

{

    /**

     * @var string $method

     */

    protected $method;


    /**

     * @var object

     */

    protected $client;


    /**

     * ClientHttpManager constructor.

     * @param ApplicationContracts $app

     * @param object $client

     */

    public function __construct(ApplicationContracts $app, $client)

    {

        parent::__construct($app);


        $this->client = $client;


        $this->method = httpMethod();

    }


    /**

     * http data resolve

     *

     * @return mixed

     */

    public function resolve()

    {

        $inputs = $this->app->get($this->method);


        $content = json_decode($this->app['request']->getContent(),1);


        if(is_array($inputs) && count($inputs)){


            if(isset($inputs[$this->client->getClientName()])){

                return $inputs[$this->client->getClientName()];

            }

            return $inputs;

        }


        if(is_array($content)){


            if(isset($content[$this->client->getClientName()])){

                return $content[$this->client->getClientName()];

            }

            return $content;

        }


        $this->inputVars();


        if(is_array($GLOBALS[ '_PUT' ])){

            return $GLOBALS[ '_PUT' ];

        }


        return [];

    }


    /**

     * @return void|mixed

     */

    private function inputVars()

    {

        global $_PUT;


        /* PUT data comes in on the stdin stream */

        $putdata = fopen("php://input", "r");


        /* Open a file for writing */

        // $fp = fopen("myputfile.ext", "w");


        $raw_data = '';


        /* Read the data 1 KB at a time

           and write to the file */

        while ($chunk = fread($putdata, 1024))

It seems like $putdata can also be of type false; however, parameter $handle of fread() does only seem to accept resource, maybe add an additional type check?

            $raw_data .= $chunk;


        /* Close the streams */

        fclose($putdata);

It seems like $putdata can also be of type false; however, parameter $handle of fclose() does only seem to accept resource, maybe add an additional type check?

        // Fetch content and determine boundary

        $boundary = substr($raw_data, 0, strpos($raw_data, "\r\n"));


        if(empty($boundary)){

            parse_str($raw_data,$data);

            $GLOBALS[ '_PUT' ] = $data;

            return;

        }


        // Fetch each part

        $parts = array_slice(explode($boundary, $raw_data), 1);

        $data = array();


        foreach ($parts as $part) {

            // If this is the last part, break

            if ($part == "--\r\n") break;


            // Separate content from headers

            $part = ltrim($part, "\r\n");

            list($raw_headers, $body) = explode("\r\n\r\n", $part, 2);


            // Parse the headers list

            $raw_headers = explode("\r\n", $raw_headers);

            $headers = array();

            foreach ($raw_headers as $header) {

                list($name, $value) = explode(':', $header);

                $headers[strtolower($name)] = ltrim($value, ' ');

            }


            // Parse the Content-Disposition to get the field name, etc.

            if (isset($headers['content-disposition'])) {

                $filename = null;

                $tmp_name = null;

                preg_match(

                    '/^(.+); *name="([^"]+)"(; *filename="([^"]+)")?/',

                    $headers['content-disposition'],

                    $matches

                );

                list(, $type, $name) = $matches;


                //Parse File

                if( isset($matches[4]) )

                {

                    //if labeled the same as previous, skip

                    if( isset( $_FILES[ $matches[ 2 ] ] ) )

                    {

                        continue;

                    }


                    //get filename

                    $filename = $matches[4];


                    //get tmp name

                    $filename_parts = pathinfo( $filename );

                    $tmp_name = tempnam( ini_get('upload_tmp_dir'), $filename_parts['filename']);


                    //populate $_FILES with information, size may be off in multibyte situation

                    $_FILES[ $matches[ 2 ] ] = array(

                        'error'=>0,

                        'name'=>$filename,

                        'tmp_name'=>$tmp_name,

                        'size'=>strlen( $body ),

                        'type'=>$value

The variable $value does not seem to be defined for all execution paths leading up to this point.

                    );


                    //place in temporary directory

                    file_put_contents($tmp_name, $body);

                }

                //Parse Field

                else

                {

                    $data[$name] = substr($body, 0, strlen($body) - 2);

                }

            }


        }

        $GLOBALS[ '_PUT' ] = $data;

        return;

    }


    /**

     * get http method

     *

     * @return mixed

     */

    public function getMethod()

    {

        return $this->method;

    }


}