<?php
 
/**
* CouchDB Server Manager
*/
class SetteeServer {
 
  /**
  * Base URL of the CouchDB REST API
  */
  private $conn_url;
  
  /**
  * HTTP REST Client instance
  */
  protected $rest_client;
 
  
  /**
   * Class constructor
   * 
   * @param $conn_url
   *    (optional) URL of the CouchDB server to connect to. Default value: http://127.0.0.1:5984
   */
  function __construct($conn_url = "http://127.0.0.1:5984") {
    $this->conn_url = rtrim($conn_url, ' /');
    $this->rest_client = SetteeRestClient::get_instance($this->conn_url);
  }
  
  /**
  * Create database
  *
  * @param $db
  *     Either a database object or a String name of the database.
  *
  * @return
  *     json string from the server.
  *
  *  @throws SetteeCreateDatabaseException
  */
  function create_db($db) {
    if ($db instanceof SetteeDatabase) {
      $db = $db->get_name();
    }
    $ret = $this->rest_client->http_put($db);
    if (!empty($ret['decoded']->error)) {
      throw new SetteeDatabaseException("Could not create database: " . $ret["json"]);
    }
    return $ret['decoded'];
  }
  
  /**
  * Drop database
  *
  * @param $db
  *     Either a database object or a String name of the database.
  *
  * @return
  *     json string from the server.
  *
  *  @throws SetteeDropDatabaseException
  */
  function drop_db($db) {
    if ($db instanceof SetteeDatabase) {
      $db = $db->get_name();
    }
    $ret =  $this->rest_client->http_delete($db);
    if (!empty($ret['decoded']->error)) {
      throw new SetteeDatabaseException("Could not create database: " . $ret["json"]);
    }
    return $ret['decoded'];
  }
  
  /**
  * Instantiate a database object
  *
  * @param $dbname
  *    name of the newly created database
  *
  * @return SetteeDatabase
  *     new SetteeDatabase instance.
  */
  function get_db($dbname) {
    return new SetteeDatabase($this->conn_url, $dbname);
  }
 
 
  /**
  * Return an array containing all databases
  *
  * @return Array
  *    an array of database names in the CouchDB instance
  */
  function list_dbs() {
    $ret = $this->rest_client->http_get('_all_dbs');
    if (!empty($ret['decoded']["error"])) {
      throw new SetteeDatabaseException("Could not get list of databases: " . $ret["json"]);
    }
    return $ret['decoded'];
  }
 
}
 
class SetteeServerErrorException extends Exception {}
class SetteeDatabaseException extends Exception {}
class SetteeWrongInputException extends Exception {}