fhteam/laravel-cache-redis-extended

<?php namespace FHTeam\LaravelRedisCache\DataLayer\Serializer;

use FHTeam\LaravelRedisCache\DataLayer\CacheItem;
use FHTeam\LaravelRedisCache\TagVersion\TagVersionManagerInterface;
use FHTeam\LaravelRedisCache\Utility\ArrayTools;
use FHTeam\LaravelRedisCache\Utility\TimeTools;

/**
 * Generic serializer implementation
 *
 * @package FHTeam\LaravelRedisCache\DataLayer\Serialization
 */
class GenericSerializer implements SerializerInterface
{
    /**
     * @var TagVersionManagerInterface
     */
    private $tagVersions;
    /**
     * @var CoderManagerInterface
     */
    private $coderManager;

    /**
     * @param TagVersionManagerInterface $tagVersionManager
     * @param CoderManagerInterface      $coderManager
     */
    public function __construct(TagVersionManagerInterface $tagVersionManager, CoderManagerInterface $coderManager)
    {
        $this->tagVersions = $tagVersionManager;
        $this->coderManager = $coderManager;
    }

    public function serialize($prefix, array $data, $minutes, array $tags)
    {
        $seconds = TimeTools::getTtlInSeconds($minutes);
        $tags = $this->tagVersions->getActualVersionsFor($tags);
        $data = ArrayTools::addPrefixToArrayKeys($prefix, $data);
        $data = array_map(
            function ($value) use ($seconds, $tags) {
                return (string)CacheItem::encode(
                    $this->isSimpleType($value) ? $value : $this->coderManager->encode($value),
                    $seconds,
                    $tags
                );
            },
            $data
        );

        return $data;
    }

    public function deserialize($prefix, array $data)
    {
        $data = ArrayTools::stripPrefixFromArrayKeys($prefix, $data);

        $data = array_map(
            function ($cacheItem) {
                return CacheItem::decode($cacheItem);
            },
            $data
        );

        /** @var CacheItem[] $data */
        foreach ($data as &$item) {
            if ($item->isExpired()) {
                $item = null;
                continue;
            }

            if ($this->tagVersions->isAnyTagExpired($item->getTags())) {
                $item = null;
                continue;
            }

            $value = $item->getValue();
            $item = $this->isSimpleType($value) ? $value : $this->coderManager->decode($value);
        }

        return $data;
    }

    /**
     * @param $value
     *
     * @return bool
     */
    protected function isSimpleType($value)
    {
        return is_numeric($value) || is_string($value) || is_bool($value);
    }
}