X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-core%2Finclude%2Fclass_jsonRPC.inc;h=bf82d971cda725228084967a57319576340840a3;hb=9773098162a69430e5c427eb458578bb39e15560;hp=d9084f61c0913dba6c4bbcefb8668f69ddc754dd;hpb=60bab946cd1e3436fd789f56707a5137d20a86f1;p=gosa.git diff --git a/gosa-core/include/class_jsonRPC.inc b/gosa-core/include/class_jsonRPC.inc index d9084f61c..bf82d971c 100644 --- a/gosa-core/include/class_jsonRPC.inc +++ b/gosa-core/include/class_jsonRPC.inc @@ -1,79 +1,173 @@ configRegistry->getProperty('core','gosaRpcUser'); + $username = $user->getValue($temporaryValue = TRUE); + $passwd = $config->configRegistry->getProperty('core','gosaRpcPassword'); + $passwdString = $passwd->getValue($temporaryValue = TRUE); + + $connection = new jsonRPC($config, $value, $username, $passwdString); + if(!$connection->success() && $message){ + msg_dialog::display(_("Warning"), + sprintf(_("The rpc connection (%s) specified for '%s:%s' is invalid! Error was: %s."), + bold($value),bold($class),bold($name), bold($connection->get_error())), + WARNING_DIALOG); + + } + + return($connection->success()); + } + + + /*! \brief Constructs a new jsonRPC handle which is connected to a given URL. + * It can either connect using a rpc method or via auth method digest. + * @param object The gosa configuration object (class_config) + * @param string The url to connect to. + * @param string The username for authentication + * @param string The password to use for authentication + * @param boolean Whether to use DIGEST authentication or not. + * @return + */ + public function __construct($config, $connectUrl, $username, $userPassword, $authModeDigest=FALSE) { $this->config = $config; $this->id = 0; + + // Get connection data + $this->connectUrl = $connectUrl; + $this->username = $username; + $this->userPassword = $userPassword; + $this->authModeDigest = $authModeDigest; + + // Put some usefull info in the logs + DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($this->connectUrl), "Initiated RPC "); + DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($this->username), "RPC user: "); + DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($this->userPassword),"RPC password: "); + DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($this->authModeDigest),"Digest Auth (0: No, 1: Yes): "); + $this->__login(); } + + /*! \brief + * @param + * @return + */ private function __login() { - // Get connection data - $url = $this->config->get_cfg_value('core','gosaRpcServer'); - $user = $this->config->get_cfg_value('core','gosaRpcUser'); - $passwd = $this->config->get_cfg_value('core','gosaRpcPassword'); - - DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($url), "Initiated RPC "); - DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($user), "RPC user: "); - DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($passwd),"RPC password: "); - // Init Curl handler - $this->curlHandler = curl_init($url); + $this->curlHandler = curl_init($this->connectUrl); // Set curl options - curl_setopt($this->curlHandler, CURLOPT_URL , $url); - curl_setopt($this->curlHandler, CURLOPT_COOKIESESSION , TRUE); - curl_setopt($this->curlHandler, CURLOPT_COOKIEFILE, 'cookiefile.txt'); - curl_setopt($this->curlHandler, CURLOPT_POST , TRUE); - curl_setopt($this->curlHandler, CURLOPT_RETURNTRANSFER , TRUE); - curl_setopt($this->curlHandler, CURLOPT_SSL_VERIFYPEER, TRUE); - curl_setopt($this->curlHandler, CURLOPT_HTTPHEADER , array('Content-Type: application/json')); + curl_setopt($this->curlHandler, CURLOPT_URL , $this->connectUrl); + curl_setopt($this->curlHandler, CURLOPT_POST , TRUE); + curl_setopt($this->curlHandler, CURLOPT_RETURNTRANSFER ,TRUE); + curl_setopt($this->curlHandler, CURLOPT_HTTPHEADER , array('Content-Type: application/json')); + curl_setopt($this->curlHandler, CURLOPT_SSL_VERIFYPEER, FALSE); // Try to login - $this->login($user, $passwd); - + if($this->authModeDigest){ + if(!empty($this->username)) + curl_setopt($this->curlHandler, CURLOPT_USERPWD , "{$this->username}:{$this->userPassword}"); + curl_setopt($this->curlHandler, CURLOPT_HTTPAUTH , CURLAUTH_ANYSAFE); + }else{ + curl_setopt($this->curlHandler, CURLOPT_COOKIESESSION , TRUE); + curl_setopt($this->curlHandler, CURLOPT_COOKIEFILE, 'cookiefile.txt'); + if(!empty($this->username)) + $this->login($this->username, $this->userPassword); + } } - + + /*! \brief Returns the last HTTP status code. + * @return int The last status code. + */ public function getHTTPstatusCode() { return((isset($this->lastStats['http_code']))? $this->lastStats['http_code'] : -1 ); } + + /*! \brief Returns the last error string. + * @return string The last error message. + */ public function get_error() { if($this->lastStats['http_code'] != 200){ - return($this->getHttpStatusCodeMessage($this->lastStats['http_code'])); + $error = $this->getHttpStatusCodeMessage($this->lastStats['http_code']); + if(isset($this->lastResult['error']['error']) && is_array($this->lastResult['error']['error'])){ + $err = $this->lastResult['error']['error']; + $message = call_user_func_array(sprintf,$err); + $error .= $message; + }elseif(isset($this->lastResult['error']['message'])){ + $error .= ": ".$this->lastResult['error']['message']; + } + return($error); }else{ return(curl_error($this->curlHandler)); } } + + + /*! \brief Returns TRUE if the last action was successfull else FALSE. + * @return boolean TRUE on success else FALSE. + */ public function success() { return(curl_errno($this->curlHandler) == 0 && $this->lastStats['http_code'] == 200); } + + /*! \brief The class destructor, it destroys open rpc handles if needed. + */ public function __destruct() { if($this->curlHandler){ - curl_close($this->curlHandler); + curl_close($this->curlHandler); } } + + /*! \brief This is some kind of catch-all method, all unknown method names will + * will be interpreted as rpc request. + * If you call "$this->blafasel" this method will initiate an rpc request + * for method 'blafasel'. + * @param string method The rpc method to execute. + * @param params array The parameter to use. + * @return mixed The request result. + */ public function __call($method,$params) { // Check if handle is still valid! if(!$this->curlHandler && $this->lastAction != 'login'){ - $this->__login(); + $this->__login(); } // Start request @@ -81,15 +175,69 @@ class jsonRPC { $response = $this->request($method,$params); if($this->success()){ DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__, - (is_array($response['result']))?$response['result']:bold($response['result']), "Result: "); + (is_array($response['result']))?$response['result']:bold($response['result']), "Result: "); }else{ DEBUG (DEBUG_RPC, __LINE__, __FUNCTION__, __FILE__,bold($this->get_error())."
".$response, "Result (FAILED): "); } - return($response['result']); + global $config; + $debugLevel = $config->get_cfg_value('core', 'debugLevel'); + if($debugLevel & DEBUG_RPC){ + print_a(array('CALLED:' => array($method => $params))); + print_a(array('RESPONSE' => $response)); + } + $return = $response['result']; + + // Inspect the result and replace predefined statements with their + // coresponding classes. + $return = $this->inspectJsonResult($return); + + return($return); } - + + + public function inspectJsonResult($result) + { + // Check for remove objects we've to create + if(isset($result['__jsonclass__']) && class_available('remoteObject')){ + + // Get all relevant class informations + $classDef = $result['__jsonclass__'][1]; + $type = $classDef[0]; + $ref_id = $classDef[1]; + $object_id = $classDef[2]; + $methods = $classDef[3]; + $properties = $classDef[4]; + + // Prepare values + $values = array(); + foreach($properties as $prop){ + $values[$prop] = NULL; + if(isset($res[$prop])) $values[$prop] = $res[$prop]; + } + + // Build up remote object + $object = new remoteObject($rpc, $type, $properties, $values, $methods, $object_id, $ref_id); + return($object); + } + return($result); + } + + + + + + + + + + /*! \brief This method finally initiates the real RPC requests and handles + * the result from the server. + * @param string method The method to call + * @param array params The paramter to use. + * @return mixed The server response. + */ private function request($method, $params) { // Set last action @@ -97,7 +245,7 @@ class jsonRPC { // Reset stats of last request. $this->lastStats = array(); - + // Validate input values if (!is_scalar($method)) trigger_error('jsonRPC::__call requires a scalar value as first parameter!'); if (is_array($params)) { @@ -117,11 +265,16 @@ class jsonRPC { // Set current result stats. $this->lastStats = curl_getinfo($this->curlHandler); - + $this->lastResult = $response; + return($response); } - + + /*! \brief Returns the HTTP status message for a given HTTP status code. + * @param int code The status to code to return a message for. + * @return string The corresponding status message. + */ public static function getHttpStatusCodeMessage($code) { $codes = array(