Spaces:
No application file
No application file
File size: 4,506 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 |
<?php
declare(strict_types=1);
namespace Mautic\CacheBundle\Cache;
use Mautic\CoreBundle\Helper\CoreParametersHelper;
use Psr\Cache\CacheItemInterface;
use Psr\Cache\InvalidArgumentException as Psr6CacheInterface;
use Symfony\Component\Cache\Adapter\TagAwareAdapterInterface;
use Symfony\Component\Cache\CacheItem;
use Symfony\Component\Cache\Exception\InvalidArgumentException;
use Symfony\Component\Cache\Psr16Cache;
use Symfony\Component\DependencyInjection\ContainerInterface;
/**
* Povides caching mechanism using adapters, it provides both PSR-6 and PSR-16.
*/
final class CacheProvider implements CacheProviderInterface
{
private ?Psr16Cache $psr16 = null;
public function __construct(
private CoreParametersHelper $coreParametersHelper,
private ContainerInterface $container
) {
}
public function getCacheAdapter(): TagAwareAdapterInterface
{
$selectedAdapter = $this->coreParametersHelper->get('cache_adapter');
if (!$selectedAdapter || !$this->container->has($selectedAdapter)) {
throw new InvalidArgumentException('Requested cache adapter "'.$selectedAdapter.'" is not available');
}
$adaptor = $this->container->get($selectedAdapter);
if (!$adaptor instanceof TagAwareAdapterInterface) {
throw new InvalidArgumentException(sprintf('Requested cache adapter "%s" is not a %s', $selectedAdapter, TagAwareAdapterInterface::class));
}
return $adaptor;
}
public function getSimpleCache(): Psr16Cache
{
if (is_null($this->psr16)) {
$this->psr16 = new Psr16Cache($this->getCacheAdapter());
}
return $this->psr16;
}
/**
* @param string $key
*
* @throws Psr6CacheInterface
*/
public function getItem($key): CacheItem
{
return $this->getCacheAdapter()->getItem($key);
}
/**
* @return CacheItem[]|\Traversable
*
* @throws Psr6CacheInterface
*/
public function getItems(array $keys = []): \Traversable
{
return $this->getCacheAdapter()->getItems($keys);
}
/**
* @param string $key
*
* @throws Psr6CacheInterface
*/
public function hasItem($key): bool
{
return $this->getCacheAdapter()->hasItem($key);
}
public function clear(string $prefix = ''): bool
{
return $this->getCacheAdapter()->clear($prefix);
}
public function deleteItem($key): bool
{
return $this->getCacheAdapter()->deleteItem($key);
}
/**
* Removes multiple items from the pool.
*
* @param string[] $keys An array of keys that should be removed from the pool
*
* @return bool True if the items were successfully removed. False if there was an error.
*
* @throws Psr6CacheInterface If any of the keys in $keys are not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown
*/
public function deleteItems(array $keys): bool
{
return $this->getCacheAdapter()->deleteItems($keys);
}
/**
* Persists a cache item immediately.
*
* @param CacheItemInterface $item The cache item to save
*
* @return bool True if the item was successfully persisted. False if there was an error.
*/
public function save(CacheItemInterface $item): bool
{
return $this->getCacheAdapter()->save($item);
}
/**
* Sets a cache item to be persisted later.
*
* @param CacheItemInterface $item The cache item to save
*
* @return bool False if the item could not be queued or if a commit was attempted and failed. True otherwise.
*/
public function saveDeferred(CacheItemInterface $item): bool
{
return $this->getCacheAdapter()->saveDeferred($item);
}
/**
* Persists any deferred cache items.
*
* @return bool True if all not-yet-saved items were successfully saved or there were none. False otherwise.
*/
public function commit(): bool
{
return $this->getCacheAdapter()->commit();
}
/**
* Invalidates cached items using tags.
*
* @param string[] $tags An array of tags to invalidate
*
* @return bool True on success
*
* @throws Psr6CacheInterface When $tags is not valid
*/
public function invalidateTags(array $tags): bool
{
return $this->getCacheAdapter()->invalidateTags($tags);
}
}
|