@@ -26,9 +26,9 @@ |
||
26 | 26 | |
27 | 27 | namespace OCA\FullTextSearch_ElasticSearch\AppInfo; |
28 | 28 | |
29 | -$composerDir = __DIR__ . '/../vendor/'; |
|
29 | +$composerDir = __DIR__.'/../vendor/'; |
|
30 | 30 | |
31 | -if (is_dir($composerDir) && file_exists($composerDir . 'autoload.php')) { |
|
32 | - require_once $composerDir . 'autoload.php'; |
|
31 | +if (is_dir($composerDir) && file_exists($composerDir.'autoload.php')) { |
|
32 | + require_once $composerDir.'autoload.php'; |
|
33 | 33 | } |
34 | 34 |
@@ -26,6 +26,6 @@ |
||
26 | 26 | |
27 | 27 | namespace OCA\FullTextSearch_ElasticSearch\AppInfo; |
28 | 28 | |
29 | -require_once __DIR__ . '/autoload.php'; |
|
29 | +require_once __DIR__.'/autoload.php'; |
|
30 | 30 | |
31 | 31 | new Application(); |
@@ -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 | } |