class.ilCurlConnection.php

Go to the documentation of this file.

<?php

/*
  +-----------------------------------------------------------------------------+
  | ILIAS open source                                                           |
  +-----------------------------------------------------------------------------+
  | Copyright (c) 1998-2006 ILIAS open source, University of Cologne            |
  |                                                                             |
  | This program is free software; you can redistribute it and/or               |
  | modify it under the terms of the GNU General Public License                 |
  | as published by the Free Software Foundation; either version 2              |
  | of the License, or (at your option) any later version.                      |
  |                                                                             |
  | This program is distributed in the hope that it will be useful,             |
  | but WITHOUT ANY WARRANTY; without even the implied warranty of              |
  | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the               |
  | GNU General Public License for more details.                                |
  |                                                                             |
  | You should have received a copy of the GNU General Public License           |
  | along with this program; if not, write to the Free Software                 |
  | Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA. |
  +-----------------------------------------------------------------------------+
 */

include_once('Services/WebServices/Curl/classes/class.ilCurlConnectionException.php');

class ilCurlConnection
{
    protected $url = '';
    protected $ch = null;

    private $header_plain = '';
    private $header_arr = array();
    
    private $response_body = '';

    public function __construct($a_url = '')
    {
        $this->url = $a_url;

        if (!self::_isCurlExtensionLoaded()) {
            throw new ilCurlConnectionException('Curl extension not enabled.');
        }
    }

    final public static function _isCurlExtensionLoaded()
    {
        if (!function_exists('curl_init')) {
            return false;
        }
        return true;
    }

    public function getResponseHeader()
    {
        return $this->header_plain;
    }

    public function getResponseHeaderArray()
    {
        return (array) $this->header_arr;
    }

    final public function init()
    {
        // teminate existing handles
        $this->close();
        if (strlen($this->url)) {
            $this->ch = curl_init($this->url);
        #$GLOBALS['DIC']['ilLog']->write(__METHOD__ . ': ' . $this->url);
        } else {
            $this->ch = curl_init();
        }
        if (!$this->ch) {
            throw new ilCurlConnectionException('Cannot init curl connection.');
        }
        if (curl_errno($this->ch)) {
            throw new ilCurlConnectionException(curl_error($this->ch), curl_errno($this->ch));
        }

        return true;
    }

    final public function setOpt($a_option, $a_value)
    {
        if (!@curl_setopt($this->ch, $a_option, $a_value)) {
            throw new ilCurlConnectionException('Invalid option given for: ' . $a_option, curl_errno($this->ch));
        }
        return true;
    }

    final public function exec()
    {
        // Add header function
        curl_setopt($this->ch, CURLOPT_HEADERFUNCTION, array($this,'parseHeader'));
        if ((@$res = curl_exec($this->ch)) === false) {
            if (strlen($err = curl_error($this->ch))) {
                throw new ilCurlConnectionException($err, curl_errno($this->ch));
            } else {
                throw new ilCurlConnectionException('Error calling curl_exec().');
            }
        }
        return $res;
    }
    
    public function parseResponse($a_response)
    {
        $header_size = $this->getInfo(CURLINFO_HEADER_SIZE);
        
        $this->header_plain = substr($a_response, 0, $header_size);
        $this->response_body = substr($a_response, $header_size);
    }
    
    public function getResponseBody()
    {
        return $this->response_body;
    }
    
    public function getInfo($opt = 0)
    {
        if ($opt) {
            $res = curl_getinfo($this->ch, $opt);
        } else {
            $res = curl_getinfo($this->ch);
        }
        return $res;
    }

    private function parseHeader($handle, $header)
    {
        $this->header_plain = $header;

        $lines = explode('\r\n', $this->getResponseHeader());
        foreach ($lines as $line) {
            list($name, $value) = explode(':', $line, 2);
            $this->header_arr[$name] = $value;
        }
        return strlen($this->getResponseHeader());
    }

    final public function close()
    {
        if ($this->ch != null) {
            curl_close($this->ch);
            $this->ch = null;
        }
    }
    
    public function __destruct()
    {
        $this->close();
    }
}