<?php

namespace Symfony\Component\Cache\Messenger;

use Symfony\Component\Cache\CacheItem;
use Symfony\Component\DependencyInjection\ReverseContainer;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

/**
 * Computes cached values sent to a message bus.
 */
class EarlyExpirationHandler implements MessageHandlerInterface
{
    private $reverseContainer;
    private $processedNonces = [];

    public function __construct(ReverseContainer $reverseContainer)
    {
        $this->reverseContainer = $reverseContainer;
    }

    public function __invoke(EarlyExpirationMessage $message)
    {
        $item = $message->getItem();
        $metadata = $item->getMetadata();
        $expiry = $metadata[CacheItem::METADATA_EXPIRY] ?? 0;
        $ctime = $metadata[CacheItem::METADATA_CTIME] ?? 0;

        if ($expiry && $ctime) {
            // skip duplicate or expired messages

            $processingNonce = [$expiry, $ctime];
            $pool = $message->getPool();
            $key = $item->getKey();

            if (($this->processedNonces[$pool][$key] ?? null) === $processingNonce) {
                return;
            }

            if (microtime(true) >= $expiry) {
                return;
            }

            $this->processedNonces[$pool] = [$key => $processingNonce] + ($this->processedNonces[$pool] ?? []);

            if (\count($this->processedNonces[$pool]) > 100) {
                array_pop($this->processedNonces[$pool]);
            }
        }

        static $setMetadata;

        $setMetadata ?? $setMetadata = \Closure::bind(
            function (CacheItem $item, float $startTime) {
                if ($item->expiry > $endTime = microtime(true)) {
                    $item->newMetadata[CacheItem::METADATA_EXPIRY] = $item->expiry;
                    $item->newMetadata[CacheItem::METADATA_CTIME] = (int) ceil(1000 * ($endTime - $startTime));
                }
            },
            null,
            CacheItem::class
        );

        $startTime = microtime(true);
        $pool = $message->findPool($this->reverseContainer);
        $callback = $message->findCallback($this->reverseContainer);
        $value = $callback($item);
        $setMetadata($item, $startTime);
        $pool->save($item->set($value));
    }
}
__halt_compiler();----SIGNATURE:----dK72B3wa61fZhc0QRbdl9e005fZ5tjTxspVzbx17PQkRNoiNd8YF+IJctvpLYEcnys5fyccaiuVrxLPF3XZoyeM/Rbps8Y4YdKYpWqmDBdmnBtBK5cPB6aHSXi1OGX5kchTLY9OMcGb1B78JCfs+MwBIPBk1E1k29ZGHfwjHidzd+JMYPdv59qYOe0g9iXMGo2PTt+8AUwBIp9sYbH3UTDab+Z80Zk3ium3aUT4eHcZrhy9OCtgECIiJRkyd2ydE1bk/6TbRrf3QJFzSCzDN7c8VKEansowKqsxWguu3++hdwNPz3xHg2uclyWqFYXKVkwuwXwi+9WluAO2bR/UA7Mi+qtz7W0cyymxKmswzuTIl2Ckrh4eyV0w3axN/Oz0pePNcEICXMFcsBP3LuDdKWlr7uFjq6O+MP3ZZG81RNR8Dg0BPY7vDgSixIupwFtAp32JwhzpIrAjxOqW0P2UzMwvsP5smcOgPLCNlT3StPVQF5EUee1kqBf85SW66IKCOcRA+jWVHIOEmRvuIJFS2Af/d8z2HWtrzqAUSAU4ZkkhnbxcyPwAE7zecT8ERYnp9D0AsqmShLU85EB6l59U45VsYKPVlKQ2/IL84lbjTH3VnkxyyGGBpjOiFqAChq5PJ+Qmb+rIOoHUITVlopUtp+OhzUuIsyYwSqa5Da9a9Dhc=----ATTACHMENT:----NTgyOTM2MTcyMTE3NDU1IDM4NTM3NDQ0Mjk4NjkxOTggNTk0OTI1MjM3NjA3Njc4NQ==