FRZB\Component\Cryptography\Integration\Symfony\Messenger\Serializer\InternalCryptoSerializer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getBody()	0	3	1
A	__construct()	0	8	1
A	decode()	0	5	1
A	getHeaders()	0	3	1
A	encode()	0	7	1

<?php

declare(strict_types=1);

namespace FRZB\Component\Cryptography\Integration\Symfony\Messenger\Serializer;

use FRZB\Component\Cryptography\Service\CryptographyInterface as CryptographyService;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Transport\Serialization\Serializer as BaseSerializer;
use Symfony\Component\Serializer\SerializerInterface as Serializer;

class InternalCryptoSerializer extends BaseSerializer
{
    private CryptographyService $crypto;

    public function __construct(
        CryptographyService $crypto,
        ?Serializer $serializer = null,
        string $format = 'json',
        array $context = []
    ) {
        parent::__construct($serializer, $format, $context);
        $this->crypto = $crypto;
    }

    public function decode(array $encodedEnvelope): Envelope
    {
        return parent::decode([
            'body' => $this->crypto->decrypt(self::getBody($encodedEnvelope)),
            'headers' => self::getHeaders($encodedEnvelope),
        ]);
    }

    public function encode(Envelope $envelope): array
    {
        $encodedEnvelope = parent::encode($envelope);

        return [
            'body' => $this->crypto->encrypt(self::getBody($encodedEnvelope)),
            'headers' => self::getHeaders($encodedEnvelope),
        ];
    }

    private static function getBody(array $decodedEnvelope): ?string
    {
        return $decodedEnvelope['body'] ?? '{}';
    }

    protected static function getHeaders(array $decodedEnvelope): array
    {
        return $decodedEnvelope['headers'] ?? [];
    }
}