@@ -108,10 +108,10 @@ |
||
108 | 108 | * @return Tick |
109 | 109 | */ |
110 | 110 | protected function parseTickSelectSql(array $data): Tick { |
111 | - $tick = new Tick($data['source'], (int) $data['id']); |
|
111 | + $tick = new Tick($data['source'], (int)$data['id']); |
|
112 | 112 | $tick->setData(json_decode($data['data'], true)) |
113 | - ->setTick((int) $data['tick']) |
|
114 | - ->setFirstTick((int) $data['first_tick']) |
|
113 | + ->setTick((int)$data['tick']) |
|
114 | + ->setFirstTick((int)$data['first_tick']) |
|
115 | 115 | ->setStatus($data['status']) |
116 | 116 | ->setAction($data['action']); |
117 | 117 |
@@ -191,8 +191,8 @@ discard block |
||
191 | 191 | */ |
192 | 192 | private function limitToDBField(IQueryBuilder &$qb, string $field, string $value) { |
193 | 193 | $expr = $qb->expr(); |
194 | - $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias . '.' : ''; |
|
195 | - $field = $pf . $field; |
|
194 | + $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias.'.' : ''; |
|
195 | + $field = $pf.$field; |
|
196 | 196 | |
197 | 197 | $qb->andWhere($expr->eq($field, $qb->createNamedParameter($value))); |
198 | 198 | } |
@@ -204,8 +204,8 @@ discard block |
||
204 | 204 | */ |
205 | 205 | private function limitToDBFieldInt(IQueryBuilder &$qb, string $field, int $value) { |
206 | 206 | $expr = $qb->expr(); |
207 | - $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias . '.' : ''; |
|
208 | - $field = $pf . $field; |
|
207 | + $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias.'.' : ''; |
|
208 | + $field = $pf.$field; |
|
209 | 209 | |
210 | 210 | $qb->andWhere($expr->eq($field, $qb->createNamedParameter($value))); |
211 | 211 | } |
@@ -218,8 +218,8 @@ discard block |
||
218 | 218 | */ |
219 | 219 | private function limitToDBFieldArray(IQueryBuilder &$qb, string $field, array $values) { |
220 | 220 | $expr = $qb->expr(); |
221 | - $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias . '.' : ''; |
|
222 | - $field = $pf . $field; |
|
221 | + $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias.'.' : ''; |
|
222 | + $field = $pf.$field; |
|
223 | 223 | |
224 | 224 | if (!is_array($values)) { |
225 | 225 | $values = [$values]; |
@@ -239,8 +239,8 @@ discard block |
||
239 | 239 | */ |
240 | 240 | protected function limitToQueuedIndexes(IQueryBuilder &$qb) { |
241 | 241 | $expr = $qb->expr(); |
242 | - $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias . '.' : ''; |
|
243 | - $qb->andWhere($expr->neq($pf . 'status', $qb->createNamedParameter(Index::INDEX_OK))); |
|
242 | + $pf = ($qb->getType() === QueryBuilder::SELECT) ? $this->defaultSelectAlias.'.' : ''; |
|
243 | + $qb->andWhere($expr->neq($pf.'status', $qb->createNamedParameter(Index::INDEX_OK))); |
|
244 | 244 | } |
245 | 245 | |
246 | 246 | } |
@@ -251,7 +251,7 @@ discard block |
||
251 | 251 | } |
252 | 252 | |
253 | 253 | if ($color !== '') { |
254 | - $this->info[$info . 'Colored'] = '<' . $color . '>' . $value . '</' . $color . '>'; |
|
254 | + $this->info[$info.'Colored'] = '<'.$color.'>'.$value.'</'.$color.'>'; |
|
255 | 255 | } |
256 | 256 | } |
257 | 257 | |
@@ -394,7 +394,7 @@ discard block |
||
394 | 394 | return; |
395 | 395 | } |
396 | 396 | |
397 | - $this->setInfo('_memory', round((memory_get_usage() / 1024 / 1024)) . ' MB'); |
|
397 | + $this->setInfo('_memory', round((memory_get_usage() / 1024 / 1024)).' MB'); |
|
398 | 398 | $this->ramUpdate = $tick; |
399 | 399 | } |
400 | 400 | |
@@ -407,7 +407,7 @@ discard block |
||
407 | 407 | */ |
408 | 408 | public function exception(string $reason, bool $stop) { |
409 | 409 | if (!$stop) { |
410 | - $this->output('Exception: ' . $reason); |
|
410 | + $this->output('Exception: '.$reason); |
|
411 | 411 | // TODO: feed an array of exceptions for log; |
412 | 412 | } |
413 | 413 | $this->runningService->exception($this->tickId, $reason, $stop); |
@@ -238,18 +238,18 @@ |
||
238 | 238 | $preAction = $tick->getAction(); |
239 | 239 | |
240 | 240 | if ($preAction !== '') { |
241 | - $preActionTotal = $tick->getInfoFloat($preAction . 'Total', 0); |
|
242 | - $preActionStart = $tick->getInfoFloat($preAction . 'Init', 0); |
|
241 | + $preActionTotal = $tick->getInfoFloat($preAction.'Total', 0); |
|
242 | + $preActionStart = $tick->getInfoFloat($preAction.'Init', 0); |
|
243 | 243 | |
244 | 244 | if ($preActionStart > 0) { |
245 | 245 | |
246 | 246 | $preActionTotal += ($now - $preActionStart); |
247 | - $tick->setInfoFloat($preAction . 'Total', $preActionTotal); |
|
248 | - $tick->unsetInfo($preAction . 'Init'); |
|
247 | + $tick->setInfoFloat($preAction.'Total', $preActionTotal); |
|
248 | + $tick->unsetInfo($preAction.'Init'); |
|
249 | 249 | } |
250 | 250 | } |
251 | 251 | $tick->setAction($action) |
252 | - ->setInfoFloat($action . 'Init', $now); |
|
252 | + ->setInfoFloat($action.'Init', $now); |
|
253 | 253 | } |
254 | 254 | |
255 | 255 |
@@ -172,7 +172,7 @@ discard block |
||
172 | 172 | $platform = \OC::$server->query((string)$selected->getClass()); |
173 | 173 | if (!($platform instanceof IFullTextSearchPlatform)) { |
174 | 174 | throw new PlatformIsNotCompatibleException( |
175 | - $selected->getClass() . ' is not a compatible FullTextSearchPlatform' |
|
175 | + $selected->getClass().' is not a compatible FullTextSearchPlatform' |
|
176 | 176 | ); |
177 | 177 | } |
178 | 178 | |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | } |
205 | 205 | |
206 | 206 | throw new PlatformDoesNotExistException( |
207 | - 'FullTextSearchPlatform ' . $selected . ' is not available' |
|
207 | + 'FullTextSearchPlatform '.$selected.' is not available' |
|
208 | 208 | ); |
209 | 209 | } |
210 | 210 |
@@ -31,9 +31,9 @@ |
||
31 | 31 | namespace OCA\FullTextSearch\AppInfo; |
32 | 32 | |
33 | 33 | |
34 | -$composerDir = __DIR__ . '/../vendor/'; |
|
34 | +$composerDir = __DIR__.'/../vendor/'; |
|
35 | 35 | |
36 | -if (is_dir($composerDir) && file_exists($composerDir . 'autoload.php')) { |
|
37 | - require_once $composerDir . 'autoload.php'; |
|
36 | +if (is_dir($composerDir) && file_exists($composerDir.'autoload.php')) { |
|
37 | + require_once $composerDir.'autoload.php'; |
|
38 | 38 | } |
39 | 39 |
@@ -34,7 +34,7 @@ |
||
34 | 34 | use OCP\AppFramework\QueryException; |
35 | 35 | |
36 | 36 | |
37 | -require_once __DIR__ . '/autoload.php'; |
|
37 | +require_once __DIR__.'/autoload.php'; |
|
38 | 38 | |
39 | 39 | try { |
40 | 40 | $app = new Application(); |
@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | $this->liveCycle(); |
101 | 101 | $this->runner->stop(); |
102 | 102 | } catch (Exception $e) { |
103 | - $this->miscService->log('Exception while cronIndex: ' . get_class($e) . ' - ' . $e->getMessage()); |
|
103 | + $this->miscService->log('Exception while cronIndex: '.get_class($e).' - '.$e->getMessage()); |
|
104 | 104 | $this->runner->exception($e->getMessage(), true); |
105 | 105 | } |
106 | 106 | |
@@ -164,6 +164,6 @@ discard block |
||
164 | 164 | * |
165 | 165 | */ |
166 | 166 | private function setLastErrReset() { |
167 | - $this->configService->setAppValue(ConfigService::CRON_LAST_ERR_RESET, (string) time()); |
|
167 | + $this->configService->setAppValue(ConfigService::CRON_LAST_ERR_RESET, (string)time()); |
|
168 | 168 | } |
169 | 169 | } |
@@ -215,7 +215,7 @@ discard block |
||
215 | 215 | $output->write(' ', true); |
216 | 216 | } |
217 | 217 | |
218 | - $output->write($line . ' ', false); |
|
218 | + $output->write($line.' ', false); |
|
219 | 219 | } |
220 | 220 | |
221 | 221 | |
@@ -276,7 +276,7 @@ discard block |
||
276 | 276 | $testProvider->setIndexOptions(new IndexOptions()); |
277 | 277 | $indexableDocuments = |
278 | 278 | $testProvider->generateIndexableDocuments(TestService::DOCUMENT_USER1, ''); |
279 | - $this->output($output, '(' . sizeof($indexableDocuments) . ' items)', false); |
|
279 | + $this->output($output, '('.sizeof($indexableDocuments).' items)', false); |
|
280 | 280 | $this->outputResult($output, true); |
281 | 281 | } |
282 | 282 | |
@@ -292,12 +292,12 @@ discard block |
||
292 | 292 | $wrapper = $this->platformService->getPlatform(); |
293 | 293 | $testPlatform = $wrapper->getPlatform(); |
294 | 294 | |
295 | - $this->output($output, '(' . $testPlatform->getName() . ')', false); |
|
295 | + $this->output($output, '('.$testPlatform->getName().')', false); |
|
296 | 296 | $this->outputResult($output, true); |
297 | 297 | |
298 | 298 | $this->output($output, 'Testing search platform.'); |
299 | 299 | if (!$testPlatform->testPlatform()) { |
300 | - throw new Exception ('Search platform (' . $testPlatform->getName() . ') down ?'); |
|
300 | + throw new Exception('Search platform ('.$testPlatform->getName().') down ?'); |
|
301 | 301 | } |
302 | 302 | $this->outputResult($output, true); |
303 | 303 | |
@@ -393,13 +393,13 @@ discard block |
||
393 | 393 | ); |
394 | 394 | |
395 | 395 | $this->output( |
396 | - $output, '(size: ' . $indexDocument->getContentSize() . ')', false |
|
396 | + $output, '(size: '.$indexDocument->getContentSize().')', false |
|
397 | 397 | ); |
398 | 398 | $this->outputResult($output, true); |
399 | 399 | } catch (Exception $e) { |
400 | 400 | throw new Exception( |
401 | - "Issue while getting test document '" . TestService::DOCUMENT_TYPE_LICENSE |
|
402 | - . "' from search platform: " . $e->getMessage() |
|
401 | + "Issue while getting test document '".TestService::DOCUMENT_TYPE_LICENSE |
|
402 | + . "' from search platform: ".$e->getMessage() |
|
403 | 403 | ); |
404 | 404 | } |
405 | 405 | |
@@ -569,7 +569,7 @@ discard block |
||
569 | 569 | ) { |
570 | 570 | $this->output( |
571 | 571 | $output, |
572 | - " - '" . $search . "'" . (($moreOutput === '') ? '' : ' - ' . $moreOutput . ' - ') |
|
572 | + " - '".$search."'".(($moreOutput === '') ? '' : ' - '.$moreOutput.' - ') |
|
573 | 573 | ); |
574 | 574 | $request = new SearchRequest(); |
575 | 575 | |
@@ -583,7 +583,7 @@ discard block |
||
583 | 583 | |
584 | 584 | $this->output( |
585 | 585 | $output, |
586 | - '(result: ' . $searchResult->getCount() . ', expected: ' . json_encode($expected) . ')', |
|
586 | + '(result: '.$searchResult->getCount().', expected: '.json_encode($expected).')', |
|
587 | 587 | false |
588 | 588 | ); |
589 | 589 | $this->compareSearchResult($searchResult, $expected); |
@@ -647,12 +647,12 @@ discard block |
||
647 | 647 | private function compareSearchResult(SearchResult $searchResult, array $entries) { |
648 | 648 | $documents = $searchResult->getDocuments(); |
649 | 649 | if (sizeof($documents) !== sizeof($entries)) { |
650 | - throw new \Exception('Unexpected SearchResult: ' . json_encode($searchResult)); |
|
650 | + throw new \Exception('Unexpected SearchResult: '.json_encode($searchResult)); |
|
651 | 651 | } |
652 | 652 | |
653 | 653 | foreach ($documents as $document) { |
654 | 654 | if (!in_array($document->getId(), $entries)) { |
655 | - throw new \Exception('Unexpected Document: ' . json_encode($document)); |
|
655 | + throw new \Exception('Unexpected Document: '.json_encode($document)); |
|
656 | 656 | } |
657 | 657 | } |
658 | 658 | } |
@@ -665,7 +665,7 @@ discard block |
||
665 | 665 | * @throws InterruptException |
666 | 666 | */ |
667 | 667 | private function pause(OutputInterface $output, int $s) { |
668 | - $this->output($output, 'Pausing ' . $s . ' seconds'); |
|
668 | + $this->output($output, 'Pausing '.$s.' seconds'); |
|
669 | 669 | |
670 | 670 | for ($i = 1; $i <= $s; $i++) { |
671 | 671 | if (time_nanosleep(1, 0) !== true) { |