plugins/ajatus/couchdb/views.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 class couchdb_views
  11 {
  12     private $configuration;
  13     private $documents;
  14
  15     public function __construct(&$configuration)
  16     {
  17         $this->configuration =& $configuration;
  18
  19         $this->documents = new couchdb_documents($this->configuration);
  20     }
  21
  22     public function __get($name)
  23     {
  24         return $this->execute($name);
  25     }
  26
  27     public function __set($name, $value)
  28     {
  29         if ($value === false)
  30         {
  31             return $this->remove($name);
  32         }
  33
  34         $results = $this->update($name, $value);
  35
  36         if (   !isset($results->ok)
  37             || !$results->ok)
  38         {
  39             $reason = '';
  40             if (   isset($results->error)
  41                 && isset($results->reason))
  42             {
  43                 $reason = "CouchDB said error: '{$results->error}', reason: '{$results->reason}'";
  44             }
  45
  46             throw new couchdb_view_exception("Couldn't save view {$name}. {$reason}");
  47         }
  48     }
  49
  50     public function __isset($name)
  51     {
  52         return $this->exists($name);
  53     }
  54
  55     public function temp($function, $args=null)
  56     {
  57         $view = new couchdb_views_view('_temp_view', $this->configuration);
  58         $view->set_args($function, true);
  59
  60         if (! is_null($args))
  61         {
  62             $view->set_args($args);
  63         }
  64
  65         $results = $view->run();
  66         if (isset($results->rows))
  67         {
  68             $results->rows = $this->documents->convert($results->rows);
  69         }
  70
  71         return $results;
  72     }
  73
  74     public function create($name, $value)
  75     {
  76         return $this->update($name, $value);
  77     }
  78
  79     public function delete($name)
  80     {
  81         return false;
  82     }
  83
  84     public function execute($name, $args=null)
  85     {
  86         $this->exists($name);
  87
  88         $view = new couchdb_views_view($name, $this->configuration);
  89         $view->set_args($args);
  90
  91         $results = $view->run();
  92         if (isset($results->rows))
  93         {
  94             $results->rows = $this->documents->convert($results->rows);
  95         }
  96
  97         return $results;
  98     }
  99
 100     public function update($name, $value)
 101     {
 102         $update_only_view = false;
 103
 104         if (strpos($name, '/') !== false)
 105         {
 106             $name_parts = explode('/', $name);
 107             $name = $name_parts[0];
 108             $update_only_view = $name_parts[1];
 109             $new_view = $value;
 110         }
 111
 112         $view = new couchdb_views_view($name, $this->configuration);
 113
 114         $existing_view = null;
 115         if ($this->exists($name, true))
 116         {
 117             $existing_view = $view->get();
 118         }
 119
 120         if ($update_only_view)
 121         {
 122             if (is_null($existing_view))
 123             {
 124                 throw new couchdb_view_exception("View {$name} doesn't exist! Cannot update.");
 125             }
 126
 127             $value = array
 128             (
 129                 '_rev' => $existing_view->_rev,
 130                 'language' => $existing_view->language,
 131                 'views' => get_object_vars($existing_view->views)
 132             );
 133             $value['views'][$update_only_view] = $new_view;
 134
 135             $view->set_args($value);
 136
 137             return $view->run(true);
 138         }
 139
 140         if (   !is_null($existing_view)
 141             && isset($existing_view->_rev))
 142         {
 143             $value['_rev'] = $existing_view->_rev;
 144         }
 145
 146         if (! isset($value['language']))
 147         {
 148             $value['language'] = 'text/javascript';
 149
 150             if (   !is_null($existing_view)
 151                 && isset($existing_view->language))
 152             {
 153                 $value['language'] = $existing_view->language;
 154             }
 155         }
 156
 157         $view->set_args($value);
 158
 159         return $view->run(true);
 160     }
 161
 162     private function exists($name, $graceful=false)
 163     {
 164         try
 165         {
 166             $view = new couchdb_views_view($name, $this->configuration);
 167             $view->exists();
 168
 169             return true;
 170         }
 171         catch(couchdb_view_exception $e)
 172         {
 173             if ($graceful)
 174             {
 175                 return false;
 176             }
 177
 178             if ($e->getCode() == 404)
 179             {
 180                 throw new couchdb_view_exception("View '{$name}' doesn't exist!");
 181             }
 182
 183             throw $e;
 184         }
 185
 186         return false;
 187     }
 188
 189     public function clear_caches()
 190     {
 191     }
 192 }
 193
 194 ?>