Smoren / multicurl-php

src/MultiCurlRunner.php

Spacing +29 added lines, -29 removed lines

@@ -48,7 +48,7 @@ 
 
         $mh = curl_multi_init();
 
-        if(!$mh) {
+        if (!$mh) {
             throw new RuntimeException("failed creating curl multi handle");
         }
 
@@ -65,18 +65,18 @@ 
      */
     public function run(): self
     {
-        for($i=0; $i<$this->maxConnections; ++$i) {
+        for ($i = 0; $i < $this->maxConnections; ++$i) {
             /** @var resource|false $unemployedWorker */
             $unemployedWorker = curl_init();
-            if(!$unemployedWorker) {
+            if (!$unemployedWorker) {
                 throw new RuntimeException("failed creating unemployed worker #{$i}");
             }
             $this->unemployedWorkers[] = $unemployedWorker;
         }
         unset($i, $this->unemployedWorker);
 
-        foreach($this->requestsConfigMap as $id => $options) {
-            while(!count($this->unemployedWorkers)) {
+        foreach ($this->requestsConfigMap as $id => $options) {
+            while (!count($this->unemployedWorkers)) {
                 $this->doWork();
             }
 
@@ -84,23 +84,23 @@ 
 
             $newWorker = array_pop($this->unemployedWorkers);
 
-            if(!curl_setopt_array($newWorker, $options)) {
+            if (!curl_setopt_array($newWorker, $options)) {
                 $errNo = curl_errno($newWorker);
                 $errMess = curl_error($newWorker);
                 $errData = var_export($options, true);
                 throw new RuntimeException("curl_setopt_array failed: {$errNo} {$errMess} {$errData}");
             }
 
-            $this->workersMap[(int)$newWorker] = $id;
+            $this->workersMap[(int) $newWorker] = $id;
             curl_multi_add_handle($this->mh, $newWorker);
         }
         unset($options);
 
-        while(count($this->workersMap) > 0) {
+        while (count($this->workersMap) > 0) {
             $this->doWork();
         }
 
-        foreach($this->unemployedWorkers as $unemployedWorker) {
+        foreach ($this->unemployedWorkers as $unemployedWorker) {
             curl_close($unemployedWorker);
         }
 
@@ -119,8 +119,8 @@ 
     {
         $result = [];
 
-        foreach($this->result as $key => $value) {
-            if(!$okOnly || $value['code'] === 200) {
+        foreach ($this->result as $key => $value) {
+            if (!$okOnly || $value['code'] === 200) {
                 $result[$key] = $value;
             }
         }
@@ -138,8 +138,8 @@ 
     {
         $result = [];
 
-        foreach($this->result as $key => $value) {
-            if(!$okOnly || $value['code'] >= 200 && $value['code'] < 300) {
+        foreach ($this->result as $key => $value) {
+            if (!$okOnly || $value['code'] >= 200 && $value['code'] < 300) {
                 $result[$key] = $value['body'];
             }
         }
@@ -156,12 +156,12 @@ 
         assert(count($this->workersMap) > 0, "work() called with 0 workers!!");
         $stillRunning = null;
 
-        while(true) {
+        while (true) {
             do {
                 $err = curl_multi_exec($this->mh, $stillRunning);
-            } while($err === CURLM_CALL_MULTI_PERFORM);
+            } while ($err === CURLM_CALL_MULTI_PERFORM);
 
-            if($err !== CURLM_OK) {
+            if ($err !== CURLM_OK) {
                 $errInfo = [
                     "multi_exec_return" => $err,
                     "curl_multi_errno" => curl_multi_errno($this->mh),
@@ -171,7 +171,7 @@ 
                 $errData = str_replace(["\r", "\n"], "", var_export($errInfo, true));
                 throw new RuntimeException("curl_multi_exec error: {$errData}");
             }
-            if($stillRunning < count($this->workersMap)) {
+            if ($stillRunning < count($this->workersMap)) {
                 // some workers has finished downloading, process them
                 // echo "processing!";
                 break;
@@ -181,13 +181,13 @@ 
                 // sleep(1);
             }
         }
-        while(($info = curl_multi_info_read($this->mh)) !== false) {
-            if($info['msg'] !== CURLMSG_DONE) {
+        while (($info = curl_multi_info_read($this->mh)) !== false) {
+            if ($info['msg'] !== CURLMSG_DONE) {
                 // no idea what this is, it's not the message we're looking for though, ignore it.
                 continue;
             }
 
-            if($info['result'] !== CURLM_OK) {
+            if ($info['result'] !== CURLM_OK) {
                 $errInfo = [
                     "effective_url" => curl_getinfo($info['handle'], CURLINFO_EFFECTIVE_URL),
                     "curl_errno" => curl_errno($info['handle']),
@@ -201,7 +201,7 @@ 
             }
 
             $ch = $info['handle'];
-            $chIndex = (int)$ch;
+            $chIndex = (int) $ch;
 
             $this->result[$this->workersMap[$chIndex]] = $this->parseResponse(curl_multi_getcontent($ch));
 
@@ -224,29 +224,29 @@ 
         $statusCode = null;
         $body = null;
 
-        while(count($arResponse)) {
+        while (count($arResponse)) {
             $respItem = array_shift($arResponse);
 
-            $line = (string)strtok($respItem, "\r\n");
+            $line = (string) strtok($respItem, "\r\n");
             $statusCodeLine = trim($line);
-            if(preg_match('|HTTP/[\d.]+\s+(\d+)|', $statusCodeLine, $matches)) {
+            if (preg_match('|HTTP/[\d.]+\s+(\d+)|', $statusCodeLine, $matches)) {
                 $arHeaders = [];
 
-                if(isset($matches[1])) {
-                    $statusCode = (int)$matches[1];
+                if (isset($matches[1])) {
+                    $statusCode = (int) $matches[1];
                 } else {
                     $statusCode = null;
                 }
 
                 // Parse the string, saving it into an array instead
-                while(($line = strtok("\r\n")) !== false) {
-                    if(($matches = explode(':', $line, 2)) !== false) {
+                while (($line = strtok("\r\n")) !== false) {
+                    if (($matches = explode(':', $line, 2)) !== false) {
                         $arHeaders[trim(mb_strtolower($matches[0]))] = trim(mb_strtolower($matches[1]));
                     }
                 }
             } else {
                 $contentType = $arHeaders['content-type'] ?? null;
-                if($contentType === 'application/json') {
+                if ($contentType === 'application/json') {
                     $body = json_decode($respItem, true);
                 } else {
                     $body = $respItem;

src/MultiCurl.php

Spacing +8 added lines, -8 removed lines

@@ -45,7 +45,7 @@ 
             CURLOPT_ENCODING => ''
         ];
 
-        foreach($commonOptions as $key => $value) {
+        foreach ($commonOptions as $key => $value) {
             $this->commonOptions[$key] = $value;
         }
 
@@ -84,23 +84,23 @@ 
         array $options = [],
         array $headers = []
     ): self {
-        foreach($this->commonOptions as $key => $value) {
-            if(!array_key_exists($key, $options)) {
+        foreach ($this->commonOptions as $key => $value) {
+            if (!array_key_exists($key, $options)) {
                 $options[$key] = $value;
             }
         }
 
-        foreach($this->commonHeaders as $key => $value) {
-            if(!array_key_exists($key, $headers)) {
+        foreach ($this->commonHeaders as $key => $value) {
+            if (!array_key_exists($key, $headers)) {
                 $headers[$key] = $value;
             }
         }
 
-        if(is_array($body)) {
+        if (is_array($body)) {
             $body = json_encode($body);
         }
 
-        if($body !== null) {
+        if ($body !== null) {
             $options[CURLOPT_POSTFIELDS] = strval($body);
         }
 
@@ -121,7 +121,7 @@ 
     {
         $result = [];
 
-        foreach($headers as $key => $value) {
+        foreach ($headers as $key => $value) {
             $result[] = "{$key}: {$value}";
         }