X-Git-Url: http://git.polytechnique.org/?a=blobdiff_plain;f=classes%2Fxmlrpcclient.php;h=c359730f33921044b00f9a07187645051d4d8f5c;hb=c504af53e5b3e13f19039f1ab03cd16279ce4967;hp=8784a0c2b5d392da58aadb457a17616fef4e6685;hpb=df69f0b9e58a6edcd47e9b6dfcf971526f268d45;p=platal.git

diff --git a/classes/xmlrpcclient.php b/classes/xmlrpcclient.php
index 8784a0c..c359730 100644
--- a/classes/xmlrpcclient.php
+++ b/classes/xmlrpcclient.php
@@ -1,147 +1,6 @@
 <?php
-/******************************************************************************
- *                                                                            *
- *  Original file can be found on http://xmlrpc-epi.sourceforge.net/          *
- *  in the module xmlrpc-epi-php v0.51 file samples/utils/utils.php           *
- *                                                                            *
- *                                                The Polytechnique.org TEAM  *
- *                                                                            *
- **************************************************************************{{{*/
-
-/*
-  This file is part of, or distributed with, libXMLRPC - a C library for
-  xml-encoded function calls.
-
-  Author: Dan Libby (dan@libby.com)
-  Epinions.com may be contacted at feedback@epinions-inc.com
-*/
-
-/*
-  Copyright 2001 Epinions, Inc.
-
-  Subject to the following 3 conditions, Epinions, Inc.  permits you, free
-  of charge, to (a) use, copy, distribute, modify, perform and display this
-  software and associated documentation files (the "Software"), and (b)
-  permit others to whom the Software is furnished to do so as well.
-
-  1) The above copyright notice and this permission notice shall be included
-  without modification in all copies or substantial portions of the
-  Software.
-
-  2) THE SOFTWARE IS PROVIDED "AS IS", WITHOUT ANY WARRANTY OR CONDITION OF
-  ANY KIND, EXPRESS, IMPLIED OR STATUTORY, INCLUDING WITHOUT LIMITATION ANY
-  IMPLIED WARRANTIES OF ACCURACY, MERCHANTABILITY, FITNESS FOR A PARTICULAR
-  PURPOSE OR NONINFRINGEMENT.
-
-  3) IN NO EVENT SHALL EPINIONS, INC. BE LIABLE FOR ANY DIRECT, INDIRECT,
-  SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES OR LOST PROFITS ARISING OUT
-  OF OR IN CONNECTION WITH THE SOFTWARE (HOWEVER ARISING, INCLUDING
-  NEGLIGENCE), EVEN IF EPINIONS, INC.  IS AWARE OF THE POSSIBILITY OF SUCH
-  DAMAGES.
-
-*/
-
-/* xmlrpc utilities (xu)
- * author: Dan Libby (dan@libby.com)
- */
-
-/* generic function to call an http server with post method */
-function xu_query_http_post($request, $host, $uri, $port, $timeout, $user,
-        $pass, $secure=false)
-{
-    $response_buf = '';
-    if ($host && $uri && $port) {
-	$content_len = strlen($request);
-	$fsockopen   = $secure ? 'fsockopen_ssl' : 'fsockopen';
-	$query_fd    = $fsockopen($host, $port, $errno, $errstr, 10);
-
-	if ($query_fd) {
-
-	    $auth = '';
-	    if ($user) {
-		$auth = 'Authorization: Basic ' .  base64_encode($user . ':' . $pass) . "\r\n";
-	    }
-
-	    $http_request =
-		"POST $uri HTTP/1.0\r\n" .
-		"Host: $host:$port\r\n" .
-		$auth .
-		"User-Agent: xmlrpc-epi-php/0.2 (PHP)\r\n" .
-		"Content-Type: text/xml\r\n" .
-		"Content-Length: $content_len\r\n" .
-		"Connection: Close\r\n" .
-		"\r\n" .
-		$request;
-
-	    fputs($query_fd, $http_request, strlen($http_request));
-
-	    $header_parsed = false;
-	    while (!feof($query_fd)) {
-		$line = fgets($query_fd, 4096);
-		if (!$header_parsed) {
-		    if ($line === "\r\n" || $line === "\n") {
-			$header_parsed = 1;
-		    }
-		} else {
-		    $response_buf .= $line;
-		}
-	    }
-
-	    fclose($query_fd);
-	}
-    }
-
-    return $response_buf;
-}
-
-function find_and_decode_xml($buf)
-{
-    if (strlen($buf)) {
-        $xml_begin = substr($buf, strpos($buf, '<?xml'));
-        if (strlen($xml_begin)) {
-            $retval = xmlrpc_decode($xml_begin);
-        }
-    }
-    return $retval;
-}
-
-
-/**
- * @param params         a struct containing 3 or more of these key/val pairs:
- * @param host		 remote host             (required)
- * @param uri		 remote uri	         (required)
- * @param port		 remote port             (required)
- * @param method         name of method to call
- * @param args	         arguments to send       (parameters to remote xmlrpc server)
- * @param timeout	 timeout in secs.        (0 = never)
- * @param user		 user name for authentication.
- * @param pass		 password for authentication
- * @param secure	 secure. wether to use fsockopen_ssl. (requires special php build).
- */
-function xu_rpc_http_concise($params) {
-    $host = $uri = $port = $method = $args = null;
-    $timeout = $user = $pass = $secure = null;
-
-    extract($params);
-
-    // default values
-    if (!$port) {
-        $port = 80;
-    }
-    if (!$uri) {
-        $uri = '/';
-    }
-    if ($host && $uri && $port) {
-        $request_xml  = xmlrpc_encode_request($method, $args);
-        $response_buf = xu_query_http_post($request_xml, $host, $uri, $port,
-                $timeout, $user, $pass, $secure);
-        $retval       = find_and_decode_xml($response_buf);
-   }
-   return $retval;
-}
-
-/*}}}***********************************************************************
- *  Copyright (C) 2003-2006 Polytechnique.org                              *
+/***************************************************************************
+ *  Copyright (C) 2003-2010 Polytechnique.org                              *
  *  http://opensource.polytechnique.org/                                   *
  *                                                                         *
  *  This program is free software; you can redistribute it and/or modify   *
@@ -171,43 +30,101 @@ function xu_rpc_http_concise($params) {
 
 class XmlrpcClient
 {
-    var $url;
-    var $urlparts;
+    private $url;
+    private $urlparts;
+    public $bt = null;
 
-    function XmlrpcClient($url)
+    public function __construct($url)
     {
         $this->url = $url;
         $this->urlparts = parse_url($this->url);
-        foreach (array('scheme', 'host', 'user', 'pass', 'path', 'query', 'fragment') as $part) {
-            if (!isset($this->urlparts[$part])) {
-                $this->urlparts[$part] = null;
-            }
+
+        if (empty($this->urlparts['port'])) {
+            $this->urlparts['port'] = 80;
+        }
+
+        if (empty($this->urlparts['path'])) {
+            $this->urlparts['path'] = '/';
         }
     }
 
-    function __call($function, $arguments)
+    private function http_post($request)
     {
-        $requestprms['host']    = $this->urlparts['host'];
-        $requestprms['port']    = $this->urlparts['port'];
-        $requestprms['uri']     = $this->urlparts['path'];
-        $requestprms['user']    = $this->urlparts['user'];
-        $requestprms['pass']    = $this->urlparts['pass'];
-        $requestprms['method']  = $function;
-        $requestprms['args']    = $arguments;
-        $requestprms['timeout'] = 0;
-        $requestprms['secure']  = 0;
-
-        $result = xu_rpc_http_concise($requestprms);
+        $host = $path = $port = $user = $pass = null;
+        extract($this->urlparts);
+
+        if ($scheme == 'https') {
+            $host = 'ssl://'.$host;
+        }
+
+        $query_fd    = fsockopen($host, $port, $errno, $errstr, 10);
+        if (!$query_fd)
+            return null;
+
+        $auth = '';
+        if ($user) {
+            $auth = 'Authorization: Basic ' . base64_encode("$user:$pass") . "\r\n";
+        }
+
+        $content_len = strlen($request);
+        $http_request =
+            "POST $path HTTP/1.0\r\n" .
+            $auth .
+            "Content-Type: text/xml\r\n" .
+            "Content-Length: $content_len\r\n" .
+            "Connection: Close\r\n" .
+            "Host: $host:$port\r\n" .
+            "\r\n" .
+            $request;
+
+        fputs($query_fd, $http_request, strlen($http_request));
+
+        $buf = '';
+        while (!feof($query_fd)) {
+            $buf .= fread($query_fd, 8192);
+        }
+
+        fclose($query_fd);
+        return $buf;
+    }
+
+    private function find_and_decode_xml($buf)
+    {
+        $pos = strpos($buf, '<?xml');
+        if ($pos !== false) {
+            return xmlrpc_decode(substr($buf, $pos));
+        }
+        trigger_error("Cannot parse XML\n".$buf);
+    }
+
+    public function __call($method, $args)
+    {
+        $query  = xmlrpc_encode_request($method, $args);
+        if ($this->bt) {
+            $this->bt->start($method . "\n" . var_export($args, true));
+        }
+        $answer = $this->http_post($query, $this->urlparts);
+        if ($this->bt) {
+            $this->bt->stop();
+        }
+        $result = $this->find_and_decode_xml($answer);
+        if ($this->bt) {
+            if (is_array($result) && isset($result['faultCode'])) {
+                $this->bt->update(0, $result['faultString']);
+            } else {
+                $this->bt->update(count($result));
+            }
+        }
+
         if (is_array($result) && isset($result['faultCode'])) {
-            print('Error in xmlrpc call \''.$function.'\''."\n");
-            print('  code  : '.$result['faultCode']."\n");
-            print('  message: '.$result['faultString']."\n");
+            trigger_error("Error in xmlrpc call $function\n".
+                          "  code   : {$result['faultCode']}\n".
+                          "  message: {$result['faultString']}\n");
             return null;
         }
         return $result;
     }
-
 }
 
-// vim:set et sw=4 sts=4 sws=4:
+// vim:set et sw=4 sts=4 sws=4 enc=utf-8:
 ?>