dedalozzo / eoc-client

src/EoC/Couch.php

Doc Comments +10 added lines, -10 removed lines

@@ -297,7 +297,7 @@ 
 
   /**
    * @brief Returns a list of all database events in the CouchDB instance.
-   * @param DbUpdatesFeedOpts $opts Additional options.
+   * @param Opt\DbUpdatesFeedOpts $opts Additional options.
    * @return Response
    * @attention Requires admin privileges.
    * @see http://docs.couchdb.org/en/latest/api/server/common.html#db-updates
@@ -577,7 +577,7 @@ 
    * @brief Obtains a list of the changes made to the database. This can be used to monitor for update and modifications
    * to the database for post processing or synchronization.
    * @param string $name The database name.
-   * @param ChangesFeedOpts $opts Additional options.
+   * @param Opt\ChangesFeedOpts $opts Additional options.
    * @return Response
    * @see http://docs.couchdb.org/en/latest/api/database/changes.html
    */
@@ -708,7 +708,7 @@ 
   /**
    * @brief Returns the special security object for the database.
    * @param string $dbName The database name.
-   * @return string A JSON object.
+   * @return Response A JSON object.
    * @see http://docs.couchdb.org/en/latest/api/database/security.html#get--db-_security
    */
   public function getSecurityObj($dbName) {
@@ -762,7 +762,7 @@ 
    * permanent continuous replications that survive a server restart without you having to do anything.
    * @param string|array $filter (optional) Name of a filter function that can choose which revisions get replicated.
    * You can also provide an array of document identifiers; if given, only these documents will be replicated.
-   * @param ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
+   * @param Opt\ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
    * docs, etc.
    * @return Response
    * @see http://docs.couchdb.org/en/latest/api/server/common.html#post--_replicate
@@ -866,7 +866,7 @@ 
    * @param array $keys (optional) Used to retrieve just the view rows matching that set of keys. Rows are returned
    * in the order of the specified keys. Combining this feature with Opt\ViewQueryOpts.includeDocs() results in the so-called
    * multi-document-fetch feature.
-   * @param ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
+   * @param Opt\ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
    * docs, etc.
    * @param ChunkHook $chunkHook (optional) A class instance that implements the IChunkHook interface.
    * @return Result::QueryResult The result of the query.
@@ -898,7 +898,7 @@ 
    * @param array $keys (optional) Used to retrieve just the view rows matching that set of keys. Rows are returned
    * in the order of the specified keys. Combining this feature with Opt\ViewQueryOpts.includeDocs() results in the so-called
    * multi-document-fetch feature.
-   * @param ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
+   * @param Opt\ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
    * docs, etc.
    * @param IChunkHook $chunkHook (optional) A class instance that implements the IChunkHook interface.
    * @return Result::QueryResult The result of the query.
@@ -950,7 +950,7 @@ 
    * @param array $keys (optional) Used to retrieve just the view rows matching that set of keys. Rows are returned
    * in the order of the specified keys. Combining this feature with Opt\ViewQueryOpts.includeDocs() results in the so-called
    * multi-document-fetch feature.
-   * @param ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
+   * @param Opt\ViewQueryOpts $opts (optional) Query options to get additional information, grouping results, include
    * docs, etc.
    * @param string $language The language used to implement the map and reduce functions.
    * @param IChunkHook $chunkHook (optional) A class instance that implements the IChunkHook interface.
@@ -1090,7 +1090,7 @@ 
    * @param string $docId The document's identifier.
    * @param string $path The document's path.
    * @param string $rev (optional) The document's revision.
-   * @param DocOpts $opts Query options to get additional document information, like conflicts, attachments, etc.
+   * @param Opt\DocOpts $opts Query options to get additional document information, like conflicts, attachments, etc.
    * @return object|Response An instance of Doc, LocalDoc, DesignDoc or any subclass of Doc.
    * @see http://docs.couchdb.org/en/latest/api/document/common.html#get--db-docid
    */
@@ -1145,7 +1145,7 @@ 
    * using PUT instead we need to specify one. We can still use the function getUuids() to ask CouchDB for some ids.
    * This is an internal detail. You have only to know that CouchDB can generate the document id for you.
    * @param string $dbName The database name.
-   * @param Doc $doc The document you want insert or update.
+   * @param Doc\IDoc $doc The document you want insert or update.
    * @param bool $batchMode (optional) You can write documents to the database at a higher rate by using the batch
    * option. This collects document writes together in memory (on a user-by-user basis) before they are committed to
    * disk. This increases the risk of the documents not being stored in the event of a failure, since the documents are
@@ -1334,7 +1334,7 @@ 
    * @param string $docId The document's identifier.
    * @param string $path The document's path.
    * @param string $rev (optional) The document's revision.
-   * @return string The document's revision.
+   * @return Response The document's revision.
    * @see http://docs.couchdb.org/en/latest/api/document/attachments.html#db-doc-attachment
    */
   public function getAttachmentInfo($dbName, $fileName, $path, $docId, $rev = NULL) {

Braces +182 added lines, -134 removed lines

@@ -108,10 +108,13 @@ 
       foreach ($keys as $key) {
         $hash = md5(json_encode($key));
 
-        if (isset($matches[$hash])) // Match found.
+        if (isset($matches[$hash])) {
+          // Match found.
           $allRows[] = $matches[$hash];
-        else // No match found.
+        } else {
+          // No match found.
           $allRows[] = ['id' => NULL, 'key' => $key, 'value' => NULL];
+        }
       }
 
       // Overrides the response, replacing rows.
@@ -174,15 +177,18 @@ 
    * @param bool $excludeLocal Document path.
    */
   public function validateDocPath($path, $excludeLocal = FALSE) {
-    if (empty($path)) // STD_DOC_PATH
+    if (empty($path)) {
+      // STD_DOC_PATH
       return;
+    }
 
-    if ($path == self::DESIGN_DOC_PATH)
-      return;
-    elseif ($path == self::LOCAL_DOC_PATH && $excludeLocal)
-      throw new \InvalidArgumentException("Local document doesn't have attachments.");
-    else
-      throw new \InvalidArgumentException("Invalid document path.");
+    if ($path == self::DESIGN_DOC_PATH) {
+          return;
+    } elseif ($path == self::LOCAL_DOC_PATH && $excludeLocal) {
+          throw new \InvalidArgumentException("Local document doesn't have attachments.");
+    } else {
+          throw new \InvalidArgumentException("Invalid document path.");
+    }
   }
 
 
@@ -193,10 +199,11 @@ 
    * @param string $docId Document id.
    */
   public function validateAndEncodeDocId(&$docId) {
-    if (!empty($docId))
-      $docId = rawurlencode($docId);
-    else
-      throw new \InvalidArgumentException("\$docId must be a non-empty string.");
+    if (!empty($docId)) {
+          $docId = rawurlencode($docId);
+    } else {
+          throw new \InvalidArgumentException("\$docId must be a non-empty string.");
+    }
   }
 
   //!@}
@@ -228,10 +235,10 @@ 
     // before the client has received the entire response. To avoid problems, we trap the exception and we go on.
     try {
       $this->send($request);
-    }
-    catch (\Exception $e) {
-      if ($e->getCode() > 0)
-        throw $e;
+    } catch (\Exception $e) {
+      if ($e->getCode() > 0) {
+              throw $e;
+      }
     }
   }
 
@@ -268,10 +275,11 @@ 
   public function getFavicon() {
     $response = $this->send(new Request(Request::GET_METHOD, "/favicon.ico"));
 
-    if ($response->getHeaderFieldValue(Request::CONTENT_TYPE_HF) == "image/x-icon")
-      return $response->getBody();
-    else
-      throw new \InvalidArgumentException("Content-Type must be image/x-icon.");
+    if ($response->getHeaderFieldValue(Request::CONTENT_TYPE_HF) == "image/x-icon") {
+          return $response->getBody();
+    } else {
+          throw new \InvalidArgumentException("Content-Type must be image/x-icon.");
+    }
   }
 
 
@@ -305,8 +313,9 @@ 
   public function getDbUpdates(Opt\DbUpdatesFeedOpts $opts = NULL) {
     $request = new Request(Request::GET_METHOD, "/_db_updates");
 
-    if (isset($opts))
-      $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    if (isset($opts)) {
+          $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    }
 
     return $this->send($request)->getBodyAsArray();
   }
@@ -335,9 +344,9 @@ 
       $request = new Request(Request::GET_METHOD, "/_log");
       $request->setQueryParam("bytes", $bytes);
       return $this->send($request)->getBody();
+    } else {
+          throw new \InvalidArgumentException("\$bytes must be a positive integer.");
     }
-    else
-      throw new \InvalidArgumentException("\$bytes must be a positive integer.");
   }
 
 
@@ -354,13 +363,15 @@ 
 
       $response = $this->send($request);
 
-      if ($count == 1) // We don't need to use === operator because, just above, we made a type checking.
+      if ($count == 1) {
+        // We don't need to use === operator because, just above, we made a type checking.
         return $response->getBodyAsArray()['uuids'][0];
-      else
-        return $response->getBodyAsArray()['uuids'];
+      } else {
+              return $response->getBodyAsArray()['uuids'];
+      }
+    } else {
+          throw new \InvalidArgumentException("\$count must be a positive integer.");
     }
-    else
-      throw new \InvalidArgumentException("\$count must be a positive integer.");
   }
 
   //!@}
@@ -384,8 +395,9 @@ 
     if (!empty($section)) {
       $path .= "/".$section;
 
-      if (!empty($key))
-        $path .= "/".$key;
+      if (!empty($key)) {
+              $path .= "/".$key;
+      }
     }
 
     return $this->send(new Request(Request::GET_METHOD, $path))->getBodyAsArray();
@@ -400,14 +412,17 @@ 
    * @see http://docs.couchdb.org/en/latest/api/server/configuration.html#put--_config-section-key
    */
   public function setConfigKey($section, $key, $value) {
-    if (!is_string($section) or empty($section))
-      throw new \InvalidArgumentException("\$section must be a not empty string.");
+    if (!is_string($section) or empty($section)) {
+          throw new \InvalidArgumentException("\$section must be a not empty string.");
+    }
 
-    if (!is_string($key) or empty($key))
-      throw new \InvalidArgumentException("\$key must be a not empty string.");
+    if (!is_string($key) or empty($key)) {
+          throw new \InvalidArgumentException("\$key must be a not empty string.");
+    }
 
-    if (is_null($value))
-      throw new \InvalidArgumentException("\$value cannot be null.");
+    if (is_null($value)) {
+          throw new \InvalidArgumentException("\$value cannot be null.");
+    }
 
     $request = new Request(Request::PUT_METHOD, "/_config/".$section."/".$key);
     $request->setHeaderField(Request::CONTENT_TYPE_HF, "application/json");
@@ -423,11 +438,13 @@ 
    * @see http://docs.couchdb.org/en/latest/api/configuration.html#delete-config-section-key
    */
   public function deleteConfigKey($section, $key) {
-    if (!is_string($section) or empty($section))
-      throw new \InvalidArgumentException("\$section must be a not empty string.");
+    if (!is_string($section) or empty($section)) {
+          throw new \InvalidArgumentException("\$section must be a not empty string.");
+    }
 
-    if (!is_string($key) or empty($key))
-      throw new \InvalidArgumentException("\$key must be a not empty string.");
+    if (!is_string($key) or empty($key)) {
+          throw new \InvalidArgumentException("\$key must be a not empty string.");
+    }
 
     $this->send(new Request(Request::DELETE_METHOD, "/_config/".$section."/".$key));
   }
@@ -454,11 +471,13 @@ 
    * @see http://docs.couchdb.org/en/latest/api/server/authn.html#post--_session
    */
   public function setSession($userName, $password) {
-    if (!is_string($userName) or empty($userName))
-      throw new \InvalidArgumentException("\$userName must be a not empty string.");
+    if (!is_string($userName) or empty($userName)) {
+          throw new \InvalidArgumentException("\$userName must be a not empty string.");
+    }
 
-    if (!is_string($password) or empty($password))
-      throw new \InvalidArgumentException("\$password must be a not empty string.");
+    if (!is_string($password) or empty($password)) {
+          throw new \InvalidArgumentException("\$password must be a not empty string.");
+    }
 
     $request = new Request(Request::POST_METHOD, "/_session");
 
@@ -545,8 +564,9 @@ 
     #    One of the characters “_$()” «_$()»
     #    A character in the range between “+” and “/” «+-/»
     # Assert position at the very end of the string «\z»
-    if (preg_match('%\A[a-z][a-z\d_$()+-/]++\z%', $name) === FALSE)
-      throw new \InvalidArgumentException("Invalid database name.");
+    if (preg_match('%\A[a-z][a-z\d_$()+-/]++\z%', $name) === FALSE) {
+          throw new \InvalidArgumentException("Invalid database name.");
+    }
 
     $this->send(new Request(Request::PUT_METHOD, "/".rawurlencode($this->prefix.$name)."/"));
   }
@@ -584,8 +604,9 @@ 
   public function getDbChanges($name, Opt\ChangesFeedOpts $opts = NULL) {
     $request = new Request(Request::GET_METHOD, "/".rawurlencode($this->prefix.$name)."/_changes");
 
-    if (isset($opts))
-      $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    if (isset($opts)) {
+          $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    }
 
     return $this->send($request);
   }
@@ -774,40 +795,47 @@ 
       is_string($targetDbUrl) && !empty($targetDbUrl)) {
       $body["source"] = $sourceDbUrl;
       $body["target"] = $targetDbUrl;
+    } else {
+          throw new \InvalidArgumentException("\$source_db_url and \$target_db_url must be non-empty strings.");
     }
-    else
-      throw new \InvalidArgumentException("\$source_db_url and \$target_db_url must be non-empty strings.");
 
-    if (!is_bool($continuous))
-      throw new \InvalidArgumentException("\$continuous must be a bool.");
-    elseif ($continuous)
-      $body["continuous"] = $continuous;
+    if (!is_bool($continuous)) {
+          throw new \InvalidArgumentException("\$continuous must be a bool.");
+    } elseif ($continuous) {
+          $body["continuous"] = $continuous;
+    }
 
     // Uses the specified proxy if any set.
-    if (isset($proxy))
-      $body["proxy"] = $proxy;
+    if (isset($proxy)) {
+          $body["proxy"] = $proxy;
+    }
 
     // create_target option
-    if (!is_bool($createTargetDb))
-      throw new \InvalidArgumentException("\$createTargetDb must be a bool.");
-    elseif ($createTargetDb)
-      $body["create_target"] = $createTargetDb;
+    if (!is_bool($createTargetDb)) {
+          throw new \InvalidArgumentException("\$createTargetDb must be a bool.");
+    } elseif ($createTargetDb) {
+          $body["create_target"] = $createTargetDb;
+    }
 
     if (!empty($filter)) {
-      if (is_string($filter)) // filter option
+      if (is_string($filter)) {
+        // filter option
         $body["filter"] = $filter;
-      elseif (is_array($filter)) // doc_ids option
+      } elseif (is_array($filter)) {
+        // doc_ids option
         $body["doc_ids"] = array_values($filter);
-      else
-        throw new \InvalidArgumentException("\$filter must be a string or an array.");
+      } else {
+              throw new \InvalidArgumentException("\$filter must be a string or an array.");
+      }
     }
 
     // queryParams option
     if (!is_null($opts)) {
-      if ($opts instanceof Opt\ViewQueryOpts)
-        $body["query_params"] = get_object_vars($opts);
-      else
-        throw new \InvalidArgumentException("\$queryParams must be an instance of ViewQueryOpts class.");
+      if ($opts instanceof Opt\ViewQueryOpts) {
+              $body["query_params"] = get_object_vars($opts);
+      } else {
+              throw new \InvalidArgumentException("\$queryParams must be an instance of ViewQueryOpts class.");
+      }
     }
 
     $request = new Request(Request::POST_METHOD, "/_replicate");
@@ -824,8 +852,9 @@ 
    * @see http://docs.couchdb.org/en/latest/api/server/common.html#canceling-continuous-replication
    */
   public function stopReplication($replicationId) {
-    if (is_null($replicationId))
-      throw new \InvalidArgumentException("You must provide a replication id.");
+    if (is_null($replicationId)) {
+          throw new \InvalidArgumentException("You must provide a replication id.");
+    }
 
     $body["replication_id"] = $replicationId;
     $body["cancel"] = TRUE;
@@ -874,15 +903,16 @@ 
    * @see http://docs.couchdb.org/en/latest/api/database/bulk-api.html#post--db-_all_docs
    */
   public function queryAllDocs($dbName, array $keys = NULL, Opt\ViewQueryOpts $opts = NULL, Hook\IChunkHook $chunkHook = NULL) {
-    if (is_null($keys))
-      $request = new Request(Request::GET_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_all_docs");
-    else {
+    if (is_null($keys)) {
+          $request = new Request(Request::GET_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_all_docs");
+    } else {
       $request = new Request(Request::POST_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_all_docs");
       $request->setBody(json_encode(['keys' => $keys]));
     }
 
-    if (isset($opts))
-      $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    if (isset($opts)) {
+          $request->setMultipleQueryParamsAtOnce($opts->asArray());
+    }
 
     $result = $this->send($request, $chunkHook)->getBodyAsArray();
 
@@ -911,12 +941,13 @@ 
   public function queryView($dbName, $designDocName, $viewName, array $keys = NULL, Opt\ViewQueryOpts $opts = NULL, Hook\IChunkHook $chunkHook = NULL) {
     $this->validateAndEncodeDocId($designDocName);
 
-    if (empty($viewName))
-      throw new \InvalidArgumentException("You must provide a valid \$viewName.");
+    if (empty($viewName)) {
+          throw new \InvalidArgumentException("You must provide a valid \$viewName.");
+    }
 
-    if (empty($keys))
-      $request = new Request(Request::GET_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_design/".$designDocName."/_view/".$viewName);
-    else {
+    if (empty($keys)) {
+          $request = new Request(Request::GET_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_design/".$designDocName."/_view/".$viewName);
+    } else {
       $request = new Request(Request::POST_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_design/".$designDocName."/_view/".$viewName);
       $request->setBody(json_encode(['keys' => $keys]));
     }
@@ -927,14 +958,15 @@ 
     if (isset($opts)) {
       $request->setMultipleQueryParamsAtOnce($opts->asArray());
       $includeMissingKeys = $opts->issetIncludeMissingKeys();
+    } else {
+          $includeMissingKeys = FALSE;
     }
-    else
-      $includeMissingKeys = FALSE;
 
     $result = $this->send($request, $chunkHook)->getBodyAsArray();
 
-    if ($includeMissingKeys)
-      $this->addMissingRows($keys, $result['rows']);
+    if ($includeMissingKeys) {
+          $this->addMissingRows($keys, $result['rows']);
+    }
 
     return new Result\QueryResult($result);
   }
@@ -961,30 +993,33 @@ 
     $handler = new Handler\ViewHandler('temp');
     $handler->language = $language;
     $handler->mapFn = $mapFn;
-    if (!empty($reduce))
-      $handler->reduceFn = $reduceFn;
+    if (!empty($reduce)) {
+          $handler->reduceFn = $reduceFn;
+    }
 
     $request = new Request(Request::POST_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_temp_view");
     $request->setHeaderField(Request::CONTENT_TYPE_HF, "application/json");
 
     $array = $handler->asArray();
 
-    if (!empty($keys))
-      $array['keys'] = $keys;
+    if (!empty($keys)) {
+          $array['keys'] = $keys;
+    }
 
     $request->setBody(json_encode($array));
 
     if (isset($opts)) {
       $request->setMultipleQueryParamsAtOnce($opts->asArray());
       $includeMissingKeys = $opts->issetIncludeMissingKeys();
+    } else {
+          $includeMissingKeys = FALSE;
     }
-    else
-      $includeMissingKeys = FALSE;
 
     $result = $this->send($request, $chunkHook)->getBodyAsArray();
 
-    if ($includeMissingKeys)
-      $this->addMissingRows($keys, $result['rows']);
+    if ($includeMissingKeys) {
+          $this->addMissingRows($keys, $result['rows']);
+    }
 
     return new Result\QueryResult($result);
   }
@@ -1043,8 +1078,9 @@ 
    * @see http://docs.couchdb.org/en/latest/api/database/misc.html#put--db-_revs_limit
    */
   public function setRevsLimit($dbName, $revsLimit = self::REVS_LIMIT) {
-    if (!is_int($revsLimit) or ($revsLimit <= 0))
-      throw new \InvalidArgumentException("\$revsLimit must be a positive integer.");
+    if (!is_int($revsLimit) or ($revsLimit <= 0)) {
+          throw new \InvalidArgumentException("\$revsLimit must be a positive integer.");
+    }
 
     $request = new Request(Request::PUT_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_revs_limit");
     $request->setHeaderField(Request::CONTENT_TYPE_HF, "application/json");
@@ -1103,16 +1139,17 @@ 
     $request = new Request(Request::GET_METHOD, $requestPath);
 
     // Retrieves the specific revision of the document.
-    if (!empty($rev))
-      $request->setQueryParam("rev", (string)$rev);
+    if (!empty($rev)) {
+          $request->setQueryParam("rev", (string)$rev);
+    }
 
     // If there are any options, add them to the request.
     if (isset($opts)) {
       $request->setMultipleQueryParamsAtOnce($opts->asArray());
       $ignoreClass = $opts->issetIgnoreClass();
+    } else {
+          $ignoreClass = FALSE;
     }
-    else
-      $ignoreClass = FALSE;
 
     $response = $this->send($request);
     $body = $response->getBodyAsArray();
@@ -1124,18 +1161,18 @@ 
     if (!$ignoreClass && isset($body['class'])) { // Special document class inherited from Doc or LocalDoc.
       $class = "\\".$body['class'];
       $doc = new $class;
+    } elseif ($path == self::DESIGN_DOC_PATH) {
+          $doc = new Doc\DesignDoc;
+    } else {
+          $doc = NULL;
     }
-    elseif ($path == self::DESIGN_DOC_PATH)
-      $doc = new Doc\DesignDoc;
-    else
-      $doc = NULL;
 
     if (is_object($doc)) {
       $doc->assignArray($body);
       return $doc;
+    } else {
+          return $response;
     }
-    else
-      return $response;
   }
 
 
@@ -1155,8 +1192,9 @@ 
   public function saveDoc($dbName, Doc\IDoc $doc, $batchMode = FALSE) {
     // Whether the document has an id we use a different HTTP method. Using POST CouchDB generates an id for the doc
     // using PUT we need to specify one. We can still use the function getUuids() to ask CouchDB for some ids.
-    if (!$doc->issetId())
-      $doc->setId(Generator\UUID::generate(Generator\UUID::UUID_RANDOM, Generator\UUID::FMT_STRING));
+    if (!$doc->issetId()) {
+          $doc->setId(Generator\UUID::generate(Generator\UUID::UUID_RANDOM, Generator\UUID::FMT_STRING));
+    }
 
     $this->setDocInfo($doc);
 
@@ -1170,8 +1208,9 @@ 
     $request->setBody($doc->asJson());
 
     // Enables batch mode.
-    if ($batchMode)
-      $request->setQueryParam("batch", "ok");
+    if ($batchMode) {
+          $request->setQueryParam("batch", "ok");
+    }
 
     $this->send($request);
   }
@@ -1224,10 +1263,11 @@ 
     // This request uses the special method COPY.
     $request = new Request(Request::COPY_METHOD, $path);
 
-    if (empty($rev))
-      $request->setHeaderField(Request::DESTINATION_HF, $targetDocId);
-    else
-      $request->setHeaderField(Request::DESTINATION_HF, $targetDocId."?rev=".(string)$rev);
+    if (empty($rev)) {
+          $request->setHeaderField(Request::DESTINATION_HF, $targetDocId);
+    } else {
+          $request->setHeaderField(Request::DESTINATION_HF, $targetDocId."?rev=".(string)$rev);
+    }
 
     $this->send($request);
   }
@@ -1256,8 +1296,9 @@ 
     $request = new Request(Request::POST_METHOD, $path);
 
     $purge = [];
-    foreach ($refs as $ref)
-      $purge[] = $ref->asArray();
+    foreach ($refs as $ref) {
+          $purge[] = $ref->asArray();
+    }
 
     $request->setBody(json_encode($purge));
 
@@ -1289,26 +1330,30 @@ 
    * @see http://wiki.apache.org/couchdb/HTTP_Bulk_Document_API
    */
   public function performBulkOperations($dbName, array $docs, $fullCommit = FALSE, $allOrNothing = FALSE, $newEdits = TRUE) {
-    if (count($docs) == 0)
-      throw new \InvalidArgumentException("The \$docs array cannot be empty.");
-    else
-      $operations = [];
+    if (count($docs) == 0) {
+          throw new \InvalidArgumentException("The \$docs array cannot be empty.");
+    } else {
+          $operations = [];
+    }
 
     $path = "/".rawurlencode($this->prefix.$dbName)."/_bulk_docs";
 
     $request = new Request(Request::POST_METHOD, $path);
     $request->setHeaderField(Request::CONTENT_TYPE_HF, "application/json");
 
-    if ($fullCommit)
-      $request->setHeaderField(Request::X_COUCHDB_FULL_COMMIT_HF, "full_commit");
-    else
-      $request->setHeaderField(Request::X_COUCHDB_FULL_COMMIT_HF, "delay_commit");
+    if ($fullCommit) {
+          $request->setHeaderField(Request::X_COUCHDB_FULL_COMMIT_HF, "full_commit");
+    } else {
+          $request->setHeaderField(Request::X_COUCHDB_FULL_COMMIT_HF, "delay_commit");
+    }
 
-    if ($allOrNothing)
-      $operations['all_or_nothing'] = 'true';
+    if ($allOrNothing) {
+          $operations['all_or_nothing'] = 'true';
+    }
 
-    if (!$newEdits)
-      $operations['new_edits'] = 'false';
+    if (!$newEdits) {
+          $operations['new_edits'] = 'false';
+    }
 
     foreach ($docs as $doc) {
       $this->setDocInfo($doc);
@@ -1346,8 +1391,9 @@ 
     $request = new Request(Request::HEAD_METHOD, $path);
 
     // In case we want retrieve a specific document revision.
-    if (!empty($rev))
-      $request->setQueryParam("rev", (string)$rev);
+    if (!empty($rev)) {
+          $request->setQueryParam("rev", (string)$rev);
+    }
 
     return $this->send($request);
   }
@@ -1373,8 +1419,9 @@ 
     $request = new Request(Request::GET_METHOD, $path);
 
     // In case we want retrieve a specific document revision.
-    if (!empty($rev))
-      $request->setQueryParam("rev", (string)$rev);
+    if (!empty($rev)) {
+          $request->setQueryParam("rev", (string)$rev);
+    }
 
     return $this->send($request)->getBody();
   }
@@ -1403,8 +1450,9 @@ 
     $request->setBody(base64_encode($attachment->getData()));
 
     // In case of adding or updating an existence document.
-    if (!empty($rev))
-      $request->setQueryParam("rev", (string)$rev);
+    if (!empty($rev)) {
+          $request->setQueryParam("rev", (string)$rev);
+    }
 
     return $this->send($request);
   }

src/EoC/Info/AttachmentInfo.php

Braces +5 added lines, -4 removed lines

@@ -50,10 +50,11 @@
    * @return string|bool The codec name or `false` if the attachment is not compressed.
    */
   public function getContentEncoding() {
-    if ($this->response->hasHeaderField(Response::CONTENT_ENCODING_HF))
-      return $this->response->getHeaderFieldValue(Response::CONTENT_ENCODING_HF);
-    else
-      return FALSE;
+    if ($this->response->hasHeaderField(Response::CONTENT_ENCODING_HF)) {
+          return $this->response->getHeaderFieldValue(Response::CONTENT_ENCODING_HF);
+    } else {
+          return FALSE;
+    }
   }
 
 

src/EoC/Result/QueryResult.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
    * arrays.
    * @return array An array of rows.
    */
-  public function asArray()  {
+  public function asArray() {
     return $this->result['rows'];
   }
 
@@ -105,7 +105,7 @@ 
    * @param integer $offset The offset to retrieve.
    * @return mixed Can return all value types.
    */
-  public function offsetGet($offset)  {
+  public function offsetGet($offset) {
     return $this->result['rows'][$offset];
   }
 

src/EoC/Opt/ChangesFeedOpts.php

Braces +30 added lines, -24 removed lines

@@ -81,10 +81,11 @@ 
    * @param integer $since Sequence number to start results. Allowed values: positive integers | 'now'.
    */
   public function setSince($since = 0) {
-    if (($since == "now") or (is_int($since) and ($since >= 0)))
-      $this->options["since"] = $since;
-    else
-      throw new \InvalidArgumentException("\$since must be a non-negative integer or can be 'now'.");
+    if (($since == "now") or (is_int($since) and ($since >= 0))) {
+          $this->options["since"] = $since;
+    } else {
+          throw new \InvalidArgumentException("\$since must be a non-negative integer or can be 'now'.");
+    }
 
     return $this;
   }
@@ -95,10 +96,11 @@ 
    * @param integer $limit Maximum number of rows to return. Must be a positive integer.
    */
   public function setLimit($limit) {
-    if (is_int($limit) and ($limit > 0))
-      $this->options["limit"] = $limit;
-    else
-      throw new \InvalidArgumentException("\$value must be a positive integer.");
+    if (is_int($limit) and ($limit > 0)) {
+          $this->options["limit"] = $limit;
+    } else {
+          throw new \InvalidArgumentException("\$value must be a positive integer.");
+    }
 
     return $this;
   }
@@ -117,10 +119,11 @@ 
    * @param string $type Type of feed.
    */
   public function setFeedType($type) {
-    if (array_key_exists($type, self::$supportedTypes))
-      $this->options["feed"] = $type;
-    else
-      throw new \InvalidArgumentException("Invalid feed type.");
+    if (array_key_exists($type, self::$supportedTypes)) {
+          $this->options["feed"] = $type;
+    } else {
+          throw new \InvalidArgumentException("Invalid feed type.");
+    }
   }
 
 
@@ -130,10 +133,11 @@ 
    * @param bool $style The feed style.
    */
   public function setStyle($style) {
-    if (array_key_exists($style, self::$supportedStyles))
-      $this->options["style"] = $style;
-    else
-      throw new \InvalidArgumentException("Invalid feed style.");
+    if (array_key_exists($style, self::$supportedStyles)) {
+          $this->options["style"] = $style;
+    } else {
+          throw new \InvalidArgumentException("Invalid feed style.");
+    }
   }
 
 
@@ -146,11 +150,12 @@ 
   public function setHeartbeat($heartbeat = self::DEFAULT_HEARTBEAT) {
     $feed = $this->options['feed'];
 
-    if (($feed == self::CONTINUOUS_TYPE) or ($feed == self::LONGPOLL_TYPE))
-      if (is_int($heartbeat) and ($heartbeat >= 0))
+    if (($feed == self::CONTINUOUS_TYPE) or ($feed == self::LONGPOLL_TYPE)) {
+          if (is_int($heartbeat) and ($heartbeat >= 0))
         $this->options["heartbeat"] = $heartbeat;
-      else
-        throw new \InvalidArgumentException("\$heartbeat must be a non-negative integer.");
+    } else {
+              throw new \InvalidArgumentException("\$heartbeat must be a non-negative integer.");
+      }
   }
 
 
@@ -163,11 +168,12 @@ 
   public function setTimeout($timeout = self::DEFAULT_TIMEOUT) {
     $feed = $this->options['feed'];
 
-    if (($feed == self::CONTINUOUS_TYPE) or ($feed == self::LONGPOLL_TYPE))
-      if (is_int($timeout) and ($timeout > 0))
+    if (($feed == self::CONTINUOUS_TYPE) or ($feed == self::LONGPOLL_TYPE)) {
+          if (is_int($timeout) and ($timeout > 0))
         $this->options["timeout"] = $timeout;
-      else
-        throw new \InvalidArgumentException("\$timeout must be a positive integer.");
+    } else {
+              throw new \InvalidArgumentException("\$timeout must be a positive integer.");
+      }
   }
 
 

src/EoC/Opt/DocOpts.php

Braces +5 added lines, -4 removed lines

@@ -143,10 +143,11 @@
    * @param string|array $revs The revision(s) identifier(s).
    */
   public function includeOpenRevs($revs = 'all') {
-    if (is_array($revs))
-      $this->options['open_revs'] = json_encode($revs);
-    else
-      $this->options['open_revs'] = 'all';
+    if (is_array($revs)) {
+          $this->options['open_revs'] = json_encode($revs);
+    } else {
+          $this->options['open_revs'] = 'all';
+    }
 
     return $this;
   }

src/EoC/Opt/DbUpdatesFeedOpts.php

Braces +10 added lines, -8 removed lines

@@ -63,10 +63,11 @@ 
    * @param string $type Type of feed.
    */
   public function setFeedType($type) {
-    if (array_key_exists($type, self::$supportedTypes))
-      $this->options["feed"] = $type;
-    else
-      throw new \InvalidArgumentException("Invalid feed type.");
+    if (array_key_exists($type, self::$supportedTypes)) {
+          $this->options["feed"] = $type;
+    } else {
+          throw new \InvalidArgumentException("Invalid feed type.");
+    }
 
     return $this;
   }
@@ -81,11 +82,12 @@ 
   public function setTimeout($timeout = self::DEFAULT_TIMEOUT) {
     $feed = $this->options['feed'];
 
-    if ($feed == self::CONTINUOUS_TYPE)
-      if (is_int($timeout) and ($timeout > 0))
+    if ($feed == self::CONTINUOUS_TYPE) {
+          if (is_int($timeout) and ($timeout > 0))
         $this->options["timeout"] = $timeout;
-      else
-        throw new \InvalidArgumentException("\$timeout must be a positive integer.");
+    } else {
+              throw new \InvalidArgumentException("\$timeout must be a positive integer.");
+      }
 
     return $this;
   }

src/EoC/Doc/Doc.php

Braces +11 added lines, -8 removed lines

@@ -45,8 +45,9 @@ 
   public function getAttachments() {
     $attachments = [];
 
-    foreach ($this->meta[self::ATTACHMENTS] as $attachment)
-      $attachments[] = Attachment::fromArray($attachment);
+    foreach ($this->meta[self::ATTACHMENTS] as $attachment) {
+          $attachments[] = Attachment::fromArray($attachment);
+    }
 
     return $attachments;
   }
@@ -64,13 +65,15 @@ 
    * @brief Removes an attachment.
    */
   public function removeAttachment($name) {
-    if ($this->isMetadataPresent(self::ATTACHMENTS))
-      if (array_key_exists($name, $this->meta[self::ATTACHMENTS]))
+    if ($this->isMetadataPresent(self::ATTACHMENTS)) {
+          if (array_key_exists($name, $this->meta[self::ATTACHMENTS]))
         unset($this->meta[self::ATTACHMENTS][$name]);
-      else
-        throw new \Exception("Can't find `$name` attachment in the document.");
-    else
-      throw new \Exception("The document doesn't have any attachment.");
+    } else {
+              throw new \Exception("Can't find `$name` attachment in the document.");
+      }
+    else {
+          throw new \Exception("The document doesn't have any attachment.");
+    }
   }