MessageDeserializerResolver::resolve() - Code Metrics - phpservicebus/core - Measure and Improve Code Quality continuously with Scrutinizer

MessageDeserializerResolver::resolve() A
last analyzed 2020-01-22 17:49 UTC

↳ Parent: MessageDeserializerResolver

Complexity

Conditions	3
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	3

Importance

Changes

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

<?php
namespace PSB\Core\Serialization;


use PSB\Core\Exception\InvalidArgumentException;
use PSB\Core\HeaderTypeEnum;

class MessageDeserializerResolver
{
    /**
     * Serializers indexed by content type
     *
     * @var MessageSerializerInterface[]
     */
    private $messageSerializers = [];

    /**
     * @var MessageSerializerInterface
     */
    private $defaultSerializer;

    /**
     * @param MessageSerializerInterface[] $messageSerializers
     * @param string                       $defaultSerializerFqcn
     */
    public function __construct(array $messageSerializers, $defaultSerializerFqcn)
    {
        $defaultFound = false;
        foreach ($messageSerializers as $serializer) {
            if ($serializer instanceof $defaultSerializerFqcn) {
                $this->defaultSerializer = $serializer;
                $defaultFound = true;
                break;
            }
        }

        if (!$defaultFound) {
            throw new InvalidArgumentException("Found no serializer that matches class '$defaultSerializerFqcn'.");
        }

        foreach ($messageSerializers as $serializer) {
            $this->messageSerializers[$serializer->getContentType()] = $serializer;
        }
    }

    /**
     * @param array $headers
     *
     * @return MessageSerializerInterface
     */
    public function resolve(array $headers)
    {
        if (!isset($headers[HeaderTypeEnum::CONTENT_TYPE]) ||
            !isset($this->messageSerializers[$headers[HeaderTypeEnum::CONTENT_TYPE]])
        ) {
            return $this->defaultSerializer;
        }

        return $this->messageSerializers[$headers[HeaderTypeEnum::CONTENT_TYPE]];
    }
}


1		<?php
2		namespace PSB\Core\Serialization;
3
4
5		use PSB\Core\Exception\InvalidArgumentException;
6		use PSB\Core\HeaderTypeEnum;
7
8		class MessageDeserializerResolver
9		{
10		/**
11		* Serializers indexed by content type
12		*
13		* @var MessageSerializerInterface[]
14		*/
15		private $messageSerializers = [];
16
17		/**
18		* @var MessageSerializerInterface
19		*/
20		private $defaultSerializer;
21
22		/**
23		* @param MessageSerializerInterface[] $messageSerializers
24		* @param string $defaultSerializerFqcn
25		*/
26	5	public function __construct(array $messageSerializers, $defaultSerializerFqcn)
27		{
28	5	$defaultFound = false;
29	5	foreach ($messageSerializers as $serializer) {
30	4	if ($serializer instanceof $defaultSerializerFqcn) {
31	3	$this->defaultSerializer = $serializer;
32	3	$defaultFound = true;
33	3	break;
34		}
35		}
36
37	5	if (!$defaultFound) {
38	2	throw new InvalidArgumentException("Found no serializer that matches class '$defaultSerializerFqcn'.");
39		}
40
41	3	foreach ($messageSerializers as $serializer) {
42	3	$this->messageSerializers[$serializer->getContentType()] = $serializer;
43		}
44	3	}
45
46		/**
47		* @param array $headers
48		*
49		* @return MessageSerializerInterface
50		*/
51	3	public function resolve(array $headers)
52		{
53	3	if (!isset($headers[HeaderTypeEnum::CONTENT_TYPE]) \|\|
54	3	!isset($this->messageSerializers[$headers[HeaderTypeEnum::CONTENT_TYPE]])
55		) {
56	2	return $this->defaultSerializer;
57		}
58
59	1	return $this->messageSerializers[$headers[HeaderTypeEnum::CONTENT_TYPE]];
60		}
61		}
62

phpservicebus / core

MessageDeserializerResolver::resolve() A last analyzed 2020-01-22 17:49 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MessageDeserializerResolver::resolve() A
last analyzed 2020-01-22 17:49 UTC