1#@!#!123s

: / opt / psa / admin / plib / modules / wp-toolkit / vendor / symfony / cache / Messenger /
Filename : EarlyExpirationHandler.php
back
<?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier <fabien@symfony.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace WPToolkitDependenciesIsolationPrefix\Symfony\Component\Cache\Messenger;

use WPToolkitDependenciesIsolationPrefix\Symfony\Component\Cache\CacheItem;
use WPToolkitDependenciesIsolationPrefix\Symfony\Component\DependencyInjection\ReverseContainer;
use WPToolkitDependenciesIsolationPrefix\Symfony\Component\Messenger\Attribute\AsMessageHandler;
/**
 * Computes cached values sent to a message bus.
 */
#[\Symfony\Component\Messenger\Attribute\AsMessageHandler]
class EarlyExpirationHandler
{
    private array $processedNonces = [];
    public function __construct(private ReverseContainer $reverseContainer)
    {
    }
    public function __invoke(EarlyExpirationMessage $message) : void
    {
        $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 ??= \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);
        $save = \true;
        $value = $callback($item, $save);
        $setMetadata($item, $startTime);
        $pool->save($item->set($value));
    }
}