[Summary view] [Print] [Text view]

   1  <?php
   2  
   3  
   4  class AkHttpClient extends AkObject
   5  {
   6      var $HttpRequest;
   7      var $error;
   8      var $Response;
   9  
  10      function get($url, $options = array())
  11      {
  12          return $this->customRequest($url, 'GET', $options);
  13      }
  14  
  15      function post($url, $options = array(), $body = '')
  16      {
  17          return $this->customRequest($url, 'POST', $options, $body);
  18      }
  19  
  20      function put($url, $options = array(), $body = '')
  21      {
  22          return $this->customRequest($url, 'PUT', $options, $body);
  23      }
  24  
  25      function delete($url, $options = array())
  26      {
  27          return $this->customRequest($url, 'DELETE', $options);
  28      }
  29  
  30      // prefix_options, query_options = split_options(options)
  31  
  32      function customRequest($url, $http_verb = 'GET', $options = array(), $body = '')
  33      {
  34          $this->getRequestInstance($url, $http_verb, $options, $body);
  35          return $this->sendRequest();
  36      }
  37      
  38      function urlExists($url)
  39      {
  40          $this->getRequestInstance($url, 'GET');
  41          $this->sendRequest(false);
  42          return $this->code == 200;
  43      }
  44  
  45      function getRequestInstance($url, $http_verb = 'GET', $options = array(), $body = '')
  46      {
  47          $default_options = array(
  48          'header' => array(),
  49          'params' => array(),
  50          );
  51  
  52          $options = array_merge($default_options, $options);
  53  
  54          $options['header']['user-agent'] = empty($options['header']['user-agent']) ?
  55          'Akelos PHP Framework AkHttpClient (http://akelos.org)' : $options['header']['user-agent'];
  56  
  57          list($user_name, $password) = $this->_extractUserNameAndPasswordFromUrl($url);
  58  
  59          require_once(AK_VENDOR_DIR.DS.'pear'.DS.'HTTP'.DS.'Request.php');
  60  
  61          $this->{'_setParamsFor'.ucfirst(strtolower($http_verb))}($url, $options['params']);
  62          
  63          $this->HttpRequest =& new HTTP_Request($url);
  64  
  65          $user_name ? $this->HttpRequest->setBasicAuth($user_name, $password) : null;
  66  
  67          $this->HttpRequest->setMethod(constant('HTTP_REQUEST_METHOD_'.$http_verb));
  68                
  69          $http_verb == 'PUT' && !empty($options['params']) && $this->setBody($options['params']);
  70          
  71          !empty($options['params']) && $this->addParams($options['params']);
  72  
  73          $this->addHeaders($options['header']);
  74  
  75          return $this->HttpRequest;
  76      }
  77  
  78      function addHeaders($headers)
  79      {
  80          foreach ($headers as $k=>$v){
  81              $this->addHeader($k, $v);
  82          }
  83      }
  84  
  85      function addHeader($name, $value)
  86      {
  87          $this->HttpRequest->removeHeader($name);
  88          $this->HttpRequest->addHeader($name, $value);
  89      }
  90  
  91      function getResponseHeader($name)
  92      {
  93          return $this->HttpRequest->getResponseHeader($name);
  94      }
  95  
  96      function getResponseHeaders()
  97      {
  98          return $this->HttpRequest->getResponseHeader();
  99      }
 100  
 101      function getResponseCode()
 102      {
 103          return $this->HttpRequest->getResponseCode();
 104      }
 105  
 106      function addParams($params = array())
 107      {
 108          if(!empty($params)){
 109              foreach (array_keys($params) as $k){
 110                  $this->HttpRequest->addPostData($k, $params[$k]);
 111              }
 112          }
 113      }
 114      
 115      function setBody($body)
 116      {
 117          Ak::compat('http_build_query');
 118          $this->HttpRequest->setBody(http_build_query((array)$body));
 119      }
 120  
 121      function sendRequest($return_body = true)
 122      {
 123          $this->Response = $this->HttpRequest->sendRequest();
 124          $this->code = $this->HttpRequest->getResponseCode();
 125          if (PEAR::isError($this->Response)) {
 126              $this->error = $this->Response->getMessage();
 127              return false;
 128          } else {
 129              return $return_body ? $this->HttpRequest->getResponseBody() : true;
 130          }
 131      }
 132  
 133      function _extractUserNameAndPasswordFromUrl(&$url)
 134      {
 135          return array(null,null);
 136      }
 137  
 138      function getParamsOnUrl($url)
 139      {
 140          $parts = parse_url($url);
 141          if($_tmp = (empty($parts['query']) ? false : $parts['query'])){
 142              unset($parts['query']);
 143              $url = $this->_httpRenderQuery($parts);
 144          }
 145          $result = array();
 146          !empty($_tmp) && parse_str($_tmp, $result);
 147          return $result;
 148      }
 149      
 150      function getUrlWithParams($url, $params)
 151      {
 152          $parts = parse_url($url);
 153          Ak::compat('http_build_query');
 154          $parts['query'] = http_build_query($params);
 155          return $this->_httpRenderQuery($parts);
 156      }
 157  
 158      function _setParamsForGet(&$url, &$params)
 159      {
 160          $url_params = $this->getParamsOnUrl($url);
 161          if(!count($url_params) && !empty($params)){
 162              $url = $this->getUrlWithParams($url, $params);
 163          }else{
 164              $params = $url_params;
 165          }
 166      }
 167      
 168      function _setParamsForPost(&$url, &$params)
 169      {
 170          empty($params) && $params = $this->getParamsOnUrl($url);
 171      }
 172      
 173      function _setParamsForPut(&$url, &$params)
 174      {
 175          empty($params) && $params = $this->getParamsOnUrl($url);
 176      }
 177      
 178      function _setParamsForDelete(&$url, &$params)
 179      {
 180          if(!$this->getParamsOnUrl($url) && !empty($params)){
 181              $url = $this->getUrlWithParams($url, $params);
 182          }
 183      }
 184  
 185      function _httpRenderQuery($parts)
 186      {
 187          return is_array($parts) ? (
 188          (isset($parts['scheme']) ? $parts['scheme'].':'.((strtolower($parts['scheme']) == 'mailto') ? '' : '//') : '').
 189          (isset($parts['user']) ? $parts['user'].(isset($parts['pass']) ? ':'.$parts['pass'] : '').'@' : '').
 190          (isset($parts['host']) ? $parts['host'] : '').
 191          (isset($parts['port']) ? ':'.$parts['port'] : '').
 192          (isset($parts['path'])?((substr($parts['path'], 0, 1) == '/') ? $parts['path'] : ('/'.$parts['path'])):'').
 193          (isset($parts['query']) ? '?'.$parts['query'] : '').
 194          (isset($parts['fragment']) ? '#'.$parts['fragment'] : '')
 195          ) : false;
 196      }
 197  }
 198  
 199  
 200  ?>