@@ -75,7 +75,7 @@ discard block |
||
| 75 | 75 | 'index' => |
| 76 | 76 | [ |
| 77 | 77 | 'index' => $this->configService->getElasticIndex(), |
| 78 | - 'id' => $document->getProviderId() . ':' . $document->getId(), |
|
| 78 | + 'id' => $document->getProviderId().':'.$document->getId(), |
|
| 79 | 79 | 'type' => 'standard', |
| 80 | 80 | 'body' => $this->generateIndexBody($document) |
| 81 | 81 | ] |
@@ -105,7 +105,7 @@ discard block |
||
| 105 | 105 | 'index' => |
| 106 | 106 | [ |
| 107 | 107 | 'index' => $this->configService->getElasticIndex(), |
| 108 | - 'id' => $document->getProviderId() . ':' . $document->getId(), |
|
| 108 | + 'id' => $document->getProviderId().':'.$document->getId(), |
|
| 109 | 109 | 'type' => 'standard', |
| 110 | 110 | 'body' => ['doc' => $this->generateIndexBody($document)] |
| 111 | 111 | ] |
@@ -133,7 +133,7 @@ discard block |
||
| 133 | 133 | 'index' => |
| 134 | 134 | [ |
| 135 | 135 | 'index' => $this->configService->getElasticIndex(), |
| 136 | - 'id' => $providerId . ':' . $documentId, |
|
| 136 | + 'id' => $providerId.':'.$documentId, |
|
| 137 | 137 | 'type' => 'standard' |
| 138 | 138 | ] |
| 139 | 139 | ]; |
@@ -189,7 +189,7 @@ |
||
| 189 | 189 | |
| 190 | 190 | /** |
| 191 | 191 | * @param ISearchResult $searchResult |
| 192 | - * @param array $result |
|
| 192 | + * @param callable $result |
|
| 193 | 193 | */ |
| 194 | 194 | private function updateSearchResult(ISearchResult $searchResult, array $result) { |
| 195 | 195 | $searchResult->setRawResult(json_encode($result)); |
@@ -85,7 +85,7 @@ discard block |
||
| 85 | 85 | Client $client, ISearchResult $searchResult, IDocumentAccess $access |
| 86 | 86 | ) { |
| 87 | 87 | try { |
| 88 | - $this->miscService->log('New Search Request; SearchResult Model: ' . json_encode($searchResult), 0); |
|
| 88 | + $this->miscService->log('New Search Request; SearchResult Model: '.json_encode($searchResult), 0); |
|
| 89 | 89 | $query = $this->searchMappingService->generateSearchQuery( |
| 90 | 90 | $searchResult->getRequest(), $access, $searchResult->getProvider() |
| 91 | 91 | ->getId() |
@@ -95,25 +95,25 @@ discard block |
||
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | try { |
| 98 | - $this->miscService->log('Searching ES: ' . json_encode($query['params']), 0); |
|
| 98 | + $this->miscService->log('Searching ES: '.json_encode($query['params']), 0); |
|
| 99 | 99 | |
| 100 | 100 | $result = $client->search($query['params']); |
| 101 | 101 | } catch (Exception $e) { |
| 102 | 102 | $this->miscService->log( |
| 103 | - 'debug - request: ' . json_encode($searchResult->getRequest()) . ' - query: ' |
|
| 103 | + 'debug - request: '.json_encode($searchResult->getRequest()).' - query: ' |
|
| 104 | 104 | . json_encode($query) |
| 105 | 105 | ); |
| 106 | 106 | throw $e; |
| 107 | 107 | } |
| 108 | 108 | |
| 109 | - $this->miscService->log('Result from ES: ' . json_encode($result), 0); |
|
| 109 | + $this->miscService->log('Result from ES: '.json_encode($result), 0); |
|
| 110 | 110 | $this->updateSearchResult($searchResult, $result); |
| 111 | 111 | |
| 112 | 112 | foreach ($result['hits']['hits'] as $entry) { |
| 113 | 113 | $searchResult->addDocument($this->parseSearchEntry($entry, $access->getViewerId())); |
| 114 | 114 | } |
| 115 | 115 | |
| 116 | - $this->miscService->log('Filled SearchResult Model: ' . json_encode($searchResult), 0); |
|
| 116 | + $this->miscService->log('Filled SearchResult Model: '.json_encode($searchResult), 0); |
|
| 117 | 117 | } |
| 118 | 118 | |
| 119 | 119 | |
@@ -279,7 +279,7 @@ discard block |
||
| 279 | 279 | |
| 280 | 280 | foreach ($request->getWildcardFields() as $field) { |
| 281 | 281 | if (!$this->fieldIsOutLimit($request, $field)) { |
| 282 | - $queryFields[] = ['wildcard' => [$field => '*' . $content->getWord() . '*']]; |
|
| 282 | + $queryFields[] = ['wildcard' => [$field => '*'.$content->getWord().'*']]; |
|
| 283 | 283 | } |
| 284 | 284 | } |
| 285 | 285 | |
@@ -380,7 +380,7 @@ discard block |
||
| 380 | 380 | return [ |
| 381 | 381 | 'index' => $this->configService->getElasticIndex(), |
| 382 | 382 | 'type' => 'standard', |
| 383 | - 'id' => $providerId . ':' . $documentId |
|
| 383 | + 'id' => $providerId.':'.$documentId |
|
| 384 | 384 | ]; |
| 385 | 385 | } |
| 386 | 386 | |
@@ -393,7 +393,7 @@ discard block |
||
| 393 | 393 | private function getPartsFields(ISearchRequest $request) { |
| 394 | 394 | return array_map( |
| 395 | 395 | function($value) { |
| 396 | - return 'parts.' . $value; |
|
| 396 | + return 'parts.'.$value; |
|
| 397 | 397 | }, $request->getParts() |
| 398 | 398 | ); |
| 399 | 399 | } |
@@ -126,12 +126,12 @@ |
||
| 126 | 126 | $hosts = $this->configService->getElasticHost(); |
| 127 | 127 | foreach ($hosts as $host) { |
| 128 | 128 | $parsedHost = parse_url($host); |
| 129 | - $safeHost = $parsedHost['scheme'] . '://'; |
|
| 129 | + $safeHost = $parsedHost['scheme'].'://'; |
|
| 130 | 130 | if (array_key_exists('user', $parsedHost)) { |
| 131 | - $safeHost .= $parsedHost['user'] . ':' . '********' . '@'; |
|
| 131 | + $safeHost .= $parsedHost['user'].':'.'********'.'@'; |
|
| 132 | 132 | } |
| 133 | 133 | $safeHost .= $parsedHost['host']; |
| 134 | - $safeHost .= ':' . $parsedHost['port']; |
|
| 134 | + $safeHost .= ':'.$parsedHost['port']; |
|
| 135 | 135 | |
| 136 | 136 | $sanitizedHosts[] = $safeHost; |
| 137 | 137 | } |
@@ -30,9 +30,9 @@ |
||
| 30 | 30 | namespace OCA\FullTextSearch_ElasticSearch\Service; |
| 31 | 31 | |
| 32 | 32 | interface IUserStoragesService { |
| 33 | - /** |
|
| 34 | - * Returns an array of strings with all external mountpoints of the current user |
|
| 35 | - * @return array |
|
| 36 | - */ |
|
| 37 | - function getAllStoragesForUser(); |
|
| 33 | + /** |
|
| 34 | + * Returns an array of strings with all external mountpoints of the current user |
|
| 35 | + * @return array |
|
| 36 | + */ |
|
| 37 | + function getAllStoragesForUser(); |
|
| 38 | 38 | } |
| 39 | 39 | \ No newline at end of file |
@@ -36,19 +36,19 @@ discard block |
||
| 36 | 36 | */ |
| 37 | 37 | class UserStoragesService implements IUserStoragesService { |
| 38 | 38 | |
| 39 | - /** @var UserGlobalStoragesService */ |
|
| 40 | - private $userGlobalStoragesService; |
|
| 39 | + /** @var UserGlobalStoragesService */ |
|
| 40 | + private $userGlobalStoragesService; |
|
| 41 | 41 | |
| 42 | - public function __construct(UserGlobalStoragesService $userGlobalStoragesService) { |
|
| 43 | - $this->userGlobalStoragesService = $userGlobalStoragesService; |
|
| 44 | - } |
|
| 42 | + public function __construct(UserGlobalStoragesService $userGlobalStoragesService) { |
|
| 43 | + $this->userGlobalStoragesService = $userGlobalStoragesService; |
|
| 44 | + } |
|
| 45 | 45 | |
| 46 | 46 | /** |
| 47 | - * Returns an array of strings with all external mountpoints of the current user |
|
| 48 | - * @return array |
|
| 49 | - */ |
|
| 50 | - public function getAllStoragesForUser() { |
|
| 51 | - $userStorages = $this->userGlobalStoragesService->getAllStoragesForUser(); |
|
| 47 | + * Returns an array of strings with all external mountpoints of the current user |
|
| 48 | + * @return array |
|
| 49 | + */ |
|
| 50 | + public function getAllStoragesForUser() { |
|
| 51 | + $userStorages = $this->userGlobalStoragesService->getAllStoragesForUser(); |
|
| 52 | 52 | $mountPoints = []; |
| 53 | 53 | foreach($userStorages as $userStorage){ |
| 54 | 54 | /** @var $userStorage OCA\Files_External\Lib\StorageConfig */ |
@@ -62,5 +62,5 @@ discard block |
||
| 62 | 62 | $mountPoints[] = $mountPoint; |
| 63 | 63 | } |
| 64 | 64 | return $mountPoints; |
| 65 | - } |
|
| 65 | + } |
|
| 66 | 66 | } |
| 67 | 67 | \ No newline at end of file |
@@ -50,13 +50,13 @@ |
||
| 50 | 50 | public function getAllStoragesForUser() { |
| 51 | 51 | $userStorages = $this->userGlobalStoragesService->getAllStoragesForUser(); |
| 52 | 52 | $mountPoints = []; |
| 53 | - foreach($userStorages as $userStorage){ |
|
| 53 | + foreach ($userStorages as $userStorage) { |
|
| 54 | 54 | /** @var $userStorage OCA\Files_External\Lib\StorageConfig */ |
| 55 | 55 | $mountPoint = $userStorage->getMountPoint(); |
| 56 | - if (substr($mountPoint, 0, 1) === '/'){ |
|
| 56 | + if (substr($mountPoint, 0, 1) === '/') { |
|
| 57 | 57 | $mountPoint = substr($mountPoint, 1, strlen($mountPoint) - 1); |
| 58 | 58 | } |
| 59 | - if (substr($mountPoint, strlen($mountPoint) - 1, 1) !== '/'){ |
|
| 59 | + if (substr($mountPoint, strlen($mountPoint) - 1, 1) !== '/') { |
|
| 60 | 60 | $mountPoint .= '/'; |
| 61 | 61 | } |
| 62 | 62 | $mountPoints[] = $mountPoint; |
@@ -41,7 +41,7 @@ discard block |
||
| 41 | 41 | use OCP\AppFramework\Bootstrap\IRegistrationContext; |
| 42 | 42 | use Psr\Container\ContainerExceptionInterface; |
| 43 | 43 | |
| 44 | -require_once __DIR__ . '/../../vendor/autoload.php'; |
|
| 44 | +require_once __DIR__.'/../../vendor/autoload.php'; |
|
| 45 | 45 | |
| 46 | 46 | |
| 47 | 47 | /** |
@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | // Make SearchMappingService also work without external storage |
| 72 | 72 | // if app is inactive or not installed. |
| 73 | 73 | $context->registerService(SearchMappingService::class, function($c) { |
| 74 | - try{ |
|
| 74 | + try { |
|
| 75 | 75 | $userStoragesService = $c->query(UserGlobalStoragesService::class); |
| 76 | 76 | return new SearchMappingService( |
| 77 | 77 | $c->query(ConfigService::class), |
@@ -78,8 +78,7 @@ |
||
| 78 | 78 | $c->query(MiscService::class), |
| 79 | 79 | new UserStoragesService($userStoragesService) |
| 80 | 80 | ); |
| 81 | - } |
|
| 82 | - catch (ContainerExceptionInterface $e) { |
|
| 81 | + } catch (ContainerExceptionInterface $e) { |
|
| 83 | 82 | return new SearchMappingService( |
| 84 | 83 | $c->query(ConfigService::class), |
| 85 | 84 | $c->query(MiscService::class) |