Gendoria / cruftflake

src/Gendoria/CruftFlake/Generator/Generator.php

Spacing +3 added lines, -3 removed lines

@@ -115,7 +115,7 @@ 
      */
     public function generate()
     {
-        $t = (int) floor($this->timer->getUnixTimestamp() - $this->epoch);
+        $t = (int) floor($this->timer->getUnixTimestamp()-$this->epoch);
         if ($t !== $this->lastTime) {
             $this->generateWithDifferentTime($t);
         } else {
@@ -152,7 +152,7 @@ 
         if ($t < $this->lastTime) {
             throw new UnexpectedValueException(
             'Time moved backwards. We cannot generate IDs for '
-            .($this->lastTime - $t).' milliseconds'
+            .($this->lastTime-$t).' milliseconds'
             );
         } elseif ($t < 0) {
             throw new UnexpectedValueException(
@@ -221,7 +221,7 @@ 
     private function hexdec($hex)
     {
         $dec = 0;
-        for ($i = strlen($hex) - 1, $e = 1; $i >= 0; $i--, $e = bcmul($e, 16)) {
+        for ($i = strlen($hex)-1, $e = 1; $i >= 0; $i--, $e = bcmul($e, 16)) {
             $factor = self::$hexdec[$hex[$i]];
             $dec = bcadd($dec, bcmul($factor, $e));
         }

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

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']);
             }
         }

Spacing +10 added lines, -10 removed lines

@@ -77,7 +77,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();
@@ -114,7 +114,7 @@ 
     public function heartbeat()
     {
         //If we have last successfull check recently new, we don't have to do anything
-        if ($this->lastSuccessfullCheck !== null && time() - $this->lastSuccessfullCheck < $this->sessionTTL / 2 ) {
+        if ($this->lastSuccessfullCheck !== null && time()-$this->lastSuccessfullCheck < $this->sessionTTL / 2) {
             return false;
         }
         //If session reneval succeedes, update last successfull check.
@@ -131,7 +131,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 === null || time() - $this->lastSuccessfullCheck >= $this->sessionTTL) {
+            if ($this->lastSuccessfullCheck === null || time()-$this->lastSuccessfullCheck >= $this->sessionTTL) {
                 throw $e;
             }
             return false;
@@ -149,7 +149,7 @@ 
         //Check, if we don't have existing value for the session
         $currentValue = $this->curl->performGetRequest('/kv/'.$this->kvPrefix.$this->sessionId);
         if (!empty($currentValue['Value'])) {
-            return (int)base64_decode($currentValue['Value']);
+            return (int) base64_decode($currentValue['Value']);
         }
         //Lock main key to block concurrent checks
         $this->lockKey();
@@ -164,7 +164,7 @@ 
         }
         //Release the lock on the main key and return machine ID.
         $this->releaseKey();
-        return (int)$machineId;
+        return (int) $machineId;
     }
     
     /**
@@ -181,10 +181,10 @@ 
             if ($currentValue['Key'] == $this->kvPrefix) {
                 continue;
             } elseif ($currentValue['Key'] == $this->sessionId) {
-                return (int)base64_decode($currentValue['Value']);
+                return (int) base64_decode($currentValue['Value']);
             }
             else {
-                $usedIds[] = (int)base64_decode($currentValue['Value']);
+                $usedIds[] = (int) base64_decode($currentValue['Value']);
             }
         }
         for ($k = 0; $k < 1024; $k++) {
@@ -201,7 +201,7 @@ 
     private function lockKey()
     {
         //try to acquire the lock on prefix during whole operation.
-        $tryCount=0;
+        $tryCount = 0;
         do {
             $acquired = $this->curl->performPutRequest('/kv/'.$this->kvPrefix.'?acquire='.$this->sessionId."&flags=".$tryCount, $this->sessionId);
             if (!$acquired) {
@@ -226,12 +226,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'])) {

src/Gendoria/CruftFlake/Config/DoctrineConfig.php

Spacing +2 added lines, -2 removed lines

@@ -110,7 +110,7 @@ 
     public function heartbeat()
     {
         //If we have last successfull check recently new, we don't have to do anything
-        if ($this->lastSuccessfullCheck !== null && time() - $this->lastSuccessfullCheck < $this->sessionTTL / 2) {
+        if ($this->lastSuccessfullCheck !== null && time()-$this->lastSuccessfullCheck < $this->sessionTTL / 2) {
             return false;
         }
         
@@ -243,7 +243,7 @@ 
      */
     private function gc()
     {
-        $lastAccess = time() - $this->sessionTTL;
+        $lastAccess = time()-$this->sessionTTL;
         $qb = $this->connection->createQueryBuilder();
         $qb->delete($this->tableName)
             ->where('last_access < ?')