DoctrinePingConnectionMiddleware::handleForManager() - Code Metrics - thomasvargiu/zf-messenger - Measure and Improve Code Quality continuously with Scrutinizer

handleForManager() A
last analyzed 2020-01-21 16:53 UTC

↳ Parent: DoctrinePingConnectionMiddleware

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	3
c	1
b	0
f	0
nc	2
nop	3
dl	0
loc	10
ccs	4
cts	4
cp	1
crap	2
rs	10

<?php

declare(strict_types=1);

namespace TMV\Messenger\Middleware;

use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Middleware\StackInterface;
use Symfony\Component\Messenger\Stamp\ReceivedStamp;

class DoctrinePingConnectionMiddleware extends AbstractDoctrineMiddleware
{
    protected function handleForManager(
        EntityManagerInterface $entityManager,
        Envelope $envelope,
        StackInterface $stack
    ): Envelope {
        if (null !== $envelope->last(ReceivedStamp::class)) {
            $this->pingConnection($entityManager);
        }

        return $stack->next()->handle($envelope, $stack);
    }

    private function pingConnection(EntityManagerInterface $entityManager): void
    {
        $connection = $entityManager->getConnection();

        if (! $connection->ping()) {
            $connection->close();
            $connection->connect();
        }

        if (! $entityManager->isOpen()) {
            $this->managerRegistry->resetManager($this->entityManagerName);
        }
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace TMV\Messenger\Middleware;
6
7		use Doctrine\ORM\EntityManagerInterface;
8		use Symfony\Component\Messenger\Envelope;
9		use Symfony\Component\Messenger\Middleware\StackInterface;
10		use Symfony\Component\Messenger\Stamp\ReceivedStamp;
11
12		class DoctrinePingConnectionMiddleware extends AbstractDoctrineMiddleware
13		{
14	3	protected function handleForManager(
15		EntityManagerInterface $entityManager,
16		Envelope $envelope,
17		StackInterface $stack
18		): Envelope {
19	3	if (null !== $envelope->last(ReceivedStamp::class)) {
20	2	$this->pingConnection($entityManager);
21		}
22
23	3	return $stack->next()->handle($envelope, $stack);
24		}
25
26	2	private function pingConnection(EntityManagerInterface $entityManager): void
27		{
28	2	$connection = $entityManager->getConnection();
29
30	2	if (! $connection->ping()) {
31	2	$connection->close();
32	2	$connection->connect();
33		}
34
35	2	if (! $entityManager->isOpen()) {
36	2	$this->managerRegistry->resetManager($this->entityManagerName);
37		}
38	2	}
39		}
40

thomasvargiu / zf-messenger

handleForManager() A last analyzed 2020-01-21 16:53 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

handleForManager() A
last analyzed 2020-01-21 16:53 UTC