library/classes/CouchDB.class.php

   1 <?php
   2
   3 // +-----------------------------------------------------------------------------+
   4 // Copyright (C) 2012 Z&H Consultancy Services Private Limited <sam@zhservices.com>
   5 //
   6 //
   7 // This program is free software; you can redistribute it and/or
   8 // modify it under the terms of the GNU General Public License
   9 // as published by the Free Software Foundation; either version 2
  10 // of the License, or (at your option) any later version.
  11 //
  12 //
  13 // This program is distributed in the hope that it will be useful,
  14 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 // GNU General Public License for more details.
  17 //
  18 //
  19 // A copy of the GNU General Public License is included along with this program:
  20 // openemr/interface/login/GnuGPL.html
  21 // For more information write to the Free Software
  22 // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  23 //
  24 // Author:   Eldho Chacko <eldho@zhservices.com>
  25 //           Jacob T Paul <jacob@zhservices.com>
  26 //
  27 // +------------------------------------------------------------------------------+
  28
  29 use OpenEMR\Common\Crypto\CryptoGen;
  30 use OpenEMR\Common\Uuid\UuidRegistry;
  31
  32 class CouchDB
  33 {
  34     function __construct()
  35     {
  36         $this->host = $GLOBALS['couchdb_host'];
  37         $this->user = ($GLOBALS['couchdb_user'] != '') ? $GLOBALS['couchdb_user'] : null;
  38         $cryptoGen = new CryptoGen();
  39         $this->pass = ($cryptoGen->decryptStandard($GLOBALS['couchdb_pass']) != '') ? $cryptoGen->decryptStandard($GLOBALS['couchdb_pass']) : null;
  40         $this->port = $GLOBALS['couchdb_port'];
  41         $this->dbase = $GLOBALS['couchdb_dbase'];
  42     }
  43
  44     function check_connection()
  45     {
  46         $resp = $this->send("GET", "/"); // response: string(46) "{"couchdb": "Welcome", "version": "0.7.0a553"}"
  47         $response = json_decode($resp);
  48         if ($response->couchdb && $response->version) {
  49             return true;
  50         } else {
  51             return false;
  52         }
  53     }
  54
  55     function createDB()
  56     {
  57         $resp = $this->send("PUT", "/" . $this->dbase);
  58         return true;
  59     }
  60
  61     // note this will include _id (and not allow _rev) in the $data
  62     function save_doc($data)
  63     {
  64         $couch_json = [];
  65         foreach ($data as $key => $value) {
  66             if ($key == '_rev') {
  67                 continue;
  68             }
  69             $couch_json[$key] = $value;
  70         }
  71         $resp = $this->send("PUT", "/" . $this->dbase . "/" . $data['_id'], json_encode($couch_json));
  72         return json_decode($resp);
  73     }
  74
  75     // note this will include _id and _rev in the $data
  76     function update_doc($data)
  77     {
  78         $couch_json = [];
  79         foreach ($data as $key => $value) {
  80             $couch_json[$key] = $value;
  81         }
  82         $resp = $this->send("PUT", "/" . $this->dbase . "/" . $data['_id'], json_encode($couch_json));
  83         return json_decode($resp);
  84     }
  85
  86     function DeleteDoc($docid, $revid)
  87     {
  88         $resp = $this->send("DELETE", "/" . $this->dbase . "/" . $docid . "?rev=" . $revid);
  89         return true;
  90     }
  91
  92     function retrieve_doc($docid)
  93     {
  94         $resp = $this->send("GET", "/" . $this->dbase . "/" . $docid);
  95         return json_decode($resp); // string(47) "{"_id":"123","_rev":"2039697587","data":"Foo"}"
  96     }
  97
  98     // category is either documents or ccda
  99     function createDocId($category)
 100     {
 101         return UuidRegistry::uuidToString((new UuidRegistry(['couchdb' => $category]))->createUuid());
 102     }
 103
 104     function send($method, $url, $post_data = null)
 105     {
 106         if ($GLOBALS['couchdb_connection_ssl']) {
 107             // encrypt couchdb over the wire
 108             if (
 109                 file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/couchdb-ca") &&
 110                 file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/couchdb-cert") &&
 111                 file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/couchdb-key")
 112             ) {
 113                 // support cacert_file and client certificates
 114                 $stream_context = stream_context_create(
 115                     [
 116                         'ssl' =>
 117                             [
 118                                 'cafile' => "${GLOBALS['OE_SITE_DIR']}/documents/certificates/couchdb-ca",
 119                                 'local_cert' => "${GLOBALS['OE_SITE_DIR']}/documents/certificates/couchdb-cert",
 120                                 'local_pk' => "${GLOBALS['OE_SITE_DIR']}/documents/certificates/couchdb-key"
 121                             ]
 122                     ]
 123                 );
 124                 $s = stream_socket_client('ssl://' . $this->host . ":" . $this->port, $errno, $errstr, ini_get("default_socket_timeout"), STREAM_CLIENT_CONNECT, $stream_context);
 125             } elseif (file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/couchdb-ca")) {
 126                 // support cacert_file
 127                 $stream_context = stream_context_create(
 128                     [
 129                         'ssl' =>
 130                             [
 131                                 'cafile' => "${GLOBALS['OE_SITE_DIR']}/documents/certificates/couchdb-ca"
 132                             ]
 133                     ]
 134                 );
 135                 $s = stream_socket_client('ssl://' . $this->host . ":" . $this->port, $errno, $errstr, ini_get("default_socket_timeout"), STREAM_CLIENT_CONNECT, $stream_context);
 136             } else {
 137                 if ($GLOBALS['couchdb_ssl_allow_selfsigned']) {
 138                     // support self-signed
 139                     $stream_context = stream_context_create(
 140                         [
 141                             'ssl' =>
 142                                 [
 143                                     'verify_peer' => false,
 144                                     'allow_self_signed' => true
 145                                 ]
 146                         ]
 147                     );
 148                     $s = stream_socket_client('ssl://' . $this->host . ":" . $this->port, $errno, $errstr, ini_get("default_socket_timeout"), STREAM_CLIENT_CONNECT, $stream_context);
 149                 } else {
 150                     // self-signed, not supported so do not proceed and return false
 151                     return false;
 152                 }
 153             }
 154         } else {
 155             // do not encrypt couchdb over the wire
 156             $s = stream_socket_client('tcp://' . $this->host . ":" . $this->port, $errno, $errstr);
 157         }
 158
 159         if (!$s) {
 160             return false;
 161         }
 162
 163         $request = "$method $url HTTP/1.0\r\nHost: $this->host\r\n";
 164
 165         if ($this->user) {
 166             $request .= 'Authorization: Basic ' . base64_encode($this->user . ':' . $this->pass) . "\r\n";
 167         }
 168
 169         if ($post_data) {
 170             $request .= "Content-Length: " . strlen($post_data) . "\r\n\r\n";
 171             $request .= "$post_data\r\n";
 172         } else {
 173             $request .= "\r\n";
 174         }
 175
 176         fwrite($s, $request);
 177         $response = "";
 178
 179         while (!feof($s)) {
 180             $response .= fgets($s);
 181         }
 182
 183         list($this->headers, $this->body) = explode("\r\n\r\n", $response);
 184         return $this->body;
 185     }
 186 }