dedalozzo / eoc-client

src/EoC/Adapter/AbstractAdapter.php

Braces +3 added lines, -2 removed lines

@@ -68,9 +68,10 @@
       $this->scheme = isset($matches['scheme']) ? $matches['scheme'] : "tcp://";
       $this->host = isset($matches['host']) ? $matches['host'] : self::DEFAULT_HOST;
       $this->port = isset($matches['port']) ? substr($matches['port'], 1) : self::DEFAULT_PORT;
-    }
-    else // Match attempt failed.
+    } else {
+      // Match attempt failed.
       throw new \InvalidArgumentException(sprintf("'%s' is not a valid URI.", $server));
+    }
 
     $this->userName = (string)$userName;
     $this->password = (string)$password;

src/EoC/Adapter/CurlAdapter.php

Braces +12 added lines, -10 removed lines

@@ -52,8 +52,9 @@ 
    * @copydoc AbstractAdapter::initialize()
    */
   public function initialize() {
-    if (!extension_loaded("curl"))
-      throw new \RuntimeException("The cURL extension is not loaded.");
+    if (!extension_loaded("curl")) {
+          throw new \RuntimeException("The cURL extension is not loaded.");
+    }
   }
 
 
@@ -64,8 +65,9 @@ 
     $opts = [];
 
     // Resets all the cURL options. The curl_reset() function is available only since PHP 5.5.
-    if (function_exists('curl_reset'))
-      curl_reset($this->handle);
+    if (function_exists('curl_reset')) {
+          curl_reset($this->handle);
+    }
 
     // Sets the methods and its related options.
     switch ($request->getMethod()) {
@@ -100,9 +102,9 @@ 
 
             $opts[CURLOPT_INFILE] = $fd;
             $opts[CURLOPT_INFILESIZE] = $request->getBodyLength();
+          } else {
+                      throw new \RuntimeException("Cannot create the stream.");
           }
-          else
-            throw new \RuntimeException("Cannot create the stream.");
         }
 
         break;
@@ -143,8 +145,9 @@ 
     // This fix a known cURL bug: see http://the-stickman.com/web-development/php-and-curl-disabling-100-continue-header/
     // cURL sets the Expect header field automatically, ignoring the fact that a client may not need it for the specific
     // request.
-    if (!$request->hasHeaderField(Request::EXPECT_HF))
-      curl_setopt($this->handle, CURLOPT_HTTPHEADER, array("Expect:"));
+    if (!$request->hasHeaderField(Request::EXPECT_HF)) {
+          curl_setopt($this->handle, CURLOPT_HTTPHEADER, array("Expect:"));
+    }
 
     // Sets the request header.
     // Due to a stupid bug, using curl_setopt_array(), cURL doesn't override the Content-Type header field. So we must
@@ -176,8 +179,7 @@ 
       $response = new Response($header);
       $response->setBody($result);
       return $response;
-    }
-    else {
+    } else {
       $error = curl_error($this->handle);
       throw new \RuntimeException($error);
     }

src/EoC/Adapter/NativeAdapter.php

Indentation +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
   /**
    * @copydoc AbstractAdapter::__construct()
    * @param[in] bool $persistent (optional) When `true` the client uses a persistent connection.
-  */
+   */
   public function __construct($server = parent::DEFAULT_SERVER, $userName = "", $password = "", $persistent = TRUE) {
     $this->initialize();
 

Braces +46 added lines, -32 removed lines

@@ -56,13 +56,15 @@ 
     $this->timeout = static::$defaultSocketTimeout;
 
     // Establishes a connection within the server.
-    if ($persistent)
-      $this->handle = @pfsockopen($this->scheme.$this->host, $this->port, $errno, $errstr, $this->timeout);
-    else
-      $this->handle = @fsockopen($this->scheme.$this->host, $this->port, $errno, $errstr, $this->timeout);
+    if ($persistent) {
+          $this->handle = @pfsockopen($this->scheme.$this->host, $this->port, $errno, $errstr, $this->timeout);
+    } else {
+          $this->handle = @fsockopen($this->scheme.$this->host, $this->port, $errno, $errstr, $this->timeout);
+    }
 
-    if (!is_resource($this->handle))
-      throw new \ErrorException($errstr, $errno);
+    if (!is_resource($this->handle)) {
+          throw new \ErrorException($errstr, $errno);
+    }
   }
 
 
@@ -117,8 +119,9 @@ 
       $statusCodeAndHeader .= $buffer;
 
       // The header is separated from the body by a newline, so we break when we read it.
-      if ($buffer == Message::CRLF)
-        break;
+      if ($buffer == Message::CRLF) {
+              break;
+      }
     }
 
     return $statusCodeAndHeader;
@@ -135,18 +138,21 @@ 
 
       // If it's only a newline, this normally means it's read the total amount of data requested minus the newline
       // continue to next loop to make sure we're done.
-      if ($line == Message::CRLF)
-        continue;
+      if ($line == Message::CRLF) {
+              continue;
+      }
 
       // The length of the block is expressed in hexadecimal.
       $length = hexdec($line);
 
-      if (!is_int($length))
-        throw new \RuntimeException("The response doesn't seem chunk encoded.");
+      if (!is_int($length)) {
+              throw new \RuntimeException("The response doesn't seem chunk encoded.");
+      }
 
       // Zero is sent when at the end of the chunks or the end of the stream.
-      if ($length < 1)
-        break;
+      if ($length < 1) {
+              break;
+      }
 
       // Reads the chunk.
       // When reading from network streams or pipes, such as those returned when reading remote files or from popen()
@@ -159,18 +165,21 @@ 
         $size = min(self::BUFFER_LENGTH, $length);
         $data = fread($this->handle, $size);
 
-        if (strlen($data) == 0)
-          break; // EOF
+        if (strlen($data) == 0) {
+                  break;
+        }
+        // EOF
 
         $buffer .= $data;
         $length -= strlen($data);
       }
 
       // If a function has been hooked, calls it, else just adds the buffer to the body.
-      if (is_null($chunkHook))
-        $body .= $buffer;
-      else
-        $chunkHook->process($buffer);
+      if (is_null($chunkHook)) {
+              $body .= $buffer;
+      } else {
+              $chunkHook->process($buffer);
+      }
     }
 
     // A chunk response might have some footer, but CouchDB doesn't use them, so we simply ignore them.
@@ -179,8 +188,9 @@ 
       $buffer = fgets($this->handle, self::BUFFER_LENGTH);
 
       // The chunk response ends with a newline, so we break when we read it.
-      if ($buffer == Message::CRLF)
-        break;
+      if ($buffer == Message::CRLF) {
+              break;
+      }
     }
 
     return $body;
@@ -203,8 +213,9 @@ 
         $body .= $buffer;
         $bytes += strlen($buffer);
 
-        if ($bytes >= $length)
-          break;
+        if ($bytes >= $length) {
+                  break;
+        }
       }
     }
 
@@ -214,10 +225,11 @@ 
 
   // Reads the entity-body.
   protected function readResponseBody($response, $chunkHook) {
-    if ($response->getHeaderFieldValue(Response::TRANSFER_ENCODING_HF) == "chunked")
-      return $this->readChunkedResponseBody($chunkHook);
-    else
-      return $this->readStandardResponseBody($response);
+    if ($response->getHeaderFieldValue(Response::TRANSFER_ENCODING_HF) == "chunked") {
+          return $this->readChunkedResponseBody($chunkHook);
+    } else {
+          return $this->readStandardResponseBody($response);
+    }
   }
 
 
@@ -227,12 +239,14 @@ 
   public function send(Request $request, Hook\IChunkHook $chunkHook = NULL) {
     $request->setHeaderField(Request::HOST_HF, $this->host.":".$this->port);
 
-    if (!empty($this->userName))
-      $request->setBasicAuth($this->userName, $this->password);
+    if (!empty($this->userName)) {
+          $request->setBasicAuth($this->userName, $this->password);
+    }
 
     // Sets the Content-Length header only when the given request has a message body.
-    if ($request->hasBody())
-      $request->setHeaderField(Message::CONTENT_LENGTH_HF, $request->getBodyLength());
+    if ($request->hasBody()) {
+          $request->setHeaderField(Message::CONTENT_LENGTH_HF, $request->getBodyLength());
+    }
 
     // Writes the request over the socket.
     $this->writeRequest($request);

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/Result/QueryResult.php

Spacing +2 added lines, -2 removed lines

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