@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | * |
48 | 48 | * @package OCA\Federation\Backgroundjob |
49 | 49 | */ |
50 | -class GetSharedSecret extends Job{ |
|
50 | +class GetSharedSecret extends Job { |
|
51 | 51 | |
52 | 52 | /** @var IClient */ |
53 | 53 | private $httpClient; |
@@ -141,7 +141,7 @@ discard block |
||
141 | 141 | |
142 | 142 | protected function run($argument) { |
143 | 143 | $target = $argument['url']; |
144 | - $created = isset($argument['created']) ? (int)$argument['created'] : time(); |
|
144 | + $created = isset($argument['created']) ? (int) $argument['created'] : time(); |
|
145 | 145 | $currentTime = time(); |
146 | 146 | $source = $this->urlGenerator->getAbsoluteURL('/'); |
147 | 147 | $source = rtrim($source, '/'); |
@@ -151,7 +151,7 @@ discard block |
||
151 | 151 | $deadline = $currentTime - $this->maxLifespan; |
152 | 152 | if ($created < $deadline) { |
153 | 153 | $this->retainJob = false; |
154 | - $this->trustedServers->setServerStatus($target,TrustedServers::STATUS_FAILURE); |
|
154 | + $this->trustedServers->setServerStatus($target, TrustedServers::STATUS_FAILURE); |
|
155 | 155 | return; |
156 | 156 | } |
157 | 157 | |
@@ -159,7 +159,7 @@ discard block |
||
159 | 159 | $endPoint = isset($endPoints['shared-secret']) ? $endPoints['shared-secret'] : $this->defaultEndPoint; |
160 | 160 | |
161 | 161 | // make sure that we have a well formated url |
162 | - $url = rtrim($target, '/') . '/' . trim($endPoint, '/') . $this->format; |
|
162 | + $url = rtrim($target, '/').'/'.trim($endPoint, '/').$this->format; |
|
163 | 163 | |
164 | 164 | $result = null; |
165 | 165 | try { |
@@ -181,9 +181,9 @@ discard block |
||
181 | 181 | } catch (ClientException $e) { |
182 | 182 | $status = $e->getCode(); |
183 | 183 | if ($status === Http::STATUS_FORBIDDEN) { |
184 | - $this->logger->info($target . ' refused to exchange a shared secret with you.', ['app' => 'federation']); |
|
184 | + $this->logger->info($target.' refused to exchange a shared secret with you.', ['app' => 'federation']); |
|
185 | 185 | } else { |
186 | - $this->logger->info($target . ' responded with a ' . $status . ' containing: ' . $e->getMessage(), ['app' => 'federation']); |
|
186 | + $this->logger->info($target.' responded with a '.$status.' containing: '.$e->getMessage(), ['app' => 'federation']); |
|
187 | 187 | } |
188 | 188 | } catch (\Exception $e) { |
189 | 189 | $status = Http::STATUS_INTERNAL_SERVER_ERROR; |
@@ -196,7 +196,7 @@ discard block |
||
196 | 196 | && $status !== Http::STATUS_FORBIDDEN |
197 | 197 | ) { |
198 | 198 | $this->retainJob = true; |
199 | - } else { |
|
199 | + } else { |
|
200 | 200 | // reset token if we received a valid response |
201 | 201 | $this->dbHandler->addToken($target, ''); |
202 | 202 | } |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | ); |
212 | 212 | } else { |
213 | 213 | $this->logger->error( |
214 | - 'remote server "' . $target . '"" does not return a valid shared secret', |
|
214 | + 'remote server "'.$target.'"" does not return a valid shared secret', |
|
215 | 215 | ['app' => 'federation'] |
216 | 216 | ); |
217 | 217 | $this->trustedServers->setServerStatus($target, TrustedServers::STATUS_FAILURE); |
@@ -228,7 +228,7 @@ discard block |
||
228 | 228 | */ |
229 | 229 | protected function reAddJob(IJobList $jobList, array $argument) { |
230 | 230 | $url = $argument['url']; |
231 | - $created = isset($argument['created']) ? (int)$argument['created'] : time(); |
|
231 | + $created = isset($argument['created']) ? (int) $argument['created'] : time(); |
|
232 | 232 | $token = $argument['token']; |
233 | 233 | $this->jobList->add( |
234 | 234 | GetSharedSecret::class, |
@@ -143,7 +143,7 @@ discard block |
||
143 | 143 | protected function run($argument) { |
144 | 144 | |
145 | 145 | $target = $argument['url']; |
146 | - $created = isset($argument['created']) ? (int)$argument['created'] : time(); |
|
146 | + $created = isset($argument['created']) ? (int) $argument['created'] : time(); |
|
147 | 147 | $currentTime = time(); |
148 | 148 | $source = $this->urlGenerator->getAbsoluteURL('/'); |
149 | 149 | $source = rtrim($source, '/'); |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | $endPoint = isset($endPoints['shared-secret']) ? $endPoints['shared-secret'] : $this->defaultEndPoint; |
162 | 162 | |
163 | 163 | // make sure that we have a well formated url |
164 | - $url = rtrim($target, '/') . '/' . trim($endPoint, '/') . $this->format; |
|
164 | + $url = rtrim($target, '/').'/'.trim($endPoint, '/').$this->format; |
|
165 | 165 | |
166 | 166 | try { |
167 | 167 | $result = $this->httpClient->post( |
@@ -181,9 +181,9 @@ discard block |
||
181 | 181 | } catch (ClientException $e) { |
182 | 182 | $status = $e->getCode(); |
183 | 183 | if ($status === Http::STATUS_FORBIDDEN) { |
184 | - $this->logger->info($target . ' refused to ask for a shared secret.', ['app' => 'federation']); |
|
184 | + $this->logger->info($target.' refused to ask for a shared secret.', ['app' => 'federation']); |
|
185 | 185 | } else { |
186 | - $this->logger->info($target . ' responded with a ' . $status . ' containing: ' . $e->getMessage(), ['app' => 'federation']); |
|
186 | + $this->logger->info($target.' responded with a '.$status.' containing: '.$e->getMessage(), ['app' => 'federation']); |
|
187 | 187 | } |
188 | 188 | } catch (\Exception $e) { |
189 | 189 | $status = Http::STATUS_INTERNAL_SERVER_ERROR; |
@@ -214,7 +214,7 @@ discard block |
||
214 | 214 | protected function reAddJob(IJobList $jobList, array $argument) { |
215 | 215 | |
216 | 216 | $url = $argument['url']; |
217 | - $created = isset($argument['created']) ? (int)$argument['created'] : time(); |
|
217 | + $created = isset($argument['created']) ? (int) $argument['created'] : time(); |
|
218 | 218 | $token = $argument['token']; |
219 | 219 | |
220 | 220 | $jobList->add( |
@@ -222,7 +222,7 @@ discard block |
||
222 | 222 | $client = $this->httpClientService->newClient(); |
223 | 223 | try { |
224 | 224 | $result = $client->get( |
225 | - $url . '/status.php', |
|
225 | + $url.'/status.php', |
|
226 | 226 | [ |
227 | 227 | 'timeout' => 3, |
228 | 228 | 'connect_timeout' => 3, |
@@ -233,7 +233,7 @@ discard block |
||
233 | 233 | |
234 | 234 | } |
235 | 235 | } catch (\Exception $e) { |
236 | - $this->logger->debug('No Nextcloud server: ' . $e->getMessage()); |
|
236 | + $this->logger->debug('No Nextcloud server: '.$e->getMessage()); |
|
237 | 237 | return false; |
238 | 238 | } |
239 | 239 | |
@@ -274,7 +274,7 @@ discard block |
||
274 | 274 | |
275 | 275 | } |
276 | 276 | |
277 | - return 'https://' . $url; |
|
277 | + return 'https://'.$url; |
|
278 | 278 | } |
279 | 279 | |
280 | 280 | protected function getTimestamp() { |