hirak / prestissimo

src/CurlRemoteFilesystem.php

Doc Comments +6 added lines

@@ -108,6 +108,12 @@
         });
     }
 
+    /**
+     * @param string $origin
+     * @param string $fileUrl
+     * @param boolean $progress
+     * @param \Closure $exec
+     */
     protected function fetch($origin, $fileUrl, $progress, $options, $exec)
     {
         do {

Spacing +8 added lines, -8 removed lines

@@ -64,11 +64,11 @@ 
      *
      * @return bool true
      */
-    public function copy($origin, $fileUrl, $fileName, $progress=true, $options=array())
+    public function copy($origin, $fileUrl, $fileName, $progress = true, $options = array())
     {
         $that = $this; // for PHP5.3
 
-        return $this->fetch($origin, $fileUrl, $progress, $options, function ($ch, $request) use ($that, $fileName) {
+        return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that, $fileName) {
             $outputFile = new OutputFile($fileName);
             curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
             curl_setopt($ch, CURLOPT_FILE, $outputFile->getPointer());
@@ -95,11 +95,11 @@ 
      *
      * @return bool|string The content
      */
-    public function getContents($origin, $fileUrl, $progress=true, $options=array())
+    public function getContents($origin, $fileUrl, $progress = true, $options = array())
     {
         $that = $this; // for PHP5.3
 
-        return $this->fetch($origin, $fileUrl, $progress, $options, function ($ch, $request) use ($that) {
+        return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that) {
             // This order is important.
             curl_setopt($ch, CURLOPT_FILE, STDOUT);
             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
@@ -154,13 +154,13 @@ 
             if ($this->pluginConfig['insecure']) {
                 $opts[CURLOPT_SSL_VERIFYPEER] = false;
             }
-            if (! empty($pluginConfig['capath'])) {
+            if (!empty($pluginConfig['capath'])) {
                 $opts[CURLOPT_CAPATH] = $pluginConfig['capath'];
             }
 
             curl_setopt_array($ch, $opts);
 
-            list($execStatus, ) = $exec($ch, $request);
+            list($execStatus,) = $exec($ch, $request);
         } while ($this->_retry);
 
         if ($progress) {
@@ -224,9 +224,9 @@ 
     {
         // @codeCoverageIgnoreStart
         if (PHP_VERSION_ID >= 50500) {
-            list(, $downBytesMax, $downBytes, , ) = func_get_args();
+            list(, $downBytesMax, $downBytes,,) = func_get_args();
         } else {
-            list($downBytesMax, $downBytes, , ) = func_get_args();
+            list($downBytesMax, $downBytes,,) = func_get_args();
         }
         // @codeCoverageIgnoreEnd
 

src/ParallelDownloader.php

Switch Indentation +33 added lines, -33 removed lines

@@ -122,41 +122,41 @@
                 } while ($stat === CURLM_CALL_MULTI_PERFORM);
 
                 switch (curl_multi_select($mh, 5)) {
-                case -1:
-                    usleep(250);
-                    // fall through
-                case 0:
-                    continue 2;
-                default:
-                    do {
-                        $stat = curl_multi_exec($mh, $running);
-                    } while ($stat === CURLM_CALL_MULTI_PERFORM);
-
-                    do {
-                        if ($raised = curl_multi_info_read($mh, $remains)) {
-                            $ch = $raised['handle'];
-                            $errno = curl_errno($ch);
-                            $info = curl_getinfo($ch);
-                            curl_setopt($ch, CURLOPT_FILE, STDOUT);
-                            $index = (int)$ch;
-                            $outputFile = $chFpMap[$index];
-                            unset($chFpMap[$index]);
-                            if (CURLE_OK === $errno && 200 === $info['http_code']) {
-                                ++$this->successCnt;
-                            } else {
-                                ++$this->failureCnt;
-                                $outputFile->setFailure();
+                    case -1:
+                        usleep(250);
+                        // fall through
+                    case 0:
+                        continue 2;
+                    default:
+                        do {
+                            $stat = curl_multi_exec($mh, $running);
+                        } while ($stat === CURLM_CALL_MULTI_PERFORM);
+
+                        do {
+                            if ($raised = curl_multi_info_read($mh, $remains)) {
+                                $ch = $raised['handle'];
+                                $errno = curl_errno($ch);
+                                $info = curl_getinfo($ch);
+                                curl_setopt($ch, CURLOPT_FILE, STDOUT);
+                                $index = (int)$ch;
+                                $outputFile = $chFpMap[$index];
+                                unset($chFpMap[$index]);
+                                if (CURLE_OK === $errno && 200 === $info['http_code']) {
+                                    ++$this->successCnt;
+                                } else {
+                                    ++$this->failureCnt;
+                                    $outputFile->setFailure();
+                                }
+                                unset($outputFile);
+                                $this->io->write($this->makeDownloadingText($info['url']));
+                                curl_multi_remove_handle($mh, $ch);
+                                $unused[] = $ch;
                             }
-                            unset($outputFile);
-                            $this->io->write($this->makeDownloadingText($info['url']));
-                            curl_multi_remove_handle($mh, $ch);
-                            $unused[] = $ch;
-                        }
-                    } while ($remains > 0);
+                        } while ($remains > 0);
 
-                    if (count($packages) > 0) {
-                        break 2;
-                    }
+                        if (count($packages) > 0) {
+                            break 2;
+                        }
                 }
             } while ($running);
         } while (count($packages) > 0);