TestTransportFactory::parseDsn() - Code Metrics - Inspection of "[bug/BC BREAK] Persist intercept & catch_exception..." - zenstruck/messenger-test - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — 1.x ( 774941...781dbf )

by Kevin

created 2021-05-14 22:28 UTC

TestTransportFactory::parseDsn() A

↳ Parent: TestTransportFactory

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	0

Metric	Value
cc	2
eloc	6
c	2
b	1
f	0
nc	2
nop	1
dl	0
loc	11
rs	10

<?php

namespace Zenstruck\Messenger\Test\Transport;

use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
use Symfony\Component\Messenger\Transport\TransportFactoryInterface;
use Symfony\Component\Messenger\Transport\TransportInterface;

/**
 * @author Kevin Bond <[email protected]>
 *
 * @internal
 */
final class TestTransportFactory implements TransportFactoryInterface
{
    private MessageBusInterface $bus;

    public function __construct(MessageBusInterface $bus)
    {
        $this->bus = $bus;
    }

    public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
    {
        return new TestTransport($options['transport_name'], $this->bus, $serializer, $this->parseDsn($dsn));
    }

    public function supports(string $dsn, array $options): bool
    {
        return 0 === \mb_strpos($dsn, 'test://');
    }

    private function parseDsn(string $dsn): array
    {
        $query = [];

        if ($queryAsString = \mb_strstr($dsn, '?')) {
            \parse_str(\ltrim($queryAsString, '?'), $query);
        }

        return [
            'intercept' => \filter_var($query['intercept'] ?? true, \FILTER_VALIDATE_BOOLEAN),
            'catch_exceptions' => \filter_var($query['catch_exceptions'] ?? true, \FILTER_VALIDATE_BOOLEAN),
        ];
    }
}


1			<?php
2
3			namespace Zenstruck\Messenger\Test\Transport;
4
5			use Symfony\Component\Messenger\MessageBusInterface;
6			use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
7			use Symfony\Component\Messenger\Transport\TransportFactoryInterface;
8			use Symfony\Component\Messenger\Transport\TransportInterface;
9
10			/**
11			* @author Kevin Bond <[email protected]>
12			*
13			* @internal
14			*/
15			final class TestTransportFactory implements TransportFactoryInterface
16			{
17			private MessageBusInterface $bus;
18
19			public function __construct(MessageBusInterface $bus)
20			{
21			$this->bus = $bus;
22			}
23
24			public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
25			{
26			return new TestTransport($options['transport_name'], $this->bus, $serializer, $this->parseDsn($dsn));
27			}
28
29			public function supports(string $dsn, array $options): bool
30			{
31			return 0 === \mb_strpos($dsn, 'test://');
32			}
33
34			private function parseDsn(string $dsn): array
35			{
36			$query = [];
37
38			if ($queryAsString = \mb_strstr($dsn, '?')) {
39			\parse_str(\ltrim($queryAsString, '?'), $query);
40			}
41
42			return [
43			'intercept' => \filter_var($query['intercept'] ?? true, \FILTER_VALIDATE_BOOLEAN),
44			'catch_exceptions' => \filter_var($query['catch_exceptions'] ?? true, \FILTER_VALIDATE_BOOLEAN),
45			];
46			}
47			}
48

zenstruck / messenger-test

Push — 1.x ( 774941...781dbf )

TestTransportFactory::parseDsn() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like