InPlacePagerPersister::insert() - Code Metrics - FriendsOfSymfony/FOSElasticaBundle - Measure and Improve Code Quality continuously with Scrutinizer

InPlacePagerPersister::insert() A
last analyzed 2021-03-12 13:55 UTC

↳ Parent: InPlacePagerPersister

Complexity

Conditions	3
Paths	8

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	21
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	32
ccs	21
cts	21
cp	1
rs	9.408
c	0
b	0
f	0
cc	3
nc	8
nop	2
crap	3

<?php

/*
 * This file is part of the FOSElasticaBundle package.
 *
 * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

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 = [])
    {
        $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 = []): 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		/*
4		* This file is part of the FOSElasticaBundle package.
5		*
6		* (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
7		*
8		* For the full copyright and license information, please view the LICENSE
9		* file that was distributed with this source code.
10		*/
11
12		namespace FOS\ElasticaBundle\Persister;
13
14		use FOS\ElasticaBundle\Persister\Event\OnExceptionEvent;
15		use FOS\ElasticaBundle\Persister\Event\PostInsertObjectsEvent;
16		use FOS\ElasticaBundle\Persister\Event\PostPersistEvent;
17		use FOS\ElasticaBundle\Persister\Event\PreFetchObjectsEvent;
18		use FOS\ElasticaBundle\Persister\Event\PreInsertObjectsEvent;
19		use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
20		use FOS\ElasticaBundle\Provider\PagerInterface;
21		use Symfony\Component\EventDispatcher\EventDispatcherInterface;
22
23		final class InPlacePagerPersister implements PagerPersisterInterface
24		{
25		public const NAME = 'in_place';
26
27		/**
28		* @var PersisterRegistry
29		*/
30		private $registry;
31
32		/**
33		* @var EventDispatcherInterface
34		*/
35		private $dispatcher;
36
37	12	public function __construct(PersisterRegistry $registry, EventDispatcherInterface $dispatcher)
38		{
39	12	$this->registry = $registry;
40	12	$this->dispatcher = $dispatcher;
41	12	}
42
43		/**
44		* {@inheritdoc}
45		*/
46	11	public function insert(PagerInterface $pager, array $options = [])
47		{
48	11	$pager->setMaxPerPage(empty($options['max_per_page']) ? 100 : $options['max_per_page']);
49
50	11	$options = \array_replace([
51	11	'max_per_page' => $pager->getMaxPerPage(),
52	11	'first_page' => $pager->getCurrentPage(),
53	11	'last_page' => $pager->getNbPages(),
54	11	], $options);
55
56	11	$pager->setCurrentPage($options['first_page']);
57
58	11	$objectPersister = $this->registry->getPersister($options['indexName']);
59
60		try {
61	11	$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...
62	11	$pager = $event->getPager();
63	11	$options = $event->getOptions();
64
65	11	$lastPage = \min($options['last_page'], $pager->getNbPages());
66	11	$page = $pager->getCurrentPage();
67		do {
68	11	$pager->setCurrentPage($page);
69
70	11	$this->insertPage($page, $pager, $objectPersister, $options);
71
72	10	++$page;
73	10	} while ($page <= $lastPage);
74	10	} finally {
75	11	$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...
76		}
77	10	}
78
79		/**
80		* @throws \Exception
81		*/
82	11	private function insertPage(int $page, PagerInterface $pager, ObjectPersisterInterface $objectPersister, array $options = []): void
83		{
84	11	$pager->setCurrentPage($page);
85
86	11	$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...
87	11	$pager = $event->getPager();
88	11	$options = $event->getOptions();
89
90	11	$objects = $pager->getCurrentPageResults();
91
92	11	if ($objects instanceof \Traversable) {
93		$objects = \iterator_to_array($objects);
94		}
95
96	11	$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...
97	11	$pager = $event->getPager();
98	11	$options = $event->getOptions();
99	11	$objects = $event->getObjects();
100
101		try {
102	11	if (!empty($objects)) {
103	10	$objectPersister->insertMany($objects);
104		}
105
106	9	$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...
107	2	} catch (\Exception $e) {
108	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...
109
110	2	if ($event->isIgnored()) {
111	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...
112		} else {
113	1	$e = $event->getException();
114
115	1	throw $e;
116		}
117		}
118	10	}
119		}
120

FriendsOfSymfony / FOSElasticaBundle

InPlacePagerPersister::insert() A last analyzed 2021-03-12 13:55 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

InPlacePagerPersister::insert() A
last analyzed 2021-03-12 13:55 UTC