dedalozzo / eoc-client

src/EoC/Info/DbInfo.php

Spacing +2 added lines, -2 removed lines

@@ -100,8 +100,8 @@
       $buffer .= "File Opened Since: ".sprintf($since, $time['days'], $time['hours'], $time['minutes'], $time['seconds']).PHP_EOL;
     }
 
-    $buffer .= "Disk Size: ".round($this->diskSize/(1024*1024*1024), 3)." GB".PHP_EOL;
-    $buffer .= "Data Size: ".round($this->dataSize/(1024*1024*1024), 3)." GB".PHP_EOL;
+    $buffer .= "Disk Size: ".round($this->diskSize / (1024 * 1024 * 1024), 3)." GB".PHP_EOL;
+    $buffer .= "Data Size: ".round($this->dataSize / (1024 * 1024 * 1024), 3)." GB".PHP_EOL;
     $buffer .= "Disk Format Version: ".$this->diskFormatVersion.PHP_EOL;
 
     $compactRunning = ($this->compactRunning) ? 'active' : 'inactive';

Braces +2 added lines, -2 removed lines

@@ -82,9 +82,9 @@
       $this->purgeSeq = $info['purge_seq'];
       $this->compactRunning = $info['compact_running'];
       $this->committedUpdateSeq = $info['committed_update_seq'];
+    } else {
+          throw new \Exception("\$info must be an associative array.");
     }
-    else
-      throw new \Exception("\$info must be an associative array.");
   }
 
 

src/EoC/Couch.php

Indentation +1 added lines, -1 removed lines

@@ -908,7 +908,7 @@
    * @see http://docs.couchdb.org/en/latest/api/server/common.html#post--_replicate
    */
   public function startReplication($sourceDbUrl, $targetDbUrl, $proxy = NULL, $createTargetDb = TRUE,
-                                     $continuous = FALSE, $filter = NULL, Opt\ViewQueryOpts $opts = NULL) {
+                                      $continuous = FALSE, $filter = NULL, Opt\ViewQueryOpts $opts = NULL) {
     // Sets source and target databases.
     if (is_string($sourceDbUrl) && !empty($sourceDbUrl) &&
       is_string($targetDbUrl) && !empty($targetDbUrl)) {

Spacing +3 added lines, -3 removed lines

@@ -35,8 +35,8 @@ 
   //!@{
 
   const STD_DOC_PATH = ""; //!< Path for standard documents.
-  const LOCAL_DOC_PATH = "_local/";  //!< Path for local documents.
-  const DESIGN_DOC_PATH = "_design/";  //!< Path for design documents.
+  const LOCAL_DOC_PATH = "_local/"; //!< Path for local documents.
+  const DESIGN_DOC_PATH = "_design/"; //!< Path for design documents.
 
   //!@}
 
@@ -662,7 +662,7 @@ 
    * @see http://docs.couchdb.org/en/latest/api/database/compact.html#db-view-cleanup
    */
   public function cleanupViews($dbName) {
-    $request =  new Request(Request::POST_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_view_cleanup");
+    $request = new Request(Request::POST_METHOD, "/".rawurlencode($this->prefix.$dbName)."/_view_cleanup");
 
     // A POST method requires Content-Type header.
     $request->setHeaderField(Request::CONTENT_TYPE_HF, "application/json");

Braces +182 added lines, -134 removed lines

@@ -107,10 +107,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.
@@ -173,15 +176,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.");
+    }
   }
 
 
@@ -192,10 +198,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.");
+    }
   }
 
   //!@}
@@ -227,10 +234,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;
+      }
     }
   }
 
@@ -267,10 +274,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.");
+    }
   }
 
 
@@ -304,8 +312,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();
   }
@@ -334,9 +343,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.");
   }
 
 
@@ -353,13 +362,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.");
   }
 
   //!@}
@@ -383,8 +394,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();
@@ -399,14 +411,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) || empty($section))
-      throw new \InvalidArgumentException("\$section must be a not empty string.");
+    if (!is_string($section) || empty($section)) {
+          throw new \InvalidArgumentException("\$section must be a not empty string.");
+    }
 
-    if (!is_string($key) || empty($key))
-      throw new \InvalidArgumentException("\$key must be a not empty string.");
+    if (!is_string($key) || 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");
@@ -422,11 +437,13 @@ 
    * @see http://docs.couchdb.org/en/latest/api/configuration.html#delete-config-section-key
    */
   public function deleteConfigKey($section, $key) {
-    if (!is_string($section) || empty($section))
-      throw new \InvalidArgumentException("\$section must be a not empty string.");
+    if (!is_string($section) || empty($section)) {
+          throw new \InvalidArgumentException("\$section must be a not empty string.");
+    }
 
-    if (!is_string($key) || empty($key))
-      throw new \InvalidArgumentException("\$key must be a not empty string.");
+    if (!is_string($key) || empty($key)) {
+          throw new \InvalidArgumentException("\$key must be a not empty string.");
+    }
 
     $this->send(new Request(Request::DELETE_METHOD, "/_config/".$section."/".$key));
   }
@@ -453,11 +470,13 @@ 
    * @see http://docs.couchdb.org/en/latest/api/server/authn.html#post--_session
    */
   public function setSession($userName, $password) {
-    if (!is_string($userName) || empty($userName))
-      throw new \InvalidArgumentException("\$userName must be a not empty string.");
+    if (!is_string($userName) || empty($userName)) {
+          throw new \InvalidArgumentException("\$userName must be a not empty string.");
+    }
 
-    if (!is_string($password) || empty($password))
-      throw new \InvalidArgumentException("\$password must be a not empty string.");
+    if (!is_string($password) || empty($password)) {
+          throw new \InvalidArgumentException("\$password must be a not empty string.");
+    }
 
     $request = new Request(Request::POST_METHOD, "/_session");
 
@@ -544,8 +563,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)."/"));
   }
@@ -583,8 +603,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);
   }
@@ -773,40 +794,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");
@@ -823,8 +851,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;
@@ -873,15 +902,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, 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();
 
@@ -910,12 +940,13 @@ 
   public function queryView($dbName, $designDocName, $viewName, array $keys = NULL, Opt\ViewQueryOpts $opts = NULL, 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]));
     }
@@ -926,14 +957,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);
   }
@@ -960,30 +992,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);
   }
@@ -1042,8 +1077,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) || ($revsLimit <= 0))
-      throw new \InvalidArgumentException("\$revsLimit must be a positive integer.");
+    if (!is_int($revsLimit) || ($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");
@@ -1102,16 +1138,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();
@@ -1123,18 +1160,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;
   }
 
 
@@ -1154,8 +1191,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);
 
@@ -1169,8 +1207,9 @@ 
     $request->setBody($doc->asJson());
 
     // Enables batch mode.
-    if ($batchMode)
-      $request->setQueryParam("batch", "ok");
+    if ($batchMode) {
+          $request->setQueryParam("batch", "ok");
+    }
 
     $this->send($request);
   }
@@ -1223,10 +1262,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);
   }
@@ -1255,8 +1295,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));
 
@@ -1288,26 +1329,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);
@@ -1345,8 +1390,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)->getHeaderAsArray();
   }
@@ -1372,8 +1418,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();
   }
@@ -1402,8 +1449,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/Doc/LocalDoc.php

Braces +3 added lines, -2 removed lines

@@ -25,8 +25,9 @@
    * @brief Removes `_local/` from he document identifier.
    */
   protected function fixDocId() {
-    if (isset($this->meta['_id']))
-      $this->meta['_id'] = preg_replace('%\A_local/%m', "", $this->meta['_id']);
+    if (isset($this->meta['_id'])) {
+          $this->meta['_id'] = preg_replace('%\A_local/%m', "", $this->meta['_id']);
+    }
   }
 
 

src/EoC/Doc/DesignDoc.php

Braces +55 added lines, -46 removed lines

@@ -63,8 +63,9 @@ 
    * @brief Removes `_design/` from he document identifier.
    */
   protected function fixDocId() {
-    if (isset($this->meta['_id']))
-      $this->meta['_id'] = preg_replace('%\A_design/%m', "", $this->meta['_id']);
+    if (isset($this->meta['_id'])) {
+          $this->meta['_id'] = preg_replace('%\A_design/%m', "", $this->meta['_id']);
+    }
   }
 
 
@@ -94,8 +95,9 @@ 
    */
   public function resetHandlers() {
     foreach ($this->sections as $name => $value) {
-      if (array_key_exists($name, $this->meta))
-        unset($this->meta[$name]);
+      if (array_key_exists($name, $this->meta)) {
+              unset($this->meta[$name]);
+      }
     }
   }
 
@@ -108,16 +110,17 @@ 
    */
   public function getHandlerAttributes($section, $name = "") {
     if (empty($name)) { // The handler doesn't have a name.
-      if (array_key_exists($section, $this->meta))
-        return $this->meta[$section];
-      else
-        throw new \Exception(sprintf("Can't find '%s' handler in the design document.", $section));
-    }
-    else { // The handler has a name.
-      if (@array_key_exists($name, $this->meta[$section]))
-        return $this->meta[$section][$name];
-      else
-        throw new \Exception(sprintf("Can't find '%s' handler in the design document '%s' section.", $name, $section));
+      if (array_key_exists($section, $this->meta)) {
+              return $this->meta[$section];
+      } else {
+              throw new \Exception(sprintf("Can't find '%s' handler in the design document.", $section));
+      }
+    } else { // The handler has a name.
+      if (@array_key_exists($name, $this->meta[$section])) {
+              return $this->meta[$section][$name];
+      } else {
+              throw new \Exception(sprintf("Can't find '%s' handler in the design document '%s' section.", $name, $section));
+      }
     }
   }
 
@@ -133,22 +136,25 @@ 
     $section = $handler->getSection();
 
     if (property_exists($handler, "name")) {
-      if (!$handler->isConsistent())
-        throw new \Exception(sprintf("The '%s' handler '%s' is not consistent.", $section, $handler->name));
-
-      if (@array_key_exists($handler->name, $this->meta[$section]))
-        throw new \Exception(sprintf("The '%s' handler '%s' already exists.", $section, $handler->name));
-      else
-        $this->meta[$section][$handler->name] = $handler->asArray();
-    }
-    else {
-      if (!$handler->isConsistent())
-        throw new \Exception(sprintf("The '%s' handler is not consistent.", $section));
-
-      if (array_key_exists($section, $this->meta))
-        throw new \Exception(sprintf("The '%s' handler already exists.", $section));
-      else
-        $this->meta[$section] = $handler;
+      if (!$handler->isConsistent()) {
+              throw new \Exception(sprintf("The '%s' handler '%s' is not consistent.", $section, $handler->name));
+      }
+
+      if (@array_key_exists($handler->name, $this->meta[$section])) {
+              throw new \Exception(sprintf("The '%s' handler '%s' already exists.", $section, $handler->name));
+      } else {
+              $this->meta[$section][$handler->name] = $handler->asArray();
+      }
+    } else {
+      if (!$handler->isConsistent()) {
+              throw new \Exception(sprintf("The '%s' handler is not consistent.", $section));
+      }
+
+      if (array_key_exists($section, $this->meta)) {
+              throw new \Exception(sprintf("The '%s' handler already exists.", $section));
+      } else {
+              $this->meta[$section] = $handler;
+      }
     }
   }
 
@@ -163,16 +169,17 @@ 
    */
   public function removeHandler($section, $name = "") {
     if (empty($name)) { // The handler doesn't have a name.
-      if (array_key_exists($section, $this->meta))
-        unset($this->meta[$section]);
-      else
-        throw new \Exception(sprintf("Can't find the '%s' handler.", $section));
-    }
-    else { // The handler has a name.
-      if (@array_key_exists($name, $this->meta[$section]))
-        unset($this->meta[$section][$name]);
-      else
-        throw new \Exception(sprintf("Can't find the '%s' handler '%s'", $section, $name));
+      if (array_key_exists($section, $this->meta)) {
+              unset($this->meta[$section]);
+      } else {
+              throw new \Exception(sprintf("Can't find the '%s' handler.", $section));
+      }
+    } else { // The handler has a name.
+      if (@array_key_exists($name, $this->meta[$section])) {
+              unset($this->meta[$section][$name]);
+      } else {
+              throw new \Exception(sprintf("Can't find the '%s' handler '%s'", $section, $name));
+      }
     }
   }
 
@@ -190,16 +197,18 @@ 
 
 
   public function setLanguage($value) {
-    if (!empty($value))
-      $this->meta['language'] = strtolower((string)$value);
-    else
-      throw new \InvalidArgumentException("\$language must be a non-empty string.");
+    if (!empty($value)) {
+          $this->meta['language'] = strtolower((string)$value);
+    } else {
+          throw new \InvalidArgumentException("\$language must be a non-empty string.");
+    }
   }
 
 
   public function unsetLanguage() {
-    if ($this->isMetadataPresent('language'))
-      unset($this->meta['language']);
+    if ($this->isMetadataPresent('language')) {
+          unset($this->meta['language']);
+    }
   }
 
   //! @endcond

src/EoC/Doc/DocRef.php

Braces +5 added lines, -4 removed lines

@@ -59,10 +59,11 @@
 
 
   public function setId($value) {
-    if (!empty($value))
-      $this->id = (string)$value;
-    else
-      throw new \Exception("\$id must be a non-empty string.");
+    if (!empty($value)) {
+          $this->id = (string)$value;
+    } else {
+          throw new \Exception("\$id must be a non-empty string.");
+    }
   }
 
 

src/EoC/Doc/Attachment/Attachment.php

Braces +15 added lines, -12 removed lines

@@ -41,8 +41,9 @@ 
     $instance = new self();
 
     if (file_exists($fileName)) {
-      if (is_dir($fileName))
-        throw new \Exception("The file $fileName is a directory.");
+      if (is_dir($fileName)) {
+              throw new \Exception("The file $fileName is a directory.");
+      }
 
       $instance->name = basename($fileName);
 
@@ -58,14 +59,15 @@ 
         finfo_close($finfo);
         fclose($fd);
 
-        if ($instance->data === FALSE)
-          throw new \Exception("Error reading the file $fileName.");
+        if ($instance->data === FALSE) {
+                  throw new \Exception("Error reading the file $fileName.");
+        }
+      } else {
+              throw new \Exception("Cannot open the file $fileName.");
       }
-      else
-        throw new \Exception("Cannot open the file $fileName.");
+    } else {
+          throw new \Exception("The file $fileName doesn't exist.");
     }
-    else
-      throw new \Exception("The file $fileName doesn't exist.");
 
     return $instance;
   }
@@ -101,11 +103,12 @@ 
       $bytes = fwrite($fd, $this->data);
       fclose($fd);
 
-      if ($bytes === FALSE)
-        throw new \Exception("Error writing the file `$this->name`.");
+      if ($bytes === FALSE) {
+              throw new \Exception("Error writing the file `$this->name`.");
+      }
+    } else {
+          throw new \Exception("Cannot create the file `$this->name`.");
     }
-    else
-      throw new \Exception("Cannot create the file `$this->name`.");
   }
 
 

src/EoC/Generator/UUID.php

Spacing +18 added lines, -18 removed lines

@@ -67,29 +67,29 @@ 
  */
 class UUID {
   /* UUID versions */
-  const UUID_TIME	 = 1;	/* Time based UUID */
-  const UUID_NAME_MD5	 = 3;	/* Name based (MD5) UUID */
-  const UUID_RANDOM	 = 4;	/* Random UUID */
-  const UUID_NAME_SHA1	 = 5;	/* Name based (SHA1) UUID */
+  const UUID_TIME = 1; /* Time based UUID */
+  const UUID_NAME_MD5 = 3; /* Name based (MD5) UUID */
+  const UUID_RANDOM = 4; /* Random UUID */
+  const UUID_NAME_SHA1 = 5; /* Name based (SHA1) UUID */
 
   /* UUID formats */
   const FMT_FIELD	 = 100;
   const FMT_STRING	 = 101;
   const FMT_BINARY	 = 102;
-  const FMT_QWORD	 = 1;	/* Quad-word, 128-bit (not impl.) */
-  const FMT_DWORD	 = 2;	/* Double-word, 64-bit (not impl.) */
-  const FMT_WORD		 = 4;	/* Word, 32-bit (not impl.) */
-  const FMT_SHORT		= 8;	/* Short (not impl.) */
-  const FMT_BYTE		= 16;	/* Byte */
-  const FMT_DEFAULT	 = 16;
+  const FMT_QWORD	 = 1; /* Quad-word, 128-bit (not impl.) */
+  const FMT_DWORD	 = 2; /* Double-word, 64-bit (not impl.) */
+  const FMT_WORD		 = 4; /* Word, 32-bit (not impl.) */
+  const FMT_SHORT		= 8; /* Short (not impl.) */
+  const FMT_BYTE = 16; /* Byte */
+  const FMT_DEFAULT = 16;
 
   /* Field UUID representation */
   static private $m_uuid_field = array(
-    'time_low' => 0,		/* 32-bit */
-    'time_mid' => 0,		/* 16-bit */
-    'time_hi' => 0,			/* 16-bit */
-    'clock_seq_hi' => 0,		/*  8-bit */
-    'clock_seq_low' => 0,		/*  8-bit */
+    'time_low' => 0, /* 32-bit */
+    'time_mid' => 0, /* 16-bit */
+    'time_hi' => 0, /* 16-bit */
+    'clock_seq_hi' => 0, /*  8-bit */
+    'clock_seq_low' => 0, /*  8-bit */
     'node' => array()		/* 48-bit */
   );
 
@@ -284,7 +284,7 @@ 
     $uuid[9] = $src['clock_seq_low'];
 
     for ($i = 0; $i < 6; $i++)
-      $uuid[10+$i] = $src['node'][$i];
+      $uuid[10 + $i] = $src['node'][$i];
 
     return ($uuid);
   }
@@ -314,7 +314,7 @@ 
     $field['clock_seq_low'] = $uuid[9];
 
     for ($i = 0; $i < 6; $i++)
-      $field['node'][$i] = $uuid[10+$i];
+      $field['node'][$i] = $uuid[10 + $i];
     return ($field);
   }
 
@@ -339,7 +339,7 @@ 
     $field['clock_seq_hi'] = ($parts[3] & 0xff00) >> 8;
     $field['clock_seq_low'] = $parts[3] & 0x00ff;
     for ($i = 0; $i < 6; $i++)
-      $field['node'][$i] = $parts[4+$i];
+      $field['node'][$i] = $parts[4 + $i];
 
     return ($field);
   }

Braces +34 added lines, -25 removed lines

@@ -131,17 +131,18 @@ 
 
   /* Auto-detect UUID format */
   static private function detectFormat($src) {
-    if (is_string($src))
-      return self::FMT_STRING;
-    else if (is_array($src)) {
+    if (is_string($src)) {
+          return self::FMT_STRING;
+    } else if (is_array($src)) {
       $len = count($src);
-      if ($len == 1 || ($len % 2) == 0)
-        return $len;
-      else
-        return (-1);
+      if ($len == 1 || ($len % 2) == 0) {
+              return $len;
+      } else {
+              return (-1);
+      }
+    } else {
+          return self::FMT_BINARY;
     }
-    else
-      return self::FMT_BINARY;
   }
 
   /*
@@ -151,8 +152,9 @@ 
   static public function generate($type, $fmt = self::FMT_BYTE,
                                   $node = "", $ns = "") {
     $func = self::$m_generate[$type];
-    if (!isset($func))
-      return null;
+    if (!isset($func)) {
+          return null;
+    }
     $conv = self::$m_convert[self::FMT_FIELD][$fmt];
 
     $uuid = self::$func($ns, $node);
@@ -164,8 +166,9 @@ 
    */
   static public function convert($uuid, $from, $to) {
     $conv = self::$m_convert[$from][$to];
-    if (!isset($conv))
-      return ($uuid);
+    if (!isset($conv)) {
+          return ($uuid);
+    }
 
     return (self::$conv($uuid));
   }
@@ -181,8 +184,9 @@ 
     $uuid['time_low'] = mt_rand(0, 0xffff) + (mt_rand(0, 0xffff) << 16);
     $uuid['time_mid'] = mt_rand(0, 0xffff);
     $uuid['clock_seq_low'] = mt_rand(0, 255);
-    for ($i = 0; $i < 6; $i++)
-      $uuid['node'][$i] = mt_rand(0, 255);
+    for ($i = 0; $i < 6; $i++) {
+          $uuid['node'][$i] = mt_rand(0, 255);
+    }
     return ($uuid);
   }
 
@@ -205,8 +209,9 @@ 
     /* Hash the namespace and node and convert to a byte array */
     $val = $hash($raw, true);
     $tmp = unpack('C16', $val);
-    foreach (array_keys($tmp) as $key)
-      $byte[$key - 1] = $tmp[$key];
+    foreach (array_keys($tmp) as $key) {
+          $byte[$key - 1] = $tmp[$key];
+    }
 
     /* Convert byte array to a field array */
     $field = self::conv_byte2field($byte);
@@ -264,8 +269,9 @@ 
       * Node should be set to the 48-bit IEEE node identifier, but
       * we leave it for the user to supply the node.
       */
-    for ($i = 0; $i < 6; $i++)
-      $uuid['node'][$i] = ord(substr($node, $i, 1));
+    for ($i = 0; $i < 6; $i++) {
+          $uuid['node'][$i] = ord(substr($node, $i, 1));
+    }
 
     return ($uuid);
   }
@@ -283,8 +289,9 @@ 
     $uuid[8] = $src['clock_seq_hi'];
     $uuid[9] = $src['clock_seq_low'];
 
-    for ($i = 0; $i < 6; $i++)
-      $uuid[10+$i] = $src['node'][$i];
+    for ($i = 0; $i < 6; $i++) {
+          $uuid[10+$i] = $src['node'][$i];
+    }
 
     return ($uuid);
   }
@@ -313,8 +320,9 @@ 
     $field['clock_seq_hi'] = $uuid[8];
     $field['clock_seq_low'] = $uuid[9];
 
-    for ($i = 0; $i < 6; $i++)
-      $field['node'][$i] = $uuid[10+$i];
+    for ($i = 0; $i < 6; $i++) {
+          $field['node'][$i] = $uuid[10+$i];
+    }
     return ($field);
   }
 
@@ -338,8 +346,9 @@ 
     $field['time_hi'] = ($parts[2]);
     $field['clock_seq_hi'] = ($parts[3] & 0xff00) >> 8;
     $field['clock_seq_low'] = $parts[3] & 0x00ff;
-    for ($i = 0; $i < 6; $i++)
-      $field['node'][$i] = $parts[4+$i];
+    for ($i = 0; $i < 6; $i++) {
+          $field['node'][$i] = $parts[4+$i];
+    }
 
     return ($field);
   }

src/EoC/Handler/ViewHandler.php

Braces +18 added lines, -12 removed lines

@@ -144,8 +144,9 @@ 
   public static function checkFn($fnImpl, $fnDef, $fnRegex) {
     Lint::checkSourceCode($fnImpl);
 
-    if (!preg_match($fnRegex, $fnImpl))
-      throw new \Exception("The \$closure must be defined like: $fnDef");
+    if (!preg_match($fnRegex, $fnImpl)) {
+          throw new \Exception("The \$closure must be defined like: $fnDef");
+    }
   }
 
 
@@ -153,14 +154,17 @@ 
     $view = [];
     $view['map'] = $this->mapFn;
 
-    if (!empty($this->language))
-      $view['language'] = $this->language;
+    if (!empty($this->language)) {
+          $view['language'] = $this->language;
+    }
 
-    if (!empty($this->reduceFn))
-      $view['reduce'] = $this->reduceFn;
+    if (!empty($this->reduceFn)) {
+          $view['reduce'] = $this->reduceFn;
+    }
 
-    if (!empty($this->options))
-      $view['options'] = $this->options;
+    if (!empty($this->options)) {
+          $view['options'] = $this->options;
+    }
 
     return $view;
   }
@@ -225,8 +229,9 @@ 
   public function setMapFn($value) {
     $fn = stripslashes((string)$value);
 
-    if ($this->language == "php")
-      self::checkFn($fn, self::MAP_DEFINITION, self::MAP_REGEX);
+    if ($this->language == "php") {
+          self::checkFn($fn, self::MAP_DEFINITION, self::MAP_REGEX);
+    }
 
     $this->mapFn = $fn;
   }
@@ -240,8 +245,9 @@ 
   public function setReduceFn($value) {
     $fn = stripslashes((string)$value);
 
-    if ($this->language == "php")
-      self::checkFn($fn, self::REDUCE_DEFINITION, self::REDUCE_REGEX);
+    if ($this->language == "php") {
+          self::checkFn($fn, self::REDUCE_DEFINITION, self::REDUCE_REGEX);
+    }
 
     $this->reduceFn = $fn;
   }

src/EoC/Opt/ViewQueryOpts.php

Braces +15 added lines, -12 removed lines

@@ -36,8 +36,9 @@ 
    * @attention Chainable.
    */
   public function unsetOpt($name) {
-    if (array_key_exists($name, $this->options))
-      unset($this->options['name']);
+    if (array_key_exists($name, $this->options)) {
+          unset($this->options['name']);
+    }
 
     return $this;
   }
@@ -137,10 +138,11 @@ 
    * @attention Chainable.
    */
   public function setLimit($value) {
-    if (is_int($value) && $value >= 0)
-      $this->options["limit"] = $value;
-    else
-      throw new \Exception("\$value must be a non-negative integer.");
+    if (is_int($value) && $value >= 0) {
+          $this->options["limit"] = $value;
+    } else {
+          throw new \Exception("\$value must be a non-negative integer.");
+    }
 
     return $this;
   }
@@ -173,9 +175,9 @@ 
     if (is_int($value) && $value > 0) {
       $this->options["group"] = "false"; // This parameter is used only if 'group' is 'false'.
       $this->options["group_level"] = $value;
+    } else {
+          throw new \Exception("\$value must be a positive integer.");
     }
-    else
-      throw new \Exception("\$value must be a positive integer.");
 
     return $this;
   }
@@ -311,10 +313,11 @@ 
    * @attention Chainable.
    */
   public function skipDocs($number) {
-    if (is_int($number) && $number > 0)
-      $this->options["skip"] = $number;
-    else
-      throw new \Exception("\$number must be a positive integer.");
+    if (is_int($number) && $number > 0) {
+          $this->options["skip"] = $number;
+    } else {
+          throw new \Exception("\$number must be a positive integer.");
+    }
 
     return $this;
   }