cvweiss / guzzler

src/Guzzler.php

Indentation +13 added lines, -13 removed lines

@@ -14,7 +14,7 @@ 
 
     public function __construct($maxConcurrent = 10, $usleep = 100000, $userAgent = 'cvweiss/guzzler/', $curlOptions = [])
     {
-	$curlOptions = $curlOptions == [] ? [CURLOPT_FRESH_CONNECT => false] : $curlOptions;
+    $curlOptions = $curlOptions == [] ? [CURLOPT_FRESH_CONNECT => false] : $curlOptions;
 
         $this->curl = new \GuzzleHttp\Handler\CurlMultiHandler();
         $this->handler = \GuzzleHttp\HandlerStack::create($this->curl);
@@ -33,7 +33,7 @@ 
         $ms = microtime();
         do {
             $this->curl->tick();
-	    if ($this->concurrent >= $this->maxConcurrent) usleep(max(1, min(1000000, $this->usleep)));
+        if ($this->concurrent >= $this->maxConcurrent) usleep(max(1, min(1000000, $this->usleep)));
         } while ($this->concurrent >= $this->maxConcurrent);
         return max(0, microtime() - $ms);
     }
@@ -60,14 +60,14 @@ 
         $this->verifyCallable($fulfilled);
         $this->verifyCallable($rejected);
 
-	$params['uri'] = $uri;
-	$params['fulfilled'] = $fulfilled;
-	$params['rejected'] = $rejected;
-	$params['setup'] = $setup;
-	$params['callType'] = $callType;
-	$params['body'] = $body;
+    $params['uri'] = $uri;
+    $params['fulfilled'] = $fulfilled;
+    $params['rejected'] = $rejected;
+    $params['setup'] = $setup;
+    $params['callType'] = $callType;
+    $params['body'] = $body;
 
-	$redis = $this->applyEtag($setup, $params);
+    $redis = $this->applyEtag($setup, $params);
 
         $guzzler = $this;
         $request = new \GuzzleHttp\Psr7\Request($callType, $uri, $setup, $body);
@@ -76,7 +76,7 @@ 
                 $guzzler->dec();
                 $content = (string) $response->getBody();
                 $this->lastHeaders = array_change_key_case($response->getHeaders());
-		$this->applyEtagPost($this->lastHeaders, $params['uri'], $content, $redis);
+        $this->applyEtagPost($this->lastHeaders, $params['uri'], $content, $redis);
                 $fulfilled($guzzler, $params, $content);
             },
             function($connectionException) use (&$guzzler, &$rejected, &$params) {
@@ -98,14 +98,14 @@ 
             if ($etag != "") $setup['If-None-Match'] = $etag;
         }
         unset($setup['etag']);
-	return $redis;
+    return $redis;
     }
 
     protected function applyEtagPost($headers, $uri, $content, $redis)
     {
         if (isset($headers['etag']) && strlen($content) == 0 && $redis !== null) {
-	    $redis->setex("guzzler:etags:$uri", 604800, $headers['etag'][0]);
-	}
+        $redis->setex("guzzler:etags:$uri", 604800, $headers['etag'][0]);
+    }
     }
 
     public function verifyCallable($callable)

Braces +6 added lines, -2 removed lines

@@ -33,7 +33,9 @@ 
         $ms = microtime();
         do {
             $this->curl->tick();
-	    if ($this->concurrent >= $this->maxConcurrent) usleep(max(1, min(1000000, $this->usleep)));
+	    if ($this->concurrent >= $this->maxConcurrent) {
+	        usleep(max(1, min(1000000, $this->usleep)));
+	    }
         } while ($this->concurrent >= $this->maxConcurrent);
         return max(0, microtime() - $ms);
     }
@@ -95,7 +97,9 @@ 
         $redis = isset($setup['etag']) ? $setup['etag'] : null;
         if ($redis !== null && $params['callType'] == 'GET') {
             $etag = $redis->get("guzzler:etags:" . $params['uri']);
-            if ($etag != "") $setup['If-None-Match'] = $etag;
+            if ($etag != "") {
+                $setup['If-None-Match'] = $etag;
+            }
         }
         unset($setup['etag']);
 	return $redis;