Curl.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\HTTP\Client;

class Curl implements \Magento\Framework\HTTP\ClientInterface
{
    private $sslVersion;

    protected $_host = 'localhost';

    protected $_port = 80;

    protected $_sock = null;

    protected $_headers = [];

    protected $_postFields = [];

    protected $_cookies = [];

    protected $_responseHeaders = [];

    protected $_responseBody = '';

    protected $_responseStatus = 0;

    protected $_timeout = 300;

    protected $_redirectCount = 0;

    protected $_ch;

    protected $_curlUserOptions = [];

    protected $_headerCount = 0;

    public function setTimeout($value)
    {
        $this->_timeout = (int)$value;
    }

    public function __construct($sslVersion = null)
    {
        $this->sslVersion = $sslVersion;
    }

    public function setHeaders($headers)
    {
        $this->_headers = $headers;
    }

    public function addHeader($name, $value)
    {
        $this->_headers[$name] = $value;
    }

    public function removeHeader($name)
    {
        unset($this->_headers[$name]);
    }

    public function setCredentials($login, $pass)
    {
        $val = base64_encode("{$login}:{$pass}");
        $this->addHeader("Authorization", "Basic {$val}");
    }

    public function addCookie($name, $value)
    {
        $this->_cookies[$name] = $value;
    }

    public function removeCookie($name)
    {
        unset($this->_cookies[$name]);
    }

    public function setCookies($cookies)
    {
        $this->_cookies = $cookies;
    }

    public function removeCookies()
    {
        $this->setCookies([]);
    }

    public function get($uri)
    {
        $this->makeRequest("GET", $uri);
    }

    public function post($uri, $params)
    {
        $this->makeRequest("POST", $uri, $params);
    }

    public function getHeaders()
    {
        return $this->_responseHeaders;
    }

    public function getBody()
    {
        return $this->_responseBody;
    }

    public function getCookies()
    {
        if (empty($this->_responseHeaders['Set-Cookie'])) {
            return [];
        }
        $out = [];
        foreach ($this->_responseHeaders['Set-Cookie'] as $row) {
            $values = explode("; ", $row);
            $c = count($values);
            if (!$c) {
                continue;
            }
            list($key, $val) = explode("=", $values[0]);
            if ($val === null) {
                continue;
            }
            $out[trim($key)] = trim($val);
        }
        return $out;
    }

    public function getCookiesFull()
    {
        if (empty($this->_responseHeaders['Set-Cookie'])) {
            return [];
        }
        $out = [];
        foreach ($this->_responseHeaders['Set-Cookie'] as $row) {
            $values = explode("; ", $row);
            $c = count($values);
            if (!$c) {
                continue;
            }
            list($key, $val) = explode("=", $values[0]);
            if ($val === null) {
                continue;
            }
            $out[trim($key)] = ['value' => trim($val)];
            array_shift($values);
            $c--;
            if (!$c) {
                continue;
            }
            for ($i = 0; $i < $c; $i++) {
                list($subkey, $val) = explode("=", $values[$i]);
                $out[trim($key)][trim($subkey)] = trim($val);
            }
        }
        return $out;
    }

    public function getStatus()
    {
        return $this->_responseStatus;
    }

    protected function makeRequest($method, $uri, $params = [])
    {
        $this->_ch = curl_init();
        $this->curlOption(CURLOPT_URL, $uri);
        if ($method == 'POST') {
            $this->curlOption(CURLOPT_POST, 1);
            $this->curlOption(CURLOPT_POSTFIELDS, is_array($params) ? http_build_query($params) : $params);
        } elseif ($method == "GET") {
            $this->curlOption(CURLOPT_HTTPGET, 1);
        } else {
            $this->curlOption(CURLOPT_CUSTOMREQUEST, $method);
        }

        if (count($this->_headers)) {
            $heads = [];
            foreach ($this->_headers as $k => $v) {
                $heads[] = $k . ': ' . $v;
            }
            $this->curlOption(CURLOPT_HTTPHEADER, $heads);
        }

        if (count($this->_cookies)) {
            $cookies = [];
            foreach ($this->_cookies as $k => $v) {
                $cookies[] = "{$k}={$v}";
            }
            $this->curlOption(CURLOPT_COOKIE, implode(";", $cookies));
        }

        if ($this->_timeout) {
            $this->curlOption(CURLOPT_TIMEOUT, $this->_timeout);
        }

        if ($this->_port != 80) {
            $this->curlOption(CURLOPT_PORT, $this->_port);
        }

        $this->curlOption(CURLOPT_RETURNTRANSFER, 1);
        $this->curlOption(CURLOPT_HEADERFUNCTION, [$this, 'parseHeaders']);
        if ($this->sslVersion !== null) {
            $this->curlOption(CURLOPT_SSLVERSION, $this->sslVersion);
        }

        if (count($this->_curlUserOptions)) {
            foreach ($this->_curlUserOptions as $k => $v) {
                $this->curlOption($k, $v);
            }
        }

        $this->_headerCount = 0;
        $this->_responseHeaders = [];
        $this->_responseBody = curl_exec($this->_ch);
        $err = curl_errno($this->_ch);
        if ($err) {
            $this->doError(curl_error($this->_ch));
        }
        curl_close($this->_ch);
    }

    public function doError($string)
    {
        throw new \Exception($string);
    }

    protected function parseHeaders($ch, $data)
    {
        if ($this->_headerCount == 0) {
            $line = explode(" ", trim($data), 3);
            if (count($line) != 3) {
                $this->doError("Invalid response line returned from server: " . $data);
            }
            $this->_responseStatus = intval($line[1]);
        } else {
            $name = $value = '';
            $out = explode(": ", trim($data), 2);
            if (count($out) == 2) {
                $name = $out[0];
                $value = $out[1];
            }

            if (strlen($name)) {
                if ("Set-Cookie" == $name) {
                    if (!isset($this->_responseHeaders[$name])) {
                        $this->_responseHeaders[$name] = [];
                    }
                    $this->_responseHeaders[$name][] = $value;
                } else {
                    $this->_responseHeaders[$name] = $value;
                }
            }
        }
        $this->_headerCount++;

        return strlen($data);
    }

    protected function curlOption($name, $value)
    {
        curl_setopt($this->_ch, $name, $value);
    }

    protected function curlOptions($arr)
    {
        curl_setopt_array($this->_ch, $arr);
    }

    public function setOptions($arr)
    {
        $this->_curlUserOptions = $arr;
    }

    public function setOption($name, $value)
    {
        $this->_curlUserOptions[$name] = $value;
    }
}