Spiral\Queue\SerializerRegistry

Complexity

Total Complexity

8

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	deserialize()	0	3	1
A	addSerializer()	0	4	2
A	getSerializer()	0	7	2
A	__construct()	0	3	1
A	serialize()	0	3	1
A	hasSerializer()	0	3	1

<?php

declare(strict_types=1);

namespace Spiral\Queue;

final class SerializerRegistry implements SerializerInterface, SerializerRegistryInterface
{
    /** @var array<non-empty-string, SerializerInterface> */

The doc comment array<non-empty-string, SerializerInterface> at position 2 could not be parsed: Unknown type name 'non-empty-string' at position 2 in array<non-empty-string, SerializerInterface>.

    private array $serializers = [];
    private SerializerInterface $default;

    /** @param array<non-empty-string, SerializerInterface> $serializers */

The doc comment array<non-empty-string, SerializerInterface> at position 2 could not be parsed: Unknown type name 'non-empty-string' at position 2 in array<non-empty-string, SerializerInterface>.

    public function __construct(SerializerInterface $default)
    {
        $this->default = $default;
    }

    public function serialize(array $payload): string
    {
        return $this->default->serialize($payload);
    }

    public function deserialize(string $payload): array
    {
        return $this->default->deserialize($payload);
    }

    public function getSerializer(string $jobType): SerializerInterface
    {
        if (!$this->hasSerializer($jobType)) {
            return $this->default;
        }

        return $this->serializers[$jobType];
    }

    public function addSerializer(string $jobType, SerializerInterface $serializer): void
    {
        if (!$this->hasSerializer($jobType)) {
            $this->serializers[$jobType] = $serializer;
        }
    }

    public function hasSerializer(string $jobType): bool
    {
        return isset($this->serializers[$jobType]);
    }
}