plugins/ajatus/couchdb/transport.php

   1 <?php
   2 /**
   3  *
   4  * Copyright (c) 2008 Jerry Jalava <jerry.jalava@gmail.com>
   5  * Licensed under the GPLv3 license
   6  * http://www.gnu.org/licenses/gpl.html
   7  *
   8  */
   9
  10 require_once "HTTP/Request.php";
  11
  12 class couchdb_transport
  13 {
  14     private $configuration;
  15     private $tmp_conf = array();
  16
  17     protected $lastStatusCode;
  18     protected $lastRevision;
  19     protected $lastDocId;
  20
  21     public function __construct(&$configuration)
  22     {
  23         if (   empty($configuration)
  24             || !isset($configuration['host'])
  25             || !isset($configuration['port']))
  26         {
  27             throw new couchdb_transport_exception('Invalid config defined for transport');
  28         }
  29
  30         $this->configuration = $configuration;
  31     }
  32
  33     public function free_execute($url=false, $options='GET', $postdata=false, $headers=array(), $tmp_conf=array())
  34     {
  35         if (! empty($tmp_conf))
  36         {
  37             $this->set_tmp_config($tmp_conf);
  38         }
  39
  40         return $this->execute($url, $options, $postdata, $headers);
  41     }
  42
  43     public function set_tmp_config($config)
  44     {
  45         $this->tmp_conf = $this->configuration;
  46
  47         foreach ($config as $key => $value)
  48         {
  49             $this->tmp_conf[$key] = $value;
  50         }
  51     }
  52
  53     private function parse_params($params)
  54     {
  55         if (   !isset($params[0])
  56             || (   $params[0] !== false
  57                 && $params[0] == ''))
  58         {
  59             throw new couchdb_transport_exception('No url defined for transport');
  60         }
  61
  62         $config = $this->configuration;
  63         if (! empty($this->tmp_conf))
  64         {
  65             $config = $this->tmp_conf;
  66         }
  67
  68         $postdata = false;
  69         $headers = array(
  70             'Content-Type' => 'text/javascript'
  71         );
  72         $options = array(
  73             'method' => 'GET',
  74             'allowRedirects' => true,
  75             'timeout' => 3
  76         );
  77
  78         $suffix = "";
  79
  80         if (   isset($config['database'])
  81             && !empty($config['database']))
  82         {
  83             $suffix = "{$config['database']}/";
  84         }
  85
  86         if (! is_null($params[0]))
  87         {
  88             $suffix .= "{$params[0]}";
  89         }
  90
  91         $url = "http://{$config['host']}:{$config['port']}/{$suffix}";
  92
  93         if (count($params) >= 2)
  94         {
  95             if (is_array($params[1]))
  96             {
  97                 foreach ($params[1] as $key => $value)
  98                 {
  99                     $options[$key] = $value;
 100                 }
 101             }
 102             else
 103             {
 104                 $options['method'] = strtoupper($params[1]);
 105             }
 106         }
 107
 108         if (count($params) >= 3)
 109         {
 110             $postdata = $params[2];
 111         }
 112
 113         if (   count($params) == 4
 114             && is_array($params[3]))
 115         {
 116             foreach ($params[3] as $key => $value)
 117             {
 118                 $headers[$key] = $value;
 119             }
 120         }
 121
 122         $this->tmp_conf = array();
 123
 124         return array(
 125             $url,
 126             $options,
 127             $postdata,
 128             $headers
 129         );
 130     }
 131
 132     private function clean_json($json)
 133     {
 134                 $json = preg_replace('/"_rev":([0-9]+)/', '"_rev":"$1"', $json);
 135                 return json_decode($json);
 136     }
 137
 138     protected function execute()
 139     {
 140         /*
 141         echo "DEBUG: execute called with params<pre>\n";
 142         var_dump(func_get_args());
 143         echo "</pre>\n";
 144         */
 145         list($url, $options, $postdata, $headers) = $this->parse_params(func_get_args());
 146
 147                 $req = new HTTP_Request($url, $options);
 148
 149                 if ($postdata)
 150                 {
 151             /**
 152              * addRawPostData() is deprecated, use setBody in stead
 153                         $req->addRawPostData($postdata);
 154                          */
 155                         $req->setBody($postdata);
 156                 }
 157
 158                 if ($headers)
 159                 {
 160                         if (   isset($headers['_rev'])
 161                             && !empty($headers['_rev']))
 162                         {
 163                                 $req->addHeader('_rev', (float) $headers['_rev']);
 164                         }
 165
 166                         if (   isset($headers['Content-Type'])
 167                             && !empty($headers['Content-Type']))
 168                         {
 169                                 $req->addHeader('Content-Type', $headers['Content-Type']);
 170                         }
 171                 }
 172
 173                 $resp = $req->sendRequest();
 174
 175                 if (PEAR::isError($resp))
 176                 {
 177                         throw new couchdb_transport_exception('Unexpected error occured while sending the request!' . $resp);
 178                 }
 179
 180                 $this->lastStatusCode = $req->getResponseCode();
 181
 182                 if ($this->lastStatusCode == 404)
 183                 {
 184                     throw new couchdb_transport_exception("Requested url {$url} not found.", 404);
 185                 }
 186
 187                 if (! in_array($this->lastStatusCode, range(200, 299)))
 188                 {
 189             $error_json = $this->clean_json($req->getResponseBody());
 190             /* Try to parse the couchdb error but it seems to be weirdly formed and json_decode cannot handle it
 191             if (isset($error_json->reason))
 192             {
 193                 echo "DEBUG: \$error_json->reason<pre>\n";
 194                 var_dump($error_json->reason);
 195                 echo "</pre>\n";
 196                 //$error_reason_json = json_decode(str_replace('\\n', "\n", $error_json->reason));
 197                 $error_reason_json = json_decode(str_replace('\\n', "\n", $error_json->reason));
 198                 echo "DEBUG: \$error_reason_json<pre>\n";
 199                 var_dump($error_reason_json);
 200                 echo "</pre>\n";
 201             }
 202             */
 203                         throw new couchdb_transport_exception("Don't know how to handle response with code {$this->lastStatusCode}.", $this->lastStatusCode, $req);
 204                 }
 205
 206                 $this->lastRevision = $req->getResponseHeader('x-couch-revid');
 207                 $this->lastDocId = $req->getResponseHeader('x-couch-docid');
 208
 209                 return $this->clean_json($req->getResponseBody());
 210     }
 211 }
 212
 213 ?>