Graviton\ImportExport\Service\HttpClient

Complexity

Total Complexity

9

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	requestAsync()	0	6	1
A	request()	0	6	1
C	checkFileUploadRequest()	0	30	7

<?php
/**
 * Extending GuzzleHttp client
 */
namespace Graviton\ImportExport\Service;

use GuzzleHttp\Client;
use GuzzleHttp\Psr7;

/**
 * Class HttpClient
 * Extends Guzzle client
 *
 * @author   List of contributors <https://github.com/libgraviton/import-export/graphs/contributors>
 * @license  http://opensource.org/licenses/gpl-license.php GNU Public License
 * @link     http://swisscom.ch
 */
class HttpClient extends Client
{
    /**
     * Parse Body and if File is found it will find file and send it
     *
     * @param string $method  Request method to be used
     * @param string $uri     Url to where to send data
     * @param array  $options Config params
     *
     * @return \GuzzleHttp\Promise\PromiseInterface
     */
    public function requestAsync($method, $uri = null, array $options = [])
    {
        $options = $this->checkFileUploadRequest($options);

        return parent::requestAsync($method, $uri, $options);
    }

    /**
     * Parse Body and if File is found it will find file and send it
     *
     * @param string $method  Request method to be used
     * @param string $uri     Url to where to send data
     * @param array  $options Config params
     * @return mixed
     */
    public function request($method, $uri = null, array $options = [])
    {
        $options = $this->checkFileUploadRequest($options);
        $options[RequestOptions::SYNCHRONOUS] = true;
        return $this->requestAsync($method, $uri, $options)->wait();
    }

    /**
     * @param array $options Curl data options
     * @return array options
     */
    private function checkFileUploadRequest($options)
    {
        $originFileName = array_key_exists('origin', $options) ? $options['origin'] : false;

        if (!$originFileName) {
            return $options;
        }
        // Remove un-used param
        unset($options['origin']);

        // Is there a file and a @
        if (!isset($options['json'])
            || !isset($options['json']['file'])
            || !strpos($options['json']['file'], '@') == 0) {
            return $options;
        }

        // Find file
        $fileName = preg_replace('/([^\/]+$)/', substr($options['json']['file'], 1), $originFileName);
        if (!file_exists($fileName)) {
            return $options;
        }
        
        // We send file only
        $options = [];
        $options['body'] = fopen(str_replace('//', '/', $fileName), 'r');

        return $options;

    }
}