class.ilRpcClient.php

Go to the documentation of this file.

<?php
include_once './Services/WebServices/RPC/classes/class.ilRpcClientException.php';
/* Copyright (c) 1998-2016 ILIAS open source, Extended GPL, see docs/LICENSE */

class ilRpcClient
{
    protected $url;
    protected $prefix = '';
    protected $timeout = 0;
    protected $encoding = '';

    public function __construct($a_url, $a_prefix = '', $a_timeout = 0, $a_encoding = 'utf-8')
    {
        if (!extension_loaded('xmlrpc')) {
            ilLoggerFactory::getLogger('wsrv')->error('RpcClient Xmlrpc extension not enabled');
            throw new ilRpcClientException('Xmlrpc extension not enabled.', 50);
        }

        $this->url = (string) $a_url;
        $this->prefix = (string) $a_prefix;
        $this->timeout = (int) $a_timeout;
        $this->encoding = (string) $a_encoding;
    }

    public function __call($a_method, $a_params)
    {
        //prepare xml post data
        $method_name = str_replace('_', '.', $this->prefix . $a_method);
        $rpc_options = array(
            'verbosity' => 'newlines_only',
            'escaping' => 'markup'
        );

        if ($this->encoding) {
            $rpc_options['encoding'] = $this->encoding;
        }

        $post_data = xmlrpc_encode_request($method_name, $a_params, $rpc_options);

        //try to connect to the given url
        try {
            include_once './Services/WebServices/Curl/classes/class.ilCurlConnection.php';
            $curl = new ilCurlConnection($this->url);
            $curl->init();
            $curl->setOpt(CURLOPT_HEADER, 'Content-Type: text/xml');
            $curl->setOpt(CURLOPT_POST, (strlen($post_data) > 0));
            $curl->setOpt(CURLOPT_POSTFIELDS, $post_data);
            $curl->setOpt(CURLOPT_RETURNTRANSFER, 1);

            if ($this->timeout > 0) {
                $curl->setOpt(CURLOPT_TIMEOUT, $this->timeout);
            }
            ilLoggerFactory::getLogger('wsrv')->info('RpcClient request to ' . $this->url . ' / ' . $method_name);
            $xml_resp = $curl->exec();
        } catch (ilCurlConnectionException $e) {
            ilLoggerFactory::getLogger('wsrv')->error('RpcClient could not connect to ' . $this->url . ' Reason ' . $e->getCode() . ': ' . $e->getMessage());
            throw new ilRpcClientException($e->getMessage(), $e->getCode());
        }

        //prepare output, throw exception if rpc fault is detected
        $resp = xmlrpc_decode($xml_resp, $this->encoding);

        //xmlrpc_is_fault can just handle arrays as response
        if (is_array($resp) && xmlrpc_is_fault($resp)) {
            ilLoggerFactory::getLogger('wsrv')->error('RpcClient recieved error ' . $resp['faultCode'] . ': ' . $resp['faultString']);
            include_once './Services/WebServices/RPC/classes/class.ilRpcClientException.php';
            throw new ilRpcClientException('RPC-Server returned fault message: ' . $resp['faultString'], $resp['faultCode']);
        }

        return $resp;
    }
}