Completed
Push — master ( 9b1dc4...47b508 )
by Tomasz
02:44
created
src/Gendoria/CruftFlake/Config/ConsulConfig.php 1 patch
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -62,7 +62,7 @@  discard block
 block discarded – undo
62 62
     {
63 63
         $this->curl = $curl;
64 64
         $this->kvPrefix = $kvPrefix;
65
-        $this->sessionTTL = (int)$sessionTTL;
65
+        $this->sessionTTL = (int) $sessionTTL;
66 66
         //If we cannot connect to Consul on start, we have a problem.
67 67
         $this->createSession();
68 68
         $this->lastSuccessfullCheck = time();
@@ -99,7 +99,7 @@  discard block
 block discarded – undo
99 99
     public function heartbeat()
100 100
     {
101 101
         //If we have last successfull check recently new, we don't have to do anything
102
-        if ($this->lastSuccessfullCheck !== null && time() - $this->lastSuccessfullCheck < $this->sessionTTL / 2 ) {
102
+        if ($this->lastSuccessfullCheck !== null && time()-$this->lastSuccessfullCheck < $this->sessionTTL / 2) {
103 103
             return false;
104 104
         }
105 105
         //If session reneval succeedes, update last successfull check.
@@ -116,7 +116,7 @@  discard block
 block discarded – undo
116 116
         } catch (RuntimeException $e) {
117 117
             //We could not create new session. We can work for some time in 'detached' mode,
118 118
             //but if our TTL time runs out, we have to throw an exception.
119
-            if ($this->lastSuccessfullCheck === null || time() - $this->lastSuccessfullCheck >= $this->sessionTTL) {
119
+            if ($this->lastSuccessfullCheck === null || time()-$this->lastSuccessfullCheck >= $this->sessionTTL) {
120 120
                 throw $e;
121 121
             }
122 122
             return false;
@@ -134,7 +134,7 @@  discard block
 block discarded – undo
134 134
         //Check, if we don't have existing value for the session
135 135
         $currentValue = $this->curl->performGetRequest('/kv/'.$this->kvPrefix.$this->sessionId);
136 136
         if (!empty($currentValue['Value'])) {
137
-            return (int)base64_decode($currentValue['Value']);
137
+            return (int) base64_decode($currentValue['Value']);
138 138
         }
139 139
         //Lock main key to block concurrent checks
140 140
         $this->lockKey();
@@ -149,7 +149,7 @@  discard block
 block discarded – undo
149 149
         }
150 150
         //Release the lock on the main key and return machine ID.
151 151
         $this->releaseKey();
152
-        return (int)$machineId;
152
+        return (int) $machineId;
153 153
     }
154 154
     
155 155
     /**
@@ -198,12 +198,12 @@  discard block
 block discarded – undo
198 198
 
199 199
     private function createSession()
200 200
     {
201
-        $url ='/session/create';
201
+        $url = '/session/create';
202 202
         //We create new session with given TTL and with lock delay equal to half of TTL.
203 203
         $payload = array(
204 204
             'TTL' => $this->sessionTTL.'s',
205 205
             "Behavior" => "delete",
206
-            'LockDelay' => floor($this->sessionTTL/2).'s',
206
+            'LockDelay' => floor($this->sessionTTL / 2).'s',
207 207
         );
208 208
         $returnData = $this->curl->performPutRequest($url, json_encode($payload));
209 209
         if (empty($returnData['ID'])) {
Please login to merge, or discard this patch.