InPlacePagerPersister::insertPage() - Code Metrics - Inspection of "Migrate to ruflin/elastica 7.x" - FriendsOfSymfony/FOSElasticaBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#1569)

unknown

created 2020-09-04 14:10 UTC

InPlacePagerPersister::insertPage() A

↳ Parent: InPlacePagerPersister

Complexity

Conditions	5
Paths	16

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	21
CRAP Score	5.0023

Importance

Changes

Metric	Value
dl	0
loc	37
ccs	21
cts	22
cp	0.9545
rs	9.0168
c	0
b	0
f	0
cc	5
nc	16
nop	4
crap	5.0023

<?php

namespace FOS\ElasticaBundle\Persister;

use FOS\ElasticaBundle\Persister\Event\OnExceptionEvent;
use FOS\ElasticaBundle\Persister\Event\PostInsertObjectsEvent;
use FOS\ElasticaBundle\Persister\Event\PostPersistEvent;
use FOS\ElasticaBundle\Persister\Event\PreFetchObjectsEvent;
use FOS\ElasticaBundle\Persister\Event\PreInsertObjectsEvent;
use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
use FOS\ElasticaBundle\Provider\PagerInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

final class InPlacePagerPersister implements PagerPersisterInterface
{
    public const NAME = 'in_place';

    /**
     * @var PersisterRegistry
     */
    private $registry;

    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    public function __construct(PersisterRegistry $registry, EventDispatcherInterface $dispatcher)
    {
        $this->registry = $registry;
        $this->dispatcher = $dispatcher;
    }

    /**
     * {@inheritdoc}
     */
    public function insert(PagerInterface $pager, array $options = array())
    {
        $pager->setMaxPerPage(empty($options['max_per_page']) ? 100 : $options['max_per_page']);

        $options = array_replace([
            'max_per_page' => $pager->getMaxPerPage(),
            'first_page' => $pager->getCurrentPage(),
            'last_page' => $pager->getNbPages(),
        ], $options);

        $pager->setCurrentPage($options['first_page']);

        $objectPersister = $this->registry->getPersister($options['indexName']);

        try {
            $this->dispatcher->dispatch($event = new PrePersistEvent($pager, $objectPersister, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            $pager = $event->getPager();
            $options = $event->getOptions();

            $lastPage = min($options['last_page'], $pager->getNbPages());
            $page = $pager->getCurrentPage();
            do {
                $pager->setCurrentPage($page);

                $this->insertPage($page, $pager, $objectPersister, $options);

                $page++;
            } while ($page <= $lastPage);
        } finally {
            $this->dispatcher->dispatch(new PostPersistEvent($pager, $objectPersister, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }
    }

    /**
     * @throws \Exception
     */
    private function insertPage(int $page, PagerInterface $pager, ObjectPersisterInterface $objectPersister, array $options = array()): void
    {
        $pager->setCurrentPage($page);

        $this->dispatcher->dispatch($event = new PreFetchObjectsEvent($pager, $objectPersister, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        $pager = $event->getPager();
        $options = $event->getOptions();

        $objects = $pager->getCurrentPageResults();

        if ($objects instanceof \Traversable) {
            $objects = iterator_to_array($objects);
        }

        $this->dispatcher->dispatch($event = new PreInsertObjectsEvent($pager, $objectPersister, $objects, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        $pager = $event->getPager();
        $options = $event->getOptions();
        $objects = $event->getObjects();

        try {
            if (!empty($objects)) {
                $objectPersister->insertMany($objects);
            }

            $this->dispatcher->dispatch(new PostInsertObjectsEvent($pager, $objectPersister, $objects, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        } catch (\Exception $e) {
            $this->dispatcher->dispatch($event = new OnExceptionEvent($pager, $objectPersister, $e, $objects, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

            if ($event->isIgnored()) {
                $this->dispatcher->dispatch(new PostInsertObjectsEvent($pager, $objectPersister, $objects, $options));
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
            } else {
                $e = $event->getException();

                throw $e;
            }
        }
    }

}


1		<?php
2
3		namespace FOS\ElasticaBundle\Persister;
4
5		use FOS\ElasticaBundle\Persister\Event\OnExceptionEvent;
6		use FOS\ElasticaBundle\Persister\Event\PostInsertObjectsEvent;
7		use FOS\ElasticaBundle\Persister\Event\PostPersistEvent;
8		use FOS\ElasticaBundle\Persister\Event\PreFetchObjectsEvent;
9		use FOS\ElasticaBundle\Persister\Event\PreInsertObjectsEvent;
10		use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
11		use FOS\ElasticaBundle\Provider\PagerInterface;
12		use Symfony\Component\EventDispatcher\EventDispatcherInterface;
13
14		final class InPlacePagerPersister implements PagerPersisterInterface
15		{
16		public const NAME = 'in_place';
17
18		/**
19		* @var PersisterRegistry
20		*/
21		private $registry;
22
23		/**
24		* @var EventDispatcherInterface
25		*/
26		private $dispatcher;
27
28	11	public function __construct(PersisterRegistry $registry, EventDispatcherInterface $dispatcher)
29		{
30	11	$this->registry = $registry;
31	11	$this->dispatcher = $dispatcher;
32	11	}
33
34		/**
35		* {@inheritdoc}
36		*/
37	10	public function insert(PagerInterface $pager, array $options = array())
38		{
39	10	$pager->setMaxPerPage(empty($options['max_per_page']) ? 100 : $options['max_per_page']);
40
41	10	$options = array_replace([
42	10	'max_per_page' => $pager->getMaxPerPage(),
43	10	'first_page' => $pager->getCurrentPage(),
44	10	'last_page' => $pager->getNbPages(),
45		], $options);
46
47	10	$pager->setCurrentPage($options['first_page']);
48
49	10	$objectPersister = $this->registry->getPersister($options['indexName']);
50
51		try {
52	10	$this->dispatcher->dispatch($event = new PrePersistEvent($pager, $objectPersister, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `$event = new \FOS\Elasti...ectPersister, $options)` is of type `object<FOS\ElasticaBundl...\Event\PrePersistEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
53	10	$pager = $event->getPager();
54	10	$options = $event->getOptions();
55
56	10	$lastPage = min($options['last_page'], $pager->getNbPages());
57	10	$page = $pager->getCurrentPage();
58		do {
59	10	$pager->setCurrentPage($page);
60
61	10	$this->insertPage($page, $pager, $objectPersister, $options);
62
63	9	$page++;
64	9	} while ($page <= $lastPage);
65	9	} finally {
66	10	$this->dispatcher->dispatch(new PostPersistEvent($pager, $objectPersister, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `new \FOS\ElasticaBundle\...ectPersister, $options)` is of type `object<FOS\ElasticaBundl...Event\PostPersistEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
67		}
68	9	}
69
70		/**
71		* @throws \Exception
72		*/
73	10	private function insertPage(int $page, PagerInterface $pager, ObjectPersisterInterface $objectPersister, array $options = array()): void
74		{
75	10	$pager->setCurrentPage($page);
76
77	10	$this->dispatcher->dispatch($event = new PreFetchObjectsEvent($pager, $objectPersister, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `$event = new \FOS\Elasti...ectPersister, $options)` is of type `object<FOS\ElasticaBundl...t\PreFetchObjectsEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
78	10	$pager = $event->getPager();
79	10	$options = $event->getOptions();
80
81	10	$objects = $pager->getCurrentPageResults();
82
83	10	if ($objects instanceof \Traversable) {
84		$objects = iterator_to_array($objects);
85		}
86
87	10	$this->dispatcher->dispatch($event = new PreInsertObjectsEvent($pager, $objectPersister, $objects, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `$event = new \FOS\Elasti...er, $objects, $options)` is of type `object<FOS\ElasticaBundl...\PreInsertObjectsEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
88	10	$pager = $event->getPager();
89	10	$options = $event->getOptions();
90	10	$objects = $event->getObjects();
91
92		try {
93	10	if (!empty($objects)) {
94	10	$objectPersister->insertMany($objects);
95		}
96
97	8	$this->dispatcher->dispatch(new PostInsertObjectsEvent($pager, $objectPersister, $objects, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `new \FOS\ElasticaBundle\...er, $objects, $options)` is of type `object<FOS\ElasticaBundl...PostInsertObjectsEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
98	2	} catch (\Exception $e) {
99	2	$this->dispatcher->dispatch($event = new OnExceptionEvent($pager, $objectPersister, $e, $objects, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `$event = new \FOS\Elasti...$e, $objects, $options)` is of type `object<FOS\ElasticaBundl...Event\OnExceptionEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
100
101	2	if ($event->isIgnored()) {
102	1	$this->dispatcher->dispatch(new PostInsertObjectsEvent($pager, $objectPersister, $objects, $options));
		0 ignored issues – show Documentation introduced 2020-06-24 09:19 UTC by Report Bug Copy Issue Report `new \FOS\ElasticaBundle\...er, $objects, $options)` is of type `object<FOS\ElasticaBundl...PostInsertObjectsEvent>`, but the function expects a `object<Symfony\Contracts\EventDispatcher\object>`. 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...
103		} else {
104	1	$e = $event->getException();
105
106	1	throw $e;
107		}
108		}
109	9	}
110
111		}
112

FriendsOfSymfony / FOSElasticaBundle

Pull Request — master (#1569)

InPlacePagerPersister::insertPage() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like