plugins/ajatus/couchdb/replicator/http.php

   1 <?php
   2 /**
   3  *
   4  * Copyright (c) 2007 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     public function check_config()
  59     {
  60         if (! isset($this->configuration['source']['host']))
  61         {
  62             if (empty($this->local_configuration['host']))
  63             {
  64                 throw new couchdb_replicator_exception('No source host found in configuration!');
  65             }
  66
  67             $this->configuration['source']['host'] = $this->local_configuration['host'];
  68         }
  69
  70         if (! isset($this->configuration['source']['port']))
  71         {
  72             if (empty($this->local_configuration['port']))
  73             {
  74                 throw new couchdb_replicator_exception('No source port found in configuration!');
  75             }
  76
  77             $this->configuration['source']['port'] = $this->local_configuration['port'];
  78         }
  79
  80         if (! isset($this->configuration['source']['db']))
  81         {
  82             throw new couchdb_replicator_exception('No source db found in configuration!');
  83         }
  84
  85         if (! isset($this->configuration['target']['host']))
  86         {
  87             if (empty($this->local_configuration['host']))
  88             {
  89                 throw new couchdb_replicator_exception('No target host found in configuration!');
  90             }
  91
  92             $this->configuration['target']['host'] = $this->local_configuration['host'];
  93         }
  94
  95         if (! isset($this->configuration['target']['port']))
  96         {
  97             if (empty($this->local_configuration['port']))
  98             {
  99                 throw new couchdb_replicator_exception('No target port found in configuration!');
 100             }
 101
 102             $this->configuration['target']['port'] = $this->local_configuration['port'];
 103         }
 104
 105         if (! isset($this->configuration['target']['db']))
 106         {
 107             throw new couchdb_replicator_exception('No target db found in configuration!');
 108         }
 109
 110         if (! isset($this->configuration['setup']))
 111         {
 112             $this->configuration['setup'] = array(
 113                 'one_way' => false
 114             );
 115         }
 116
 117         return true;
 118     }
 119
 120     private function can_connect()
 121     {
 122         $source_socket = @fsockopen($this->configuration['source']['host'], $this->configuration['source']['port'], $errno = -1, $errstr = '', $timeout = 10);
 123
 124         if (! $source_socket)
 125         {
 126             throw new couchdb_replicator_exception("Couldn't connect to source server at {$this->configuration['source']['host']}:{$this->configuration['source']['port']}");
 127         }
 128
 129         @fclose($source_socket);
 130
 131         $target_socket = @fsockopen($this->configuration['target']['host'], $this->configuration['target']['port'], $errno = -1, $errstr = '', $timeout = 20);
 132
 133         if (! $target_socket)
 134         {
 135             throw new couchdb_replicator_exception("Couldn't connect to target server at {$this->configuration['target']['host']}:{$this->configuration['target']['port']}");
 136         }
 137
 138         @fclose($target_socket);
 139
 140         return true;
 141     }
 142 }
 143
 144 ?>