Redbox\Twitch\Transport\Adapter\Curl

Complexity

Total Complexity

13

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes	6
Bugs	0	Features	4

6 Methods

Rating	Name	Duplication	Size	Complexity
A	verifySupport()	0	7	2
A	open()	0	7	2
A	close()	0	6	2
A	getHttpStatusCode()	0	4	1
A	getContentType()	0	4	1
B	send()	0	22	5

<?php
namespace Redbox\Twitch\Transport\Adapter;

class Curl implements AdapterInterface
{
    /**
     * @var resource
     */
    protected $curl;

    /**
     * @var int
     */
    protected $timeout = 30;

    /**
     * @var int
     */
    protected $connect_timeout = 30;

    /**
     * Verify that we can support the curl extention.
     * If this is not the case we will throw a BadFunctionCallException.
     *
     * @throws BadFunctionCallException
     * @return bool
     */
    public function verifySupport()
    {
        if (!extension_loaded('curl')) {
            throw new \BadFunctionCallException('The cURL extension is required.');
        }
        return true;
    }

    /**
     * Initialize curl and close the connection if
     * needed.
     */
    public function open()
    {
        if (is_resource($this->curl)) {
            $this->close();
        }
        $this->curl = curl_init();
    }

    /**
     * Close the curl connection
     */
    public function close()
    {
        if ($this->curl) {
            curl_close($this->curl);
        }
    }


    /**
     * Send the request to the server.
     *
     * @param $address
     * @param $method
     * @param null $headers
     * @param null $body
     * @return mixed
     */
    public function send($address, $method, $headers = null, $body = null)
    {
        // Set connection options
        curl_setopt($this->curl, CURLOPT_URL, $address);
        curl_setopt($this->curl, CURLOPT_CUSTOMREQUEST, $method);
        curl_setopt($this->curl, CURLOPT_HEADER, false);
        curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($this->curl, CURLOPT_VERBOSE, false);

        if (is_array($headers)) {
            $curlHeaders = array();
            foreach ($headers as $k => $v) {
                $curlHeaders[] = "$k: $v";
            }
            curl_setopt($this->curl, CURLOPT_HTTPHEADER, $curlHeaders);
        }

        if (is_array($body) === true && count($body) > 0) {
            curl_setopt($this->curl, CURLOPT_POSTFIELDS, $body);
        }
        return curl_exec($this->curl);
    }

    /**
     * Return the HTTP status code
     *
     * @return mixed
     */
    public function getHttpStatusCode()
    {
        return curl_getinfo($this->curl, CURLINFO_HTTP_CODE);
    }

    /**
     * Return the content-type header set by the server.
     *
     * @return mixed
     */
    public function getContentType()
    {
        return curl_getinfo($this->curl, CURLINFO_CONTENT_TYPE);
    }
}