Index::isAliased() - Code Metrics - NimbleCo/NimbleElasticBundle - Measure and Improve Code Quality continuously with Scrutinizer

Index::isAliased() A
last analyzed 2016-10-17 09:31 UTC

↳ Parent: Index

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	1
eloc	2
nc	1
nop	0

<?php

namespace Nimble\ElasticBundle\Index;

use Elasticsearch\Client;
use Elasticsearch\Common\Exceptions\Missing404Exception;
use Nimble\ElasticBundle\Document;
use Nimble\ElasticBundle\Exception\TypeNotFoundException;
use Nimble\ElasticBundle\SearchResults;
use Nimble\ElasticBundle\Type\Type;

class Index
{
    /**
     * The actual index name used for querying elasticsearch.
     *
     * @var string
     */
    private $name;

    /**
     * @var Client
     */
    private $client;

    /**
     * @var array
     */
    private $settings;

    /**
     * @var Type[]
     */
    private $types = [];

    /**
     * Internal index id.
     * Used for naming services and internal identification.
     *
     * @var string
     */
    private $id;

    /**
     * @param string $id Internal index name.
     * @param string $name
     * @param Client $client
     * @param array $settings
     * @param array $types
     */
    public function __construct($id, $name = null, Client $client, array $settings, array $types)
    {
        $this->id = $id;
        $this->name = null === $name ? $id : $name;
        $this->client = $client;
        $this->settings = $settings;

        $this->buildTypes($types);
    }

    /**
     * @param array $types
     */
    protected function buildTypes(array $types)
    {
        foreach ($types as $typeName => $typeData) {

            $mappings = null;

            if (isset($typeData['mappings'])) {
                $mappings = ['properties' => $typeData['mappings']];
            }

            $this->types[$typeName] = new Type($typeName, $this, $mappings);
        }
    }

    /**
     * @return Client
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * @return string
     */
    public function getName()
    {
        return $this->name;
    }

    /**
     * @return string
     */
    public function getId()
    {
        return $this->id;
    }

    /**
     * @return bool
     */
    public function isAliased()
    {
        return $this->id !== $this->name;
    }

    /**
     * Checks if the index exists in ES.
     *
     * @return bool
     */
    public function exists()
    {
        return $this->client->indices()->exists(['index' => $this->name]);
    }

    /**
     * Deletes the index.
     */
    public function delete()
    {
        $this->client->indices()->delete(['index' => $this->name]);
    }

    /**
     * Resets the index.
     */
    public function reset()
    {
        if ($this->exists()) {
            $this->delete();
        }

        $this->create();
    }

    /**
     * Creates the index in ES.
     */
    public function create()
    {
        $params = [
            'index' => $this->name,
        ];

        $mappings = $this->getMappings();

        if (!empty($mappings)) {
            $params['body']['mappings'] = $mappings;
        }

        if (!empty($this->settings)) {
            $params['body']['settings'] = $this->settings;
        }

        $this->client->indices()->create($params);
    }

    /**
     * @return array
     */
    public function getMappings()
    {
        $mappings = [];

        foreach ($this->types as $type) {
            if (!empty($type->getMappings())) {
                $mappings[$type->getName()] = $type->getMappings();
            }
        }

        return $mappings;
    }

    /**
     * @param string $name
     * @return bool
     */
    public function hasType($name)
    {
        return isset($this->types[$name]);
    }

    /**
     * @param string $name
     * @return Type
     */
    public function getType($name)
    {
        if (!$this->hasType($name)) {
            throw new TypeNotFoundException($name, $this->name);
        }

        return $this->types[$name];
    }

    /**
     * @return Type[]
     */
    public function getTypes()
    {
        return $this->types;
    }

    /**
     * @param string $type
     * @param Document $document
     */
    public function putDocument($type, Document $document)
    {
        $data = [
            'index' => $this->name,
            'type' => $type,
            'body' => $document->getData(),
        ];

        if (null !== $document->getId()) {
            $data['id'] = $document->getId();
        }

        $this->client->index($data);
    }

    /**
     * @param string $type
     * @param string|int $id
     * @return bool Returns false if document didn't exist.
     */
    public function deleteDocument($type, $id)
    {
        try {
            $this->client->delete([
                'index' => $this->name,
                'type' => $type,
                'id' => $id,
            ]);
        } catch (Missing404Exception $exception) {
            /* Do nothing, just ignore not synched. */
            return false;
        }

        return true;
    }

    /**
     * @param string $type
     * @param array $documents
     */
    public function putDocuments($type, array $documents)
    {
        foreach ($documents as $document) {
            $this->putDocument($type, $document);
        }
    }

    /**
     * @param string $type
     * @param array $ids
     */
    public function deleteDocuments($type, array $ids)
    {
        foreach ($ids as $id) {
            $this->deleteDocument($type, $id);
        }
    }

    /**
     * @param array|string $body
     * @param array $options
     * @param string $type
     * @return array
     */
    protected function buildParams($body, array $options, $type = null)
    {
        $params = array_merge([
            'index' => $this->name,
            'body' => $body,
        ], $options);

        if (null !== $type) {
            $params['type'] = $type;
        }

        return $params;
    }

    /**
     * @param array|string $query Array that will be serialized or raw JSON.
     * @param array $options
     * @param string $type
     * @return SearchResults
     */
    public function search($query, array $options = [], $type = null)
    {
        return new SearchResults($this->client->search(
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            $this->buildParams($query, $options, $type)
        ));
    }

    /**
     * @param array|string $query Array that will be serialized or raw JSON.
     * @param array $options
     * @param string $type
     * @return int|null
     */
    public function count($query, array $options = [], $type = null)
    {
        $data = $this->client->count(
            $this->buildParams($query, $options, $type)
        );

        return isset($data['count']) ? $data['count'] : NULL;
    }

    /**
     * @param array|string $query
     * @param array $options
     * @param string $type
     */
    public function deleteByQuery($query, array $options = [], $type)
    {
        $this->client->deleteByQuery(

            $this->buildParams($query, $options, $type)
        );
    }
}


1			<?php
2
3			namespace Nimble\ElasticBundle\Index;
4
5			use Elasticsearch\Client;
6			use Elasticsearch\Common\Exceptions\Missing404Exception;
7			use Nimble\ElasticBundle\Document;
8			use Nimble\ElasticBundle\Exception\TypeNotFoundException;
9			use Nimble\ElasticBundle\SearchResults;
10			use Nimble\ElasticBundle\Type\Type;
11
12			class Index
13			{
14			/**
15			* The actual index name used for querying elasticsearch.
16			*
17			* @var string
18			*/
19			private $name;
20
21			/**
22			* @var Client
23			*/
24			private $client;
25
26			/**
27			* @var array
28			*/
29			private $settings;
30
31			/**
32			* @var Type[]
33			*/
34			private $types = [];
35
36			/**
37			* Internal index id.
38			* Used for naming services and internal identification.
39			*
40			* @var string
41			*/
42			private $id;
43
44			/**
45			* @param string $id Internal index name.
46			* @param string $name
47			* @param Client $client
48			* @param array $settings
49			* @param array $types
50			*/
51			public function __construct($id, $name = null, Client $client, array $settings, array $types)
52			{
53			$this->id = $id;
54			$this->name = null === $name ? $id : $name;
55			$this->client = $client;
56			$this->settings = $settings;
57
58			$this->buildTypes($types);
59			}
60
61			/**
62			* @param array $types
63			*/
64			protected function buildTypes(array $types)
65			{
66			foreach ($types as $typeName => $typeData) {
67
68			$mappings = null;
69
70			if (isset($typeData['mappings'])) {
71			$mappings = ['properties' => $typeData['mappings']];
72			}
73
74			$this->types[$typeName] = new Type($typeName, $this, $mappings);
75			}
76			}
77
78			/**
79			* @return Client
80			*/
81			public function getClient()
82			{
83			return $this->client;
84			}
85
86			/**
87			* @return string
88			*/
89			public function getName()
90			{
91			return $this->name;
92			}
93
94			/**
95			* @return string
96			*/
97			public function getId()
98			{
99			return $this->id;
100			}
101
102			/**
103			* @return bool
104			*/
105			public function isAliased()
106			{
107			return $this->id !== $this->name;
108			}
109
110			/**
111			* Checks if the index exists in ES.
112			*
113			* @return bool
114			*/
115			public function exists()
116			{
117			return $this->client->indices()->exists(['index' => $this->name]);
118			}
119
120			/**
121			* Deletes the index.
122			*/
123			public function delete()
124			{
125			$this->client->indices()->delete(['index' => $this->name]);
126			}
127
128			/**
129			* Resets the index.
130			*/
131			public function reset()
132			{
133			if ($this->exists()) {
134			$this->delete();
135			}
136
137			$this->create();
138			}
139
140			/**
141			* Creates the index in ES.
142			*/
143			public function create()
144			{
145			$params = [
146			'index' => $this->name,
147			];
148
149			$mappings = $this->getMappings();
150
151			if (!empty($mappings)) {
152			$params['body']['mappings'] = $mappings;
153			}
154
155			if (!empty($this->settings)) {
156			$params['body']['settings'] = $this->settings;
157			}
158
159			$this->client->indices()->create($params);
160			}
161
162			/**
163			* @return array
164			*/
165			public function getMappings()
166			{
167			$mappings = [];
168
169			foreach ($this->types as $type) {
170			if (!empty($type->getMappings())) {
171			$mappings[$type->getName()] = $type->getMappings();
172			}
173			}
174
175			return $mappings;
176			}
177
178			/**
179			* @param string $name
180			* @return bool
181			*/
182			public function hasType($name)
183			{
184			return isset($this->types[$name]);
185			}
186
187			/**
188			* @param string $name
189			* @return Type
190			*/
191			public function getType($name)
192			{
193			if (!$this->hasType($name)) {
194			throw new TypeNotFoundException($name, $this->name);
195			}
196
197			return $this->types[$name];
198			}
199
200			/**
201			* @return Type[]
202			*/
203			public function getTypes()
204			{
205			return $this->types;
206			}
207
208			/**
209			* @param string $type
210			* @param Document $document
211			*/
212			public function putDocument($type, Document $document)
213			{
214			$data = [
215			'index' => $this->name,
216			'type' => $type,
217			'body' => $document->getData(),
218			];
219
220			if (null !== $document->getId()) {
221			$data['id'] = $document->getId();
222			}
223
224			$this->client->index($data);
225			}
226
227			/**
228			* @param string $type
229			* @param string\|int $id
230			* @return bool Returns false if document didn't exist.
231			*/
232			public function deleteDocument($type, $id)
233			{
234			try {
235			$this->client->delete([
236			'index' => $this->name,
237			'type' => $type,
238			'id' => $id,
239			]);
240			} catch (Missing404Exception $exception) {
241			/* Do nothing, just ignore not synched. */
242			return false;
243			}
244
245			return true;
246			}
247
248			/**
249			* @param string $type
250			* @param array $documents
251			*/
252			public function putDocuments($type, array $documents)
253			{
254			foreach ($documents as $document) {
255			$this->putDocument($type, $document);
256			}
257			}
258
259			/**
260			* @param string $type
261			* @param array $ids
262			*/
263			public function deleteDocuments($type, array $ids)
264			{
265			foreach ($ids as $id) {
266			$this->deleteDocument($type, $id);
267			}
268			}
269
270			/**
271			* @param array\|string $body
272			* @param array $options
273			* @param string $type
274			* @return array
275			*/
276			protected function buildParams($body, array $options, $type = null)
277			{
278			$params = array_merge([
279			'index' => $this->name,
280			'body' => $body,
281			], $options);
282
283			if (null !== $type) {
284			$params['type'] = $type;
285			}
286
287			return $params;
288			}
289
290			/**
291			* @param array\|string $query Array that will be serialized or raw JSON.
292			* @param array $options
293			* @param string $type
294			* @return SearchResults
295			*/
296			public function search($query, array $options = [], $type = null)
297			{
298			return new SearchResults($this->client->search(
			0 ignored issues – show Documentation introduced 2016-01-14 13:56 UTC by Report Bug Copy Issue Report `$this->client->search($t...uery, $options, $type))` is of type `callable`, but the function expects a `array`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
299			$this->buildParams($query, $options, $type)
300			));
301			}
302
303			/**
304			* @param array\|string $query Array that will be serialized or raw JSON.
305			* @param array $options
306			* @param string $type
307			* @return int\|null
308			*/
309			public function count($query, array $options = [], $type = null)
310			{
311			$data = $this->client->count(
312			$this->buildParams($query, $options, $type)
313			);
314
315			return isset($data['count']) ? $data['count'] : NULL;
316			}
317
318			/**
319			* @param array\|string $query
320			* @param array $options
321			* @param string $type
322			*/
323			public function deleteByQuery($query, array $options = [], $type)
324			{
325			$this->client->deleteByQuery(
			0 ignored issues – show Deprecated Code introduced 2016-10-17 09:31 UTC by Report Bug Copy Issue Report The method `Elasticsearch\Client::deleteByQuery()` has been deprecated with message: $params[''] @todo finish the rest of these params ['ignore_unavailable'] = (bool) Whether specified concrete indices should be ignored when unavailable (missing or closed) ['allow_no_indices'] = (bool) Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes `_all` string or when no indices have been specified) ['expand_wildcards'] = (enum) Whether to expand wildcard expression to concrete indices that are open, closed or both. This method has been deprecated. The supplier of the class has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead. Loading history...
326			$this->buildParams($query, $options, $type)
327			);
328			}
329			}
330

NimbleCo / NimbleElasticBundle

GitHub Access Token became invalid

Index::isAliased() A last analyzed 2016-10-17 09:31 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Index::isAliased() A
last analyzed 2016-10-17 09:31 UTC