Ego_Http.php

gehe zur Dokumentation dieser Datei

<?php

class Ego_Http {
    private $_requestHeader = array();
    public $responseHeader = array();
    protected $info = array();
    public $code = 0;
    public $responseTime = 0;
    public $content = null;
    public $cookie = array();
    public $error = null;
    public $verifySSL = true;
    public $json = null;
    public $use_http_build_query = true;
    private $_proxy = array();

    public function addHeader($headers) {
        foreach ($headers as $key => $value) {
            $this->_requestHeader[$key] = $value;
        }
    }

    public function auth($username, $password = '') {
        $this->addHeader(array(
            'Authorization' => 'Basic '.base64_encode("$username:$password")
        ));
    }

    public function proxy($host, $port, $ssl = false, $username = '', $password = '', $insecure = false) {
        $this->_proxy['host'] = $host;
        $this->_proxy['port'] = (int) $port;
        $this->_proxy['ssl'] = (bool) $ssl;
        $this->_proxy['username'] = $username;
        $this->_proxy['password'] = $password;
        $this->_proxy['insecure'] = $insecure;
    }

    public function get($url, $additional_header = array()) {
        $this->request(array(
            'url' => $url,
            'method' => 'GET',
            'header' => $additional_header
        ));
    }

    public function post($url, $param = array(), $additional_header = array()) {
        $this->request(array(
            'url' => $url,
            'method' => 'POST',
            'param' => $param,
            'header' => $additional_header
        ));
    }

    public function download($url, $target, $param = array(), $additional_header = array()) {
        $this->request(array(
            'url' => $url,
            'method' => 'POST',
            'download' => $target,
            'param' => $param,
            'header' => $additional_header
        ));
    }

    public function upload($url, $file, $param = array(), $additional_header = array()) {
        $this->request(array(
            'url' => $url,
            'method' => 'POST',
            'upload' => $file,
            'param' => $param,
            'header' => $additional_header
        ));
    }

    public function request($request) {
        $header = array();
        foreach (array_merge($this->_requestHeader, $request['header']) as $key => $value) {
            $header[] = $key.": ".$value;
        }

        $ch = curl_init();
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_URL, $request['url']);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $request['method']);

        // Download
        if ($request['download']) {
            $fp = fopen($request['download'], 'w+');
            curl_setopt($ch, CURLOPT_FILE, $fp);
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
            curl_setopt($ch, CURLOPT_TIMEOUT, 900);
        } else {
            curl_setopt($ch, CURLOPT_HEADER, true);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        }

        // Don't verify SSL certificates.
        if (!$this->verifySSL) {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        }

        // Upload
        if ($request['upload']) {
            curl_setopt($ch, CURLOPT_INFILE, $request['upload']);
            curl_setopt($ch, CURLOPT_INFILESIZE, filesize($request['upload']));
        }

        // URL Parameter
        if (!empty($request['param'])) {
            assert($request['method'] === 'POST', "Makes only sense with POST.");
            if ($this->use_http_build_query) {
                curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($request['param']));
            } else {
                curl_setopt($ch, CURLOPT_POSTFIELDS, $request['param']);
            }
        }

        // Proxy
        if (!empty($this->_proxy)) {
            curl_setopt($ch, CURLOPT_PROXY, $this->_proxy['host']);
            curl_setopt($ch, CURLOPT_PROXYPORT, $this->_proxy['port']);
            if ($this->_proxy['ssl']) {
                curl_setopt($ch, CURLOPT_HTTPPROXYTUNNEL, true);
            }
            if (!empty($this->_proxy['username'])) {
                curl_setopt($ch, CURLOPT_PROXYUSERPWD, implode(':', array(
                    $this->_proxy['username'],
                    $this->_proxy['password']
                )));
            }
            if ($this->_proxy['insecure']) {
                curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
                curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            }
        }

        $response = curl_exec($ch);
        if (!$response) {
            $this->error = curl_error($ch);
            return;
        }
        $this->error = null;

        if (!$request['download']) {
            // Generate Response Headers
            $header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
            $headers = substr($response, 0, $header_size);
            $content_orig = substr($response, $header_size);
            $this->responseHeader = array();
            foreach (explode("\n", $headers) as $value) {
                $pos = strpos($value, ":");
                $key = substr($value, 0, $pos);
                $val = trim(substr($value, $pos + 1));
                $this->responseHeader[$key] = $val;
            }

            // Collect Cookies
            $this->cookie = array();
            if ($this->responseHeader['Set-Cookie']) {
                $cookies = explode("\n", $this->responseHeader['Set-Cookie']);
                foreach ($cookies as $line) {
                    $row = explode(";", $line);
                    $row0 = array_shift($row);
                    $row0_keyval = explode("=", $row0);
                    $cookie = array('value' => $row0_keyval[1]);
                    foreach ($row as $s) {
                        $keyval = explode("=", $s);
                        $cookie[trim($keyval[0])] = $keyval[1];
                    }
                    $this->cookie[$row0_keyval[0]] = $cookie;
                }
            }
        }

        $this->info = curl_getinfo($ch);
        $this->responseTime = $this->info['total_time'];
        $this->content = $this->responseHeader['Content-Encoding']=='gzip' ? zlib_decode($content_orig) : $content_orig;

        // decode JSON
        if (strpos($this->responseHeader['Content-Type'], "application/json") !== false) {
            $this->json = json_decode($this->content);
        } else {
            $this->json = null;
        }

        $this->code = $this->info['http_code'];

        curl_close($ch);
        if (isset($fp)) {
            fclose($fp);
        }
    }
}
?>