banker/src/Pool.php

315 lines
7.0 KiB
PHP
Raw Normal View History

2016-10-19 09:57:06 -04:00
<?php declare(strict_types=1);
2016-08-31 12:18:46 -04:00
/**
2016-09-05 16:43:37 -04:00
* Banker
2016-08-31 12:18:46 -04:00
*
* A Caching library implementing psr/cache
*
2016-10-19 09:57:06 -04:00
* PHP version 7.0
2016-08-31 12:18:46 -04:00
*
2016-09-05 16:43:37 -04:00
* @package Banker
2016-08-31 12:18:46 -04:00
* @author Timothy J. Warren <tim@timshomepage.net>
2017-03-01 12:33:12 -05:00
* @copyright 2016 - 2017 Timothy J. Warren
2016-08-31 12:18:46 -04:00
* @license http://www.opensource.org/licenses/mit-license.html MIT License
2017-03-01 12:33:12 -05:00
* @version 1.0.1
2016-09-05 16:43:37 -04:00
* @link https://git.timshomepage.net/timw4mail/banker
2016-08-31 12:18:46 -04:00
*/
namespace Aviat\Banker;
use Aviat\Banker\Driver\DriverInterface;
2016-09-05 16:43:37 -04:00
use Aviat\Banker\Exception\InvalidArgumentException;
2016-10-19 09:57:06 -04:00
use Aviat\Banker\{Item, ItemCollection};
use Psr\Cache\{CacheItemInterface, CacheItemPoolInterface};
use Psr\Log\{LoggerAwareInterface, LoggerInterface};
2016-08-31 12:18:46 -04:00
/**
* The main cache manager
*/
2016-09-06 17:03:43 -04:00
class Pool implements CacheItemPoolInterface, LoggerAwareInterface {
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
use LoggerTrait;
2016-08-31 12:18:46 -04:00
/**
* Driver class for handling the chosen caching backend
*
2016-09-05 16:43:37 -04:00
* @var DriverInterface
2016-08-31 12:18:46 -04:00
*/
protected $driver;
2016-09-05 16:43:37 -04:00
/**
* Cache Items to be saved
*
* @var array
*/
protected $deferred = [];
2016-08-31 12:18:46 -04:00
/**
* Set up the cache backend
*
* @param array $config
*/
2016-09-06 17:03:43 -04:00
public function __construct(array $config, LoggerInterface $logger = NULL)
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
$this->driver = $this->loadDriver($config);
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
if ( ! is_null($logger))
{
$this->setLogger($logger);
}
2016-08-31 12:18:46 -04:00
}
/**
* Returns a Cache Item representing the specified key.
*
* This method must always return a CacheItemInterface object, even in case of
* a cache miss. It MUST NOT return null.
*
* @param string $key
* The key for which to return the corresponding Cache Item.
*
* @throws InvalidArgumentException
* If the $key string is not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown.
*
* @return CacheItemInterface
* The corresponding Cache Item.
*/
2016-10-19 09:57:06 -04:00
public function getItem($key): CacheItemInterface
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
if ( ! is_string($key))
{
2016-09-06 17:03:43 -04:00
throw new InvalidArgumentException();
}
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
// If a deferred item exists, return that
if (array_key_exists($key, $this->deferred))
{
return $this->deferred[$key];
2016-09-05 16:43:37 -04:00
}
$item = new Item($this->driver, $key);
return $item;
2016-08-31 12:18:46 -04:00
}
/**
* Returns a traversable set of cache items.
*
* @param string[] $keys
* An indexed array of keys of items to retrieve.
*
* @throws InvalidArgumentException
* If any of the keys in $keys are not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown.
*
* @return array|\Traversable
* A traversable collection of Cache Items keyed by the cache keys of
* each item. A Cache item will be returned for each key, even if that
* key is not found. However, if no keys are specified then an empty
* traversable MUST be returned instead.
*/
public function getItems(array $keys = [])
{
2016-09-06 17:03:43 -04:00
if (empty($keys))
{
return new ItemCollection([]);
}
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
foreach($keys as $key)
{
if ( ! is_string($key))
{
throw new InvalidArgumentException();
}
}
2016-09-06 20:57:24 -04:00
2016-09-05 16:43:37 -04:00
// Get the set of items selected
$items = [];
2016-09-06 17:03:43 -04:00
$rawItems = $this->driver->getMultiple($keys);
foreach($rawItems as $key => $val)
2016-09-05 16:43:37 -04:00
{
2016-09-06 17:03:43 -04:00
if (array_key_exists($key, $this->deferred))
{
$items[$key] = $this->deferred[$key];
}
else
{
$items[$key] = new Item($this->driver, $key);
}
2016-09-05 16:43:37 -04:00
}
return new ItemCollection($items);
2016-08-31 12:18:46 -04:00
}
/**
* Confirms if the cache contains specified cache item.
*
* Note: This method MAY avoid retrieving the cached value for performance reasons.
* This could result in a race condition with CacheItemInterface::get(). To avoid
* such situation use CacheItemInterface::isHit() instead.
*
* @param string $key
* The key for which to check existence.
*
* @throws InvalidArgumentException
* If the $key string is not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown.
*
* @return bool
* True if item exists in the cache, false otherwise.
*/
public function hasItem($key)
{
2016-09-05 16:43:37 -04:00
if ( ! is_string($key))
{
2016-09-06 17:03:43 -04:00
throw new InvalidArgumentException();
}
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
// See if there are any deferred items
if (array_key_exists($key, $this->deferred))
{
return TRUE;
2016-09-05 16:43:37 -04:00
}
return $this->driver->exists($key);
2016-08-31 12:18:46 -04:00
}
/**
* Deletes all items in the pool.
*
* @return bool
* True if the pool was successfully cleared. False if there was an error.
*/
2016-10-19 09:57:06 -04:00
public function clear(): bool
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
return $this->driver->flush();
2016-08-31 12:18:46 -04:00
}
/**
* Removes the item from the pool.
*
* @param string $key
* The key to delete.
*
* @throws InvalidArgumentException
* If the $key string is not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown.
*
* @return bool
* True if the item was successfully removed. False if there was an error.
*/
2016-10-19 09:57:06 -04:00
public function deleteItem($key): bool
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
if ( ! is_string($key))
{
2016-09-06 17:03:43 -04:00
throw new InvalidArgumentException();
2016-09-05 16:43:37 -04:00
}
if ( ! $this->hasItem($key))
{
return FALSE;
}
else
{
return $this->driver->delete($key);
}
2016-08-31 12:18:46 -04:00
}
/**
* Removes multiple items from the pool.
*
* @param string[] $keys
* An array of keys that should be removed from the pool.
* @throws InvalidArgumentException
* If any of the keys in $keys are not a legal value a \Psr\Cache\InvalidArgumentException
* MUST be thrown.
*
* @return bool
* True if the items were successfully removed. False if there was an error.
*/
2016-10-19 09:57:06 -04:00
public function deleteItems(array $keys): bool
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
foreach ($keys as $key)
{
if ( ! is_string($key))
{
2016-09-06 17:03:43 -04:00
throw new InvalidArgumentException();
2016-09-05 16:43:37 -04:00
}
}
return $this->driver->deleteMultiple($keys);
2016-08-31 12:18:46 -04:00
}
/**
* 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.
*/
2016-10-19 09:57:06 -04:00
public function save(CacheItemInterface $item): bool
2016-08-31 12:18:46 -04:00
{
2016-09-06 17:03:43 -04:00
return $item->save();
2016-08-31 12:18:46 -04:00
}
/**
* 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.
*/
2016-10-19 09:57:06 -04:00
public function saveDeferred(CacheItemInterface $item): bool
2016-08-31 12:18:46 -04:00
{
2016-09-06 17:03:43 -04:00
$this->deferred[$item->getKey()] = $item;
return TRUE;
2016-08-31 12:18:46 -04:00
}
/**
* Persists any deferred cache items.
*
* @return bool
* True if all not-yet-saved items were successfully saved or there were none. False otherwise.
*/
2016-10-19 09:57:06 -04:00
public function commit(): bool
2016-08-31 12:18:46 -04:00
{
2016-09-05 16:43:37 -04:00
if (empty($this->deferred))
{
return TRUE;
}
$result = TRUE;
foreach($this->deferred as $item)
{
$result = $result && $this->save($item);
}
2016-09-06 20:57:24 -04:00
2016-09-06 17:03:43 -04:00
if ($result === TRUE)
{
$this->deferred = [];
}
2016-09-05 16:43:37 -04:00
return $result;
2016-08-31 12:18:46 -04:00
}
2016-09-05 16:43:37 -04:00
2016-08-31 12:18:46 -04:00
/**
* Instantiate the appropriate cache backend based on the config
*
* @param array $driverConfig
* @return DriverInterface
*/
2016-10-19 09:57:06 -04:00
protected function loadDriver(array $driverConfig): DriverInterface
2016-08-31 12:18:46 -04:00
{
$driver = ucfirst(strtolower($driverConfig['driver']));
2016-09-06 17:03:43 -04:00
$class = __NAMESPACE__ . "\\Driver\\${driver}Driver";
2017-02-28 16:44:02 -05:00
$driverConfig['connection'] = $driverConfig['connection'] ?? [];
$driverConfig['options'] = $driverConfig['options'] ?? [];
2016-09-06 20:57:24 -04:00
return new $class($driverConfig['connection'], $driverConfig['options']);
2016-08-31 12:18:46 -04:00
}
}