dedalozzo / eoc-client

src/EoC/Adapter/SocketAdapter.php

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);
+    }
   }
 
 
@@ -123,8 +125,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;
@@ -144,18 +147,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()
@@ -168,18 +174,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.
@@ -188,8 +197,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;
@@ -216,8 +226,9 @@ 
         $body .= $buffer;
         $bytes += strlen($buffer);
 
-        if ($bytes >= $length)
-          break;
+        if ($bytes >= $length) {
+                  break;
+        }
       }
     }
 
@@ -232,10 +243,11 @@ 
    * @return string
    */
   protected function readResponseBody(Response $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);
+    }
   }
 
 
@@ -245,12 +257,14 @@ 
   public function send(Request $request, 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);