Ego_REST_Client.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_REST_Client {
    private $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 setTimeout($n) {
        $this->timeout = $n;
    }
 
    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(), $header = array()) {
        return $this->send($path, $params, 'GET', $header);
    }
 
    public function put($path = '', $params = array(), $header = array()) {
        return $this->send($path, $params, 'PUT', $header);
    }
 
    public function post($path = '', $params = array(), $header = array()) {
        return $this->send($path, $params, 'POST', $header);
    }
 
    public function delete($path = '', $params = array(), $header = array()) {
        return $this->send($path, $params, 'DELETE', $header);
    }
 
    private function send($path = '', $params = array(), $method = 'GET', $header = array()) {
        $url = $this->url.$path;
        $ch = curl_init();
 
        // Zusätzliche Header setzen
        if (!empty($header)) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        }
 
        switch ($method) {
            case 'GET':
                curl_setopt($ch, CURLOPT_HTTPGET, true);
                if (!empty($params)) {
                    $url .= (strpos($url, '?') !== false ? '&' : '?').json_encode($params);
                }
                break;
            case 'PUT':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
                break;
            case 'POST':
                curl_setopt($ch, CURLOPT_POST, true);
                curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
                break;
            case 'DELETE':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($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_VERBOSE, true); // verbose echo
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 0);
        curl_setopt($ch, CURLOPT_TIMEOUT, $this->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);
    }
}