Abacaphiliac\AwsSdk\ClaimCheck\Serializer\JsonSnsMessageSerializer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	serialize()	0	4	1
A	unserialize()	0	14	3

<?php

namespace Abacaphiliac\AwsSdk\ClaimCheck\Serializer;

use Abacaphiliac\AwsSdk\ClaimCheck\ClaimCheck;
use Abacaphiliac\AwsSdk\ClaimCheck\Exception\ExceptionInterface;
use Abacaphiliac\AwsSdk\ClaimCheck\Exception\InvalidArgumentException;
use Zend\Json\Exception\RuntimeException;
use Zend\Json\Json;

class JsonSnsMessageSerializer implements ClaimCheckSerializerInterface
{
    /** @var  ClaimCheckJsonSerializer */
    private $serializer;

    /**
     * JsonSnsMessageSerializer constructor.
     */
    public function __construct()
    {
        $this->serializer = new ClaimCheckJsonSerializer();
    }

    /**
     * @param ClaimCheck $claimCheck
     * @return string
     * @throws ExceptionInterface
     */
    public function serialize(ClaimCheck $claimCheck)
    {
        return $this->serializer->serialize($claimCheck);
    }

    /**
     * @param string $encodedValue
     * @return ClaimCheck
     * @throws ExceptionInterface
     */
    public function unserialize($encodedValue)
    {
        try {
            $data = Json::decode($encodedValue, Json::TYPE_ARRAY);
        } catch (RuntimeException $e) {
            throw new InvalidArgumentException($e->getMessage(), 0, $e);
        }
        
        if (!array_key_exists('Message', $data)) {
            throw new InvalidArgumentException('Message is required and cannot be empty.');
        }
        
        return $this->serializer->unserialize($data['Message']);
    }
}