plugins/ajatus/couchdb/replicator/http.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_replicator_http extends couchdb_replicator implements couchdb_replicator_interface
  11 {
  12     public function replicate()
  13     {
  14         $this->can_connect();
  15
  16         $from_packet = json_encode(array(
  17             'source' => "http://{$this->configuration['source']['host']}:{$this->configuration['source']['port']}/{$this->configuration['source']['db']}",
  18             'target' => "http://{$this->configuration['target']['host']}:{$this->configuration['source']['port']}/{$this->configuration['target']['db']}",
  19         ));
  20
  21         $transport = new couchdb_transport($this->local_configuration);
  22
  23         try
  24         {
  25             $from_results = $transport->free_execute('_replicate', 'POST', $from_packet);
  26         }
  27         catch (couchdb_transport_exception $e)
  28         {
  29             throw new couchdb_replicator_exception("Unknown error occured while executing replication to {$this->configuration['target']['host']}. {$e}");
  30         }
  31
  32         $to_results = false;
  33
  34         if (   !isset($this->configuration['setup']['one_way'])
  35             || !$this->configuration['setup']['one_way'])
  36         {
  37             $to_packet = json_encode(array(
  38                 'source' => "http://{$this->configuration['target']['host']}:{$this->configuration['source']['port']}/{$this->configuration['target']['db']}",
  39                 'target' => "http://{$this->configuration['source']['host']}:{$this->configuration['source']['port']}/{$this->configuration['source']['db']}",
  40             ));
  41
  42             try
  43             {
  44                 $to_results = $transport->free_execute('_replicate', 'POST', $to_packet);
  45             }
  46             catch (couchdb_transport_exception $e)
  47             {
  48                 throw new couchdb_replicator_exception("Unknown error occured while executing replication to {$this->configuration['source']['host']}. {$e}");
  49             }
  50         }
  51
  52         return array(
  53             'from' => $from_results,
  54             'to' => $to_results
  55         );
  56     }
  57
  58     private function set_view($function)
  59     {
  60         //TODO: Implement
  61         /**
  62          * This will create temp db in sources and run the given temp view
  63          * and inserts the result to the created temp db.
  64          * After that those dbs are replicated to the original targets
  65         **/
  66
  67         return;
  68     }
  69
  70     public function check_config()
  71     {
  72         if (! isset($this->configuration['source']['host']))
  73         {
  74             if (empty($this->local_configuration['host']))
  75             {
  76                 throw new couchdb_replicator_exception('No source host found in configuration!');
  77             }
  78
  79             $this->configuration['source']['host'] = $this->local_configuration['host'];
  80         }
  81
  82         if (! isset($this->configuration['source']['port']))
  83         {
  84             if (empty($this->local_configuration['port']))
  85             {
  86                 throw new couchdb_replicator_exception('No source port found in configuration!');
  87             }
  88
  89             $this->configuration['source']['port'] = $this->local_configuration['port'];
  90         }
  91
  92         if (! isset($this->configuration['source']['db']))
  93         {
  94             throw new couchdb_replicator_exception('No source db found in configuration!');
  95         }
  96
  97         if (! isset($this->configuration['target']['host']))
  98         {
  99             if (empty($this->local_configuration['host']))
 100             {
 101                 throw new couchdb_replicator_exception('No target host found in configuration!');
 102             }
 103
 104             $this->configuration['target']['host'] = $this->local_configuration['host'];
 105         }
 106
 107         if (! isset($this->configuration['target']['port']))
 108         {
 109             if (empty($this->local_configuration['port']))
 110             {
 111                 throw new couchdb_replicator_exception('No target port found in configuration!');
 112             }
 113
 114             $this->configuration['target']['port'] = $this->local_configuration['port'];
 115         }
 116
 117         if (! isset($this->configuration['target']['db']))
 118         {
 119             throw new couchdb_replicator_exception('No target db found in configuration!');
 120         }
 121
 122         if (! isset($this->configuration['setup']))
 123         {
 124             $this->configuration['setup'] = array(
 125                 'one_way' => false
 126             );
 127         }
 128
 129         return true;
 130     }
 131
 132     private function can_connect()
 133     {
 134         $source_socket = @fsockopen($this->configuration['source']['host'], $this->configuration['source']['port'], $errno = -1, $errstr = '', $timeout = 10);
 135
 136         if (! $source_socket)
 137         {
 138             throw new couchdb_replicator_exception("Couldn't connect to source server at {$this->configuration['source']['host']}:{$this->configuration['source']['port']}");
 139         }
 140
 141         @fclose($source_socket);
 142
 143         $target_socket = @fsockopen($this->configuration['target']['host'], $this->configuration['target']['port'], $errno = -1, $errstr = '', $timeout = 20);
 144
 145         if (! $target_socket)
 146         {
 147             throw new couchdb_replicator_exception("Couldn't connect to target server at {$this->configuration['target']['host']}:{$this->configuration['target']['port']}");
 148         }
 149
 150         @fclose($target_socket);
 151
 152         return true;
 153     }
 154 }
 155
 156 ?>