DoctrineElastic\Http\CurlRequest

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
D	request()	0	71	11
A	getBaseUrl()	0	3	1
A	setBaseUrl()	0	3	1

<?php

namespace DoctrineElastic\Http;

/**
 * Class ElasticRequest
 * @author Andsalves <ands.alves.nunes@gmail.com>
 */
class CurlRequest {

    protected $baseUrl = '';

    public function request($url, array $data, $method = 'POST', array $headers = null) {
        try {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

            if (!boolval($headers)) {
                $headers = ['Content-Type: application/json; charset=utf-8'];
            }

            switch ($method) {
                case 'GET':
                    $url .= '?';

                    foreach ($data as $key => $value) {
                        $url .= $key . '=' . $value . '&';
                    }

                    rtrim($url, '&');
                    break;
                case 'POST':
                    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
                    curl_setopt($ch, CURLOPT_POST, true);
                    break;
                case 'HEAD':
                    curl_setopt($ch, CURLOPT_HEADER, true);
                    curl_setopt($ch, CURLOPT_NOBODY, true);
                    break;
                default:
                    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
            }

            if (in_array($method, ['POST', 'PUT'])) {
                if (!empty($data)) {
                    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
                }
            }

            $url = rtrim($this->baseUrl, '/') . '/' . ltrim($url, '/');
            curl_setopt($ch, CURLOPT_URL, $url);

            $resultJson = curl_exec($ch);

            $content = json_decode($resultJson, true);
            $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

            curl_close($ch);

            if (is_null($content) && in_array($httpcode, [400, 500])) {
                return array(
                    'status' => $httpcode,
                    'content' => array(
                        'error' => ['reason' => $resultJson]
                    )
                );
            }

            return array(
                'status' => $httpcode,
                'content' => $content
            );
        } catch (\Exception $ex) {
            return array(
                'status' => 500,
                'content' => array(
                    'error' => ['reason' => $ex->getMessage()],
                    'detail' => $ex->getTraceAsString(),
                    'line' => $ex->getLine()
                )
            );
        }
    }

    /**
     * @return string
     */
    public function getBaseUrl() {
        return $this->baseUrl;
    }

    /**
     * @param string $baseUrl
     */
    public function setBaseUrl($baseUrl) {
        $this->baseUrl = $baseUrl;
    }

}