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

Passed

Push — master ( 109e7c...79a79c )

by Thomas Mauro

created 2025-01-26 06:06 UTC

handleForManager() A

↳ Parent: DoctrinePingConnectionMiddleware

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

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

<?php

declare(strict_types=1);

namespace TMV\Laminas\Messenger\Middleware;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\Persistence\ManagerRegistry;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Middleware\StackInterface;
use Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp;

final class DoctrinePingConnectionMiddleware extends AbstractDoctrineMiddleware
{
    private string $query;

    public function __construct(ManagerRegistry $managerRegistry, string $entityManagerName, string $query = 'SELECT 1;')
    {
        parent::__construct($managerRegistry, $entityManagerName);
        $this->query = $query;
    }

    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 {
            $connection->executeQuery($this->query);
        } catch (\Throwable $exception) {
            $connection->close();
        }

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


1		<?php
2
3		declare(strict_types=1);
4
5		namespace TMV\Laminas\Messenger\Middleware;
6
7		use Doctrine\ORM\EntityManagerInterface;
8		use Doctrine\Persistence\ManagerRegistry;
9		use Symfony\Component\Messenger\Envelope;
10		use Symfony\Component\Messenger\Middleware\StackInterface;
11		use Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp;
12
13		final class DoctrinePingConnectionMiddleware extends AbstractDoctrineMiddleware
14	3	{
15		private string $query;
16
17		public function __construct(ManagerRegistry $managerRegistry, string $entityManagerName, string $query = 'SELECT 1;')
18		{
19	3	parent::__construct($managerRegistry, $entityManagerName);
20	2	$this->query = $query;
21		}
22
23	3	protected function handleForManager(
24		EntityManagerInterface $entityManager,
25		Envelope $envelope,
26	2	StackInterface $stack
27		): Envelope {
28	2	if (null !== $envelope->last(ConsumedByWorkerStamp::class)) {
29		$this->pingConnection($entityManager);
30	2	}
31	2
32	2	return $stack->next()->handle($envelope, $stack);
33		}
34
35	2	private function pingConnection(EntityManagerInterface $entityManager): void
36	2	{
37		$connection = $entityManager->getConnection();
38	2
39		try {
40		$connection->executeQuery($this->query);
41		} catch (\Throwable $exception) {
42		$connection->close();
43		}
44
45		if (! $entityManager->isOpen()) {
46		$this->managerRegistry->resetManager($this->entityManagerName);
47		}
48		}
49		}
50

thomasvargiu / laminas-messenger

Push — master ( 109e7c...79a79c )

handleForManager() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like