AbstractProvider::getMemoryUsage() - Code Metrics - Inspection of "Move provider options always used to the base Abst..." - FriendsOfSymfony/FOSElasticaBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — 3.1.x (#1038)

by Karel

created 2016-03-02 11:10 UTC

AbstractProvider::getMemoryUsage() A

↳ Parent: AbstractProvider

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Metric	Value
dl	0
loc	7
ccs	2
cts	2
cp	1
rs	9.4285
cc	1
eloc	4
nc	1
nop	0
crap	1

<?php

namespace FOS\ElasticaBundle\Provider;

use FOS\ElasticaBundle\Persister\ObjectPersisterInterface;
use Symfony\Component\OptionsResolver\OptionsResolver;

/**
 * AbstractProvider.
 */
abstract class AbstractProvider implements ProviderInterface
{
    /**
     * @var array
     */
    protected $baseOptions;

    /**
     * @var string
     */
    protected $objectClass;

    /**
     * @var ObjectPersisterInterface
     */
    protected $objectPersister;

    /**
     * @var OptionsResolver
     */
    protected $resolver;

    /**
     * @var IndexableInterface
     */
    private $indexable;

    /**
     * Constructor.
     *
     * @param ObjectPersisterInterface $objectPersister
     * @param IndexableInterface       $indexable
     * @param string                   $objectClass
     * @param array                    $baseOptions
     */
    public function __construct(
        ObjectPersisterInterface $objectPersister,
        IndexableInterface $indexable,
        $objectClass,
        array $baseOptions = array()
    ) {
        $this->baseOptions = $baseOptions;
        $this->indexable = $indexable;
        $this->objectClass = $objectClass;
        $this->objectPersister = $objectPersister;
        $this->resolver = new OptionsResolver();
        $this->configureOptions();
    }

    /**
     * {@inheritDoc}
     */
    public function populate(\Closure $loggerClosure = null, array $options = array())
    {
        $options = $this->resolveOptions($options);

        $logger = !$options['debug_logging'] ?
            $this->disableLogging() :
            null;

        $this->doPopulate($options, $loggerClosure);

        if (null !== $logger) {
            $this->enableLogging($logger);
        }
    }

    /**
     * Disables logging and returns the logger that was previously set.
     *
     * @return mixed
     */
    abstract protected function disableLogging();

    /**
     * Perform actual population.
     *
     * @param array $options
     * @param \Closure $loggerClosure
     */
    abstract protected function doPopulate($options, \Closure $loggerClosure = null);

    /**
     * Reenables the logger with the previously returned logger from disableLogging();.
     *
     * @param mixed $logger
     *
     * @return mixed
     */
    abstract protected function enableLogging($logger);

    /**
     * Configures the option resolver. Some of these options can be ignored if
     * implementing this class if they do not have any behaviour for a specific provider.
     */
    protected function configureOptions()
    {
        $this->resolver->setDefaults(array(
            'batch_size' => 100,
            'clear_object_manager' => true,
            'debug_logging' => false,
            'ignore_errors' => false,
            'offset' => 0,
            'query_builder_method' => 'createQueryBuilder',
            'skip_indexable_check' => false,
            'sleep' => 0
        ));
        $this->resolver->setRequired(array(
            'indexName',
            'typeName',
        ));
        $this->resolver->setAllowedTypes(array(
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            'batch_size' => 'int',
            'clear_object_manager' => 'bool',
            'debug_logging' => 'bool',
            'ignore_errors' => 'bool',
            'indexName' => 'string',
            'typeName' => 'string',
            'offset' => 'int',
            'query_builder_method' => 'string',
            'skip_indexable_check' => 'bool',
            'sleep' => 'int'
        ));
    }

    /**
     * Filters objects away if they are not indexable.
     *
     * @param array $options
     * @param array $objects
     * @return array
     */
    protected function filterObjects(array $options, array $objects)
    {
        if ($options['skip_indexable_check']) {
            return $objects;
        }

        $index = $options['indexName'];
        $type = $options['typeName'];

        $return = array();
        foreach ($objects as $object) {
            if (!$this->indexable->isObjectIndexable($index, $type, $object)) {
                continue;
            }

            $return[] = $object;
        }

        return $return;
    }

    /**
     * Checks if a given object should be indexed or not.
     *
     * @deprecated To be removed in 4.0
     *
     * @param object $object
     *
     * @return bool
     */
    protected function isObjectIndexable($object)
    {
        return $this->indexable->isObjectIndexable(
            $this->baseOptions['indexName'],
            $this->baseOptions['typeName'],
            $object
        );
    }

    /**
     * Get string with RAM usage information (current and peak).
     *
     * @deprecated To be removed in 4.0
     *
     * @return string
     */
    protected function getMemoryUsage()
    {
        $memory = round(memory_get_usage() / (1024 * 1024)); // to get usage in Mo
        $memoryMax = round(memory_get_peak_usage() / (1024 * 1024)); // to get max usage in Mo

        return sprintf('(RAM : current=%uMo peak=%uMo)', $memory, $memoryMax);
    }

    /**
     * Merges the base options provided by the class with options passed to the populate
     * method and runs them through the resolver.
     *
     * @param array $options
     *
     * @return array
     */
    protected function resolveOptions(array $options)
    {
        return $this->resolver->resolve(array_merge($this->baseOptions, $options));
    }
}


1		<?php
2
3		namespace FOS\ElasticaBundle\Provider;
4
5		use FOS\ElasticaBundle\Persister\ObjectPersisterInterface;
6		use Symfony\Component\OptionsResolver\OptionsResolver;
7
8		/**
9		* AbstractProvider.
10		*/
11		abstract class AbstractProvider implements ProviderInterface
12		{
13		/**
14		* @var array
15		*/
16		protected $baseOptions;
17
18		/**
19		* @var string
20		*/
21		protected $objectClass;
22
23		/**
24		* @var ObjectPersisterInterface
25		*/
26		protected $objectPersister;
27
28		/**
29		* @var OptionsResolver
30		*/
31		protected $resolver;
32
33		/**
34		* @var IndexableInterface
35		*/
36		private $indexable;
37
38		/**
39		* Constructor.
40		*
41		* @param ObjectPersisterInterface $objectPersister
42		* @param IndexableInterface $indexable
43		* @param string $objectClass
44		* @param array $baseOptions
45		*/
46	9	public function __construct(
47		ObjectPersisterInterface $objectPersister,
48		IndexableInterface $indexable,
49		$objectClass,
50		array $baseOptions = array()
51		) {
52	9	$this->baseOptions = $baseOptions;
53	9	$this->indexable = $indexable;
54	9	$this->objectClass = $objectClass;
55	9	$this->objectPersister = $objectPersister;
56	9	$this->resolver = new OptionsResolver();
57	9	$this->configureOptions();
58	9	}
59
60		/**
61		* {@inheritDoc}
62		*/
63	9	public function populate(\Closure $loggerClosure = null, array $options = array())
64		{
65	9	$options = $this->resolveOptions($options);
66
67	9	$logger = !$options['debug_logging'] ?
68	9	$this->disableLogging() :
69	9	null;
70
71	9	$this->doPopulate($options, $loggerClosure);
72
73	8	if (null !== $logger) {
74		$this->enableLogging($logger);
75		}
76	8	}
77
78		/**
79		* Disables logging and returns the logger that was previously set.
80		*
81		* @return mixed
82		*/
83		abstract protected function disableLogging();
84
85		/**
86		* Perform actual population.
87		*
88		* @param array $options
89		* @param \Closure $loggerClosure
90		*/
91		abstract protected function doPopulate($options, \Closure $loggerClosure = null);
92
93		/**
94		* Reenables the logger with the previously returned logger from disableLogging();.
95		*
96		* @param mixed $logger
97		*
98		* @return mixed
99		*/
100		abstract protected function enableLogging($logger);
101
102		/**
103		* Configures the option resolver. Some of these options can be ignored if
104		* implementing this class if they do not have any behaviour for a specific provider.
105	9	*/
106		protected function configureOptions()
107	9	{
108	9	$this->resolver->setDefaults(array(
109	9	'batch_size' => 100,
110	9	'clear_object_manager' => true,
111	9	'debug_logging' => false,
112		'ignore_errors' => false,
113	9	'offset' => 0,
114		'query_builder_method' => 'createQueryBuilder',
115	9	'skip_indexable_check' => false,
116	9	'sleep' => 0
117	9	));
118	9	$this->resolver->setRequired(array(
119	9	'indexName',
120		'typeName',
121		));
122		$this->resolver->setAllowedTypes(array(
		0 ignored issues – show Documentation introduced 2016-03-02 11:35 UTC by Report Bug Copy Issue Report `array('batch_size' => 'i...ool', 'sleep' => 'int')` is of type `array<string,string,{"ba...ing","sleep":"string"}>`, but the function expects a `string`. 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...
123		'batch_size' => 'int',
124		'clear_object_manager' => 'bool',
125		'debug_logging' => 'bool',
126		'ignore_errors' => 'bool',
127		'indexName' => 'string',
128		'typeName' => 'string',
129	9	'offset' => 'int',
130		'query_builder_method' => 'string',
131	9	'skip_indexable_check' => 'bool',
132		'sleep' => 'int'
133		));
134		}
135	9
136	9	/**
137		* Filters objects away if they are not indexable.
138	9	*
139	9	* @param array $options
140	9	* @param array $objects
141	2	* @return array
142		*/
143		protected function filterObjects(array $options, array $objects)
144	8	{
145	9	if ($options['skip_indexable_check']) {
146		return $objects;
147	9	}
148
149		$index = $options['indexName'];
150		$type = $options['typeName'];
151
152		$return = array();
153		foreach ($objects as $object) {
154		if (!$this->indexable->isObjectIndexable($index, $type, $object)) {
155		continue;
156		}
157
158		$return[] = $object;
159		}
160
161		return $return;
162		}
163
164		/**
165		* Checks if a given object should be indexed or not.
166		*
167		* @deprecated To be removed in 4.0
168		*
169		* @param object $object
170		*
171		* @return bool
172		*/
173		protected function isObjectIndexable($object)
174		{
175		return $this->indexable->isObjectIndexable(
176		$this->baseOptions['indexName'],
177		$this->baseOptions['typeName'],
178		$object
179		);
180		}
181
182		/**
183		* Get string with RAM usage information (current and peak).
184		*
185		* @deprecated To be removed in 4.0
186		*
187		* @return string
188		*/
189		protected function getMemoryUsage()
190		{
191	9	$memory = round(memory_get_usage() / (1024 * 1024)); // to get usage in Mo
192		$memoryMax = round(memory_get_peak_usage() / (1024 * 1024)); // to get max usage in Mo
193	9
194		return sprintf('(RAM : current=%uMo peak=%uMo)', $memory, $memoryMax);
195		}
196
197		/**
198		* Merges the base options provided by the class with options passed to the populate
199		* method and runs them through the resolver.
200		*
201		* @param array $options
202		*
203		* @return array
204		*/
205		protected function resolveOptions(array $options)
206		{
207		return $this->resolver->resolve(array_merge($this->baseOptions, $options));
208		}
209		}
210

FriendsOfSymfony / FOSElasticaBundle

Pull Request — 3.1.x (#1038)

AbstractProvider::getMemoryUsage() A

Complexity

Size

Duplication

Code Coverage

Duplication Side-by-Side

Filter issues like