xenapi.php

<?php
/*
 *    PHP XenAPI v1.0
 *    a class for XenServer API calls
 *
 *    Copyright (C) 2010 Andy Goodwin <andyg@unf.net>
 *
 *    This class requires xml-rpc, PHP5, and curl.
 *
 *    Permission is hereby granted, free of charge, to any person obtaining 
 *    a copy of this software and associated documentation files (the 
 *    "Software"), to deal in the Software without restriction, including 
 *    without limitation the rights to use, copy, modify, merge, publish, 
 *    distribute, sublicense, and/or sell copies of the Software, and to 
 *    permit persons to whom the Software is furnished to do so, subject to 
 *    the following conditions:
 *
 *    The above copyright notice and this permission notice shall be included 
 *    in all copies or substantial portions of the Software.
 *
 *    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS 
 *    OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF 
 *    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. 
 *    IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY 
 *    CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, 
 *    TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE 
 *    SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 */
class XenApi {
    private $_url;
    private $_session_id;
    private $_user;
    private $_password;
    private $_ch;
    function __construct ($url, $user, $password) {
        $r = $this->xenrpc_request($url, $this->xenrpc_method('session.login_with_password', array($user, $password, '1.3')));
        if (is_array($r) && $r['Status'] == 'Success') {
            $this->_session_id = $r['Value'];
            $this->_url = $url;
            $this->_user = $user;
            $this->_password = $password;
        } else {
            echo "API failure.  (" . implode(' ', $r['ErrorDescription']) . ")\n";  exit;
        }
    }
    function __destruct()
    {
        if (isset($this->_ch))
        {
            curl_close($this->_ch); 
        }
    }
    function __call($name, $args) {
        if (!is_array($args)) {
            $args = array();
        }
        $name = str_replace("__", "#", $name);
	list($mod, $method) = explode('_', $name, 2);
	$mod = str_replace("#", "_", $mod);
        
        $ret = $this->xenrpc_parseresponse($this->xenrpc_request($this->_url, 
                  $this->xenrpc_method($mod . '.' . $method, array_merge(array($this->_session_id), $args))));
        return $ret;
    }
    function xenrpc_parseresponse($response) {
        if (!@is_array($response) && !@$response['Status']) {
            echo "API failure.  (500)\n";  exit;
        } else {
            if ($response['Status'] == 'Success') {
               $ret = $response['Value'];
            } else {
               if ($response['ErrorDescription'][0] == 'SESSION_INVALID') {
                   $r = $this->xenrpc_request($url, $this->xenrpc_method('session.login_with_password', 
                               array($this->_user, $this->_password, '1.3')));
                   if (!is_array($r) && $r['Status'] == 'Success') {
                       $this->_session_id = $r['Value'];
                   } else {
                       echo "API failure.  (session)\n";  exit;
                   }
               } else {
                   echo "API failure.  (" . implode(' ', $response['ErrorDescription']) . ")\n";  exit;
               }
            }
        }
        return $ret;
    }
    function xenrpc_method($name, $params) {
        $ret = xmlrpc_encode_request($name, $params);
        return $ret;
    }
    function xenrpc_request($url, $req) {
        $headers = array('Content-type: text/xml', 'Content-length: ' . strlen($req));
        if (!isset($this->_ch))
        {
            $this->_ch = curl_init($url);
            curl_setopt($this->_ch, CURLOPT_CUSTOMREQUEST, 'POST');
            curl_setopt($this->_ch, CURLOPT_CONNECTTIMEOUT, 10);
            curl_setopt($this->_ch, CURLOPT_TIMEOUT, 60);
            curl_setopt($this->_ch, CURLOPT_SSL_VERIFYPEER, FALSE);
            curl_setopt($this->_ch, CURLOPT_SSL_VERIFYHOST, FALSE);
            curl_setopt($this->_ch, CURLOPT_RETURNTRANSFER, 1);
        }
        curl_setopt($this->_ch, CURLOPT_HTTPHEADER, $headers); 
        curl_setopt($this->_ch, CURLOPT_POSTFIELDS, $req); 
        
        $resp = curl_exec($this->_ch);
        $ret = xmlrpc_decode($resp);
        return $ret;
        }
}