@@ -139,7 +139,7 @@ discard block |
||
139 | 139 | |
140 | 140 | protected function run($argument) { |
141 | 141 | $target = $argument['url']; |
142 | - $created = isset($argument['created']) ? (int)$argument['created'] : $this->time->getTime(); |
|
142 | + $created = isset($argument['created']) ? (int) $argument['created'] : $this->time->getTime(); |
|
143 | 143 | $currentTime = $this->time->getTime(); |
144 | 144 | $source = $this->urlGenerator->getAbsoluteURL('/'); |
145 | 145 | $source = rtrim($source, '/'); |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | $deadline = $currentTime - $this->maxLifespan; |
150 | 150 | if ($created < $deadline) { |
151 | 151 | $this->retainJob = false; |
152 | - $this->trustedServers->setServerStatus($target,TrustedServers::STATUS_FAILURE); |
|
152 | + $this->trustedServers->setServerStatus($target, TrustedServers::STATUS_FAILURE); |
|
153 | 153 | return; |
154 | 154 | } |
155 | 155 | |
@@ -157,7 +157,7 @@ discard block |
||
157 | 157 | $endPoint = isset($endPoints['shared-secret']) ? $endPoints['shared-secret'] : $this->defaultEndPoint; |
158 | 158 | |
159 | 159 | // make sure that we have a well formatted url |
160 | - $url = rtrim($target, '/') . '/' . trim($endPoint, '/'); |
|
160 | + $url = rtrim($target, '/').'/'.trim($endPoint, '/'); |
|
161 | 161 | |
162 | 162 | $result = null; |
163 | 163 | try { |
@@ -179,14 +179,14 @@ discard block |
||
179 | 179 | } catch (ClientException $e) { |
180 | 180 | $status = $e->getCode(); |
181 | 181 | if ($status === Http::STATUS_FORBIDDEN) { |
182 | - $this->logger->info($target . ' refused to exchange a shared secret with you.', ['app' => 'federation']); |
|
182 | + $this->logger->info($target.' refused to exchange a shared secret with you.', ['app' => 'federation']); |
|
183 | 183 | } else { |
184 | - $this->logger->info($target . ' responded with a ' . $status . ' containing: ' . $e->getMessage(), ['app' => 'federation']); |
|
184 | + $this->logger->info($target.' responded with a '.$status.' containing: '.$e->getMessage(), ['app' => 'federation']); |
|
185 | 185 | } |
186 | 186 | } catch (RequestException $e) { |
187 | 187 | $status = -1; // There is no status code if we could not connect |
188 | 188 | $this->logger->logException($e, [ |
189 | - 'message' => 'Could not connect to ' . $target, |
|
189 | + 'message' => 'Could not connect to '.$target, |
|
190 | 190 | 'level' => ILogger::INFO, |
191 | 191 | 'app' => 'federation', |
192 | 192 | ]); |
@@ -213,7 +213,7 @@ discard block |
||
213 | 213 | ); |
214 | 214 | } else { |
215 | 215 | $this->logger->error( |
216 | - 'remote server "' . $target . '"" does not return a valid shared secret. Received data: ' . $body, |
|
216 | + 'remote server "'.$target.'"" does not return a valid shared secret. Received data: '.$body, |
|
217 | 217 | ['app' => 'federation'] |
218 | 218 | ); |
219 | 219 | $this->trustedServers->setServerStatus($target, TrustedServers::STATUS_FAILURE); |
@@ -228,7 +228,7 @@ discard block |
||
228 | 228 | */ |
229 | 229 | protected function reAddJob(array $argument) { |
230 | 230 | $url = $argument['url']; |
231 | - $created = isset($argument['created']) ? (int)$argument['created'] : $this->time->getTime(); |
|
231 | + $created = isset($argument['created']) ? (int) $argument['created'] : $this->time->getTime(); |
|
232 | 232 | $token = $argument['token']; |
233 | 233 | $this->jobList->add( |
234 | 234 | GetSharedSecret::class, |
@@ -138,7 +138,7 @@ discard block |
||
138 | 138 | |
139 | 139 | protected function run($argument) { |
140 | 140 | $target = $argument['url']; |
141 | - $created = isset($argument['created']) ? (int)$argument['created'] : $this->time->getTime(); |
|
141 | + $created = isset($argument['created']) ? (int) $argument['created'] : $this->time->getTime(); |
|
142 | 142 | $currentTime = $this->time->getTime(); |
143 | 143 | $source = $this->urlGenerator->getAbsoluteURL('/'); |
144 | 144 | $source = rtrim($source, '/'); |
@@ -156,7 +156,7 @@ discard block |
||
156 | 156 | $endPoint = isset($endPoints['shared-secret']) ? $endPoints['shared-secret'] : $this->defaultEndPoint; |
157 | 157 | |
158 | 158 | // make sure that we have a well formated url |
159 | - $url = rtrim($target, '/') . '/' . trim($endPoint, '/'); |
|
159 | + $url = rtrim($target, '/').'/'.trim($endPoint, '/'); |
|
160 | 160 | |
161 | 161 | try { |
162 | 162 | $result = $this->httpClient->post( |
@@ -176,13 +176,13 @@ discard block |
||
176 | 176 | } catch (ClientException $e) { |
177 | 177 | $status = $e->getCode(); |
178 | 178 | if ($status === Http::STATUS_FORBIDDEN) { |
179 | - $this->logger->info($target . ' refused to ask for a shared secret.', ['app' => 'federation']); |
|
179 | + $this->logger->info($target.' refused to ask for a shared secret.', ['app' => 'federation']); |
|
180 | 180 | } else { |
181 | - $this->logger->info($target . ' responded with a ' . $status . ' containing: ' . $e->getMessage(), ['app' => 'federation']); |
|
181 | + $this->logger->info($target.' responded with a '.$status.' containing: '.$e->getMessage(), ['app' => 'federation']); |
|
182 | 182 | } |
183 | 183 | } catch (RequestException $e) { |
184 | 184 | $status = -1; // There is no status code if we could not connect |
185 | - $this->logger->info('Could not connect to ' . $target, ['app' => 'federation']); |
|
185 | + $this->logger->info('Could not connect to '.$target, ['app' => 'federation']); |
|
186 | 186 | } catch (\Throwable $e) { |
187 | 187 | $status = Http::STATUS_INTERNAL_SERVER_ERROR; |
188 | 188 | $this->logger->logException($e, ['app' => 'federation']); |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | */ |
205 | 205 | protected function reAddJob(array $argument) { |
206 | 206 | $url = $argument['url']; |
207 | - $created = isset($argument['created']) ? (int)$argument['created'] : $this->time->getTime(); |
|
207 | + $created = isset($argument['created']) ? (int) $argument['created'] : $this->time->getTime(); |
|
208 | 208 | $token = $argument['token']; |
209 | 209 | |
210 | 210 | $this->jobList->add( |