Gendoria / cruftflake

src/Gendoria/CruftFlake/Config/ConsulCurl.php

Doc Comments +6 added lines

@@ -25,6 +25,9 @@ 
         $this->apiPrefix = $apiPrefix;
     }
     
+    /**
+     * @param string $url
+     */
     public function performGetRequest($url)
     {
         $curlUrl = $this->consulBaseUrl . $this->apiPrefix . $url;
@@ -35,6 +38,9 @@ 
         return $returnData;
     }
     
+    /**
+     * @param string $url
+     */
     public function performPutRequest($url, $payload = null)
     {
         $curlUrl = $this->consulBaseUrl . $this->apiPrefix . $url;

Spacing +3 added lines, -3 removed lines

@@ -27,7 +27,7 @@ 
     
     public function performGetRequest($url)
     {
-        $curlUrl = $this->consulBaseUrl . $this->apiPrefix . $url;
+        $curlUrl = $this->consulBaseUrl.$this->apiPrefix.$url;
         $ch = curl_init($curlUrl);
         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
         $result = curl_exec($ch);
@@ -37,7 +37,7 @@ 
     
     public function performPutRequest($url, $payload = null)
     {
-        $curlUrl = $this->consulBaseUrl . $this->apiPrefix . $url;
+        $curlUrl = $this->consulBaseUrl.$this->apiPrefix.$url;
         $ch = curl_init($curlUrl);
         curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PUT");
         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
@@ -49,7 +49,7 @@ 
         curl_setopt($ch, CURLOPT_HTTPHEADER,
             array(
             'Content-Type: application/json',
-            'Content-Length: ' . strlen($payload))
+            'Content-Length: '.strlen($payload))
         );
         $result = curl_exec($ch);
         $returnData = json_decode($result, true);

src/Gendoria/CruftFlake/Config/ConsulConfig.php

Spacing +5 added lines, -5 removed lines

@@ -55,7 +55,7 @@ 
     {
         $this->curl = $curl;
         $this->kvPrefix = $kvPrefix;
-        $this->sessionTTL = (int)$sessionTTL;
+        $this->sessionTTL = (int) $sessionTTL;
         //If we cannot connect to Consul on start, we have a problem.
         $this->createSession();
         $this->lastSuccessfullCheck = time();
@@ -92,7 +92,7 @@ 
     public function heartbeat()
     {
         //If we have last successfull check recently new, we don't have to do anything
-        if ($this->lastSuccessfullCheck && time() - $this->lastSuccessfullCheck < $this->sessionTTL / 2 ) {
+        if ($this->lastSuccessfullCheck && time()-$this->lastSuccessfullCheck < $this->sessionTTL / 2) {
             return false;
         }
         //If session reneval succeedes, update last successfull check.
@@ -109,7 +109,7 @@ 
         } catch (RuntimeException $e) {
             //We could not create new session. We can work for some time in 'detached' mode,
             //but if our TTL time runs out, we have to throw an exception.
-            if (!$this->lastSuccessfullCheck || time() - $this->lastSuccessfullCheck >= $this->sessionTTL) {
+            if (!$this->lastSuccessfullCheck || time()-$this->lastSuccessfullCheck >= $this->sessionTTL) {
                 throw $e;
             }
             return false;
@@ -178,12 +178,12 @@ 
 
     private function createSession()
     {
-        $url ='/session/create';
+        $url = '/session/create';
         //We create new session with given TTL and with lock delay equal to half of TTL.
         $payload = array(
             'TTL' => $this->sessionTTL.'s',
             "Behavior" => "delete",
-            'LockDelay' => floor($this->sessionTTL/2).'s',
+            'LockDelay' => floor($this->sessionTTL / 2).'s',
         );
         $returnData = $this->curl->performPutRequest($url, json_encode($payload));
         if (empty($returnData['ID'])) {

Braces +1 added lines, -2 removed lines

@@ -147,8 +147,7 @@
                 continue;
             } elseif ($currentValue['Key'] == $this->sessionId) {
                 return base64_decode($currentValue['Value']);
-            }
-            else {
+            } else {
                 $usedIds[] = base64_decode($currentValue['Value']);
             }
         }