GetEntryProcessor.php

<?php

namespace Doctrine\Cache\Driver\InMemory\Processor;

class GetEntryProcessor implements EntryProcessor
{
    public function process(MutableEntry $entry, ...$arguments) : EntryProcessorResult
    {
        $now            = microtime(true);
        $valueConverter = $this->cache->getConfiguration()->getValueConverter();
        $keyConverter   = $this->cache->getConfiguration()->getKeyConverter();
        $internalKey    = $keyConverter->toInternal($entry->getKey());
        $cachedValue    = $this->cache->internalGet($internalKey);
        
        if ($cachedValue !== null && ! $cachedValue->isExpiredAt($now)) {
            $internalValue = $cachedValue->getInternalValue();
            $value         = $valueConverter->fromInternal($internalValue);
            
            $entry->setValue($value);
            
            return new EntryProcessorResult($entry);
        }
        
        $value = $this->cache->getConfiguration()->isReadThrough()
            ? $this->cache->getConfiguration()->getCacheLoader()->load($key)
            : null;
            
        if ($value === null) {
            return new EntryProcessorResult(null);
        }
        
        $entry->setValue($value);
        
        $expiryPolicy     = $this->cache->getConfiguration()->getExpiryPolicy();
        $creationDuration = $expiryPolicy->getExpiryForCreation();
        $expiryTime       = $creationDuration->getAdjustedTime($now);
        $internalValue    = $valueConverter->toInternal($value);
        $cachedValue      = new CachedValue($internalValue, $now, $expiryTime);
        
        $this->cache->internalSet($internalKey, $cachedValue);
            
        return new EntryProcessorResult($entry);
    }
}