Ego_REST_Client.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_REST_Client {
    const TIMEOUT = 30;

    private $url;

    private $session;

    public function __construct($url = '', $user_id = '', $token = '') {
        $this->url = $url;
        if (!empty($user_id)) {
            $this->start($user_id, $token);
        }
    }

    public function start($user_id, $token) {
        return $this->post('startSession', array($user_id, $token));
    }

    public function close() {
        if (!empty($this->session)) {
            $this->post('closeSession');
        }
    }

    public function get($path = '', $params = array()) {
        return $this->send($path, $params, 'GET');
    }

    public function put($path = '', $params = array()) {
        return $this->send($path, $params, 'PUT');
    }

    public function post($path = '', $params = array()) {
        return $this->send($path, $params, 'POST');
    }

    public function delete($path = '', $params = array()) {
        return $this->send($path, $params, 'DELETE');
    }

    private function send($path = '', $params = array(), $method = 'GET') {
        $url = $this->url.$path;
        $ch = curl_init();

        switch ($method) {
            case 'GET':
                curl_setopt($ch, CURLOPT_HTTPGET, true);
                if (!empty($params)) {
                    $url .= (strpos($url, '?') !== false ? '&' : '?').http_build_query($params);
                }
                break;
            case 'PUT':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
                if (!empty($params['params']['@file'])) {
                    // Datei übertragen
                    curl_setopt($ch, CURLOPT_INFILE, $params['params']['@file']);
                    curl_setopt($ch, CURLOPT_INFILESIZE, filesize($params['params']['@file']));
                    unset($params['params']['@file']);
                }
                curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($params));
                break;
            case 'POST':
                curl_setopt($ch, CURLOPT_POST, true);
                curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($params));
                break;
            case 'DELETE':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
                curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
        }

        // Session ID übermitteln
        if (!empty($this->session)) {
            curl_setopt($ch, CURLOPT_COOKIE, EGOTEC."={$this->session}");
        }

        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HEADER, true);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, self::TIMEOUT);

        if (!empty($GLOBALS['egotec_conf']['proxy'])) {
            curl_setopt($ch, CURLOPT_PROXY, $GLOBALS['egotec_conf']['proxy']['proxy_host']);
            curl_setopt($ch, CURLOPT_PROXYPORT, $GLOBALS['egotec_conf']['proxy']['proxy_port']);
            if (!empty($GLOBALS['egotec_conf']['proxy']['proxy_ssl'])) {
                curl_setopt($ch, CURLOPT_HTTPPROXYTUNNEL, true);
            }
            if (!empty($GLOBALS['egotec_conf']['proxy']['proxy_login'])) {
                curl_setopt($ch, CURLOPT_PROXYAUTH, implode(':', array(
                    $GLOBALS['egotec_conf']['proxy']['proxy_login'],
                    (string) $GLOBALS['egotec_conf']['proxy']['proxy_password']
                )));
            }
        }

        $result = curl_exec($ch);

        $header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
        $header = substr($result, 0, $header_size);
        $result = substr($result, $header_size);

        // Die Session ID aus dem Header ermitteln
        if (!empty($header) && preg_match('/Set-Cookie: ?'.preg_quote(EGOTEC, '/').'=(.*?);/msi', $header, $match)) {
            $this->session = $match[1];
        }

        curl_close($ch);
        return json_decode($result, true);
    }
}
?>