DoctrinePingConnectionMiddleware::handleForManager() - Code Metrics - Inspection of "new middlewares" - thomasvargiu/laminas-messenger - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 79a79c...9c574d )

by Thomas Mauro

created 2025-01-28 22:51 UTC

handleForManager() A

↳ Parent: DoctrinePingConnectionMiddleware

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	3

Duplication

Lines	0
Ratio	0 %

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
rs	10

<?php

declare(strict_types=1);

namespace TMV\Laminas\Messenger\Bridge\Doctrine\Middleware;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Exception;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Middleware\StackInterface;
use Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp;

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

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

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

        try {
            $this->executeDummySql($connection);
        } catch (Exception) {
            $connection->close();
            // Attempt to reestablish the lazy connection by sending another query.
            $this->executeDummySql($connection);
        }

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

    /**
     * @throws Exception
     */
    private function executeDummySql(Connection $connection): void
    {
        $connection->executeQuery($connection->getDatabasePlatform()->getDummySelectSQL());
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace TMV\Laminas\Messenger\Bridge\Doctrine\Middleware;
6
7			use Doctrine\DBAL\Connection;
8			use Doctrine\DBAL\Exception;
9			use Doctrine\ORM\EntityManagerInterface;
10			use Symfony\Component\Messenger\Envelope;
11			use Symfony\Component\Messenger\Middleware\StackInterface;
12			use Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp;
13
14			/**
15			* @final
16			*/
17			class DoctrinePingConnectionMiddleware extends AbstractDoctrineMiddleware
18			{
19			protected function handleForManager(
20			EntityManagerInterface $entityManager,
21			Envelope $envelope,
22			StackInterface $stack
23			): Envelope {
24			if (null !== $envelope->last(ConsumedByWorkerStamp::class)) {
25			$this->pingConnection($entityManager);
26			}
27
28			return $stack->next()->handle($envelope, $stack);
29			}
30
31			private function pingConnection(EntityManagerInterface $entityManager): void
32			{
33			$connection = $entityManager->getConnection();
34
35			try {
36			$this->executeDummySql($connection);
37			} catch (Exception) {
38			$connection->close();
39			// Attempt to reestablish the lazy connection by sending another query.
40			$this->executeDummySql($connection);
41			}
42
43			if (! $entityManager->isOpen()) {
44			$this->managerRegistry->resetManager($this->entityManagerName);
45			}
46			}
47
48			/**
49			* @throws Exception
50			*/
51			private function executeDummySql(Connection $connection): void
52			{
53			$connection->executeQuery($connection->getDatabasePlatform()->getDummySelectSQL());
54			}
55			}
56

thomasvargiu / laminas-messenger

Push — master ( 79a79c...9c574d )

handleForManager() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like