25
25
*/
26
26
class ElasticSearchRepository implements Repository
27
27
{
28
+ /** @var Client */
28
29
private $ client ;
30
+
31
+ /** @var Serializer */
29
32
private $ serializer ;
33
+
34
+ /** @var string */
30
35
private $ index ;
36
+
37
+ /** @var string */
31
38
private $ class ;
39
+
40
+ /** @var string[] */
32
41
private $ notAnalyzedFields ;
33
42
34
43
public function __construct (
@@ -121,7 +130,7 @@ public function remove($id): void
121
130
}
122
131
}
123
132
124
- private function searchAndDeserializeHits (array $ query )
133
+ private function searchAndDeserializeHits (array $ query ): array
125
134
{
126
135
try {
127
136
$ result = $ this ->client ->search ($ query );
@@ -153,7 +162,7 @@ protected function search(array $query, array $facets = [], int $size = 500): ar
153
162
}
154
163
}
155
164
156
- protected function query (array $ query )
165
+ protected function query (array $ query ): array
157
166
{
158
167
return $ this ->searchAndDeserializeHits (
159
168
[
@@ -183,7 +192,7 @@ private function buildFindAllQuery(): array
183
192
];
184
193
}
185
194
186
- private function deserializeHit (array $ hit )
195
+ private function deserializeHit (array $ hit ): Identifiable
187
196
{
188
197
return $ this ->serializer ->deserialize (
189
198
[
@@ -193,12 +202,12 @@ private function deserializeHit(array $hit)
193
202
);
194
203
}
195
204
196
- private function deserializeHits (array $ hits )
205
+ private function deserializeHits (array $ hits ): array
197
206
{
198
207
return array_map ([$ this , 'deserializeHit ' ], $ hits );
199
208
}
200
209
201
- private function buildFilter (array $ filter )
210
+ private function buildFilter (array $ filter ): array
202
211
{
203
212
$ retval = [];
204
213
@@ -247,8 +256,6 @@ public function createIndex(): bool
247
256
248
257
/**
249
258
* Deletes the index for this repository's ReadModel.
250
- *
251
- * @return True, if the index was successfully deleted
252
259
*/
253
260
public function deleteIndex (): bool
254
261
{
0 commit comments