129 lines
3.3 KiB
PHP
129 lines
3.3 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of the PHPFlasher package.
|
|
* (c) Younes KHOUBZA <younes.khoubza@gmail.com>
|
|
*/
|
|
|
|
namespace Flasher\Prime\Storage;
|
|
|
|
use Flasher\Prime\EventDispatcher\Event\FilterEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\PersistEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\PostPersistEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\PostRemoveEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\PostUpdateEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\RemoveEvent;
|
|
use Flasher\Prime\EventDispatcher\Event\UpdateEvent;
|
|
use Flasher\Prime\EventDispatcher\EventDispatcher;
|
|
use Flasher\Prime\EventDispatcher\EventDispatcherInterface;
|
|
|
|
final class StorageManager implements StorageManagerInterface
|
|
{
|
|
/**
|
|
* @var StorageInterface
|
|
*/
|
|
private $storage;
|
|
|
|
/**
|
|
* @var EventDispatcherInterface
|
|
*/
|
|
private $eventDispatcher;
|
|
|
|
/**
|
|
* @var mixed[]
|
|
*/
|
|
private $criteria = array();
|
|
|
|
/**
|
|
* @param mixed[] $criteria
|
|
*/
|
|
public function __construct(StorageInterface $storage = null, EventDispatcherInterface $eventDispatcher = null, array $criteria = array())
|
|
{
|
|
$this->storage = $storage ?: new StorageBag();
|
|
$this->eventDispatcher = $eventDispatcher ?: new EventDispatcher();
|
|
$this->criteria = $criteria;
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function all()
|
|
{
|
|
return $this->storage->all();
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function filter(array $criteria = array())
|
|
{
|
|
$criteria = array_merge($this->criteria, $criteria);
|
|
|
|
$criteria['delay'] = 0;
|
|
// @phpstan-ignore-next-line
|
|
$criteria['hops']['min'] = 1;
|
|
|
|
$event = new FilterEvent($this->all(), $criteria);
|
|
$this->eventDispatcher->dispatch($event);
|
|
|
|
return $event->getEnvelopes();
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function add($envelopes)
|
|
{
|
|
$envelopes = \is_array($envelopes) ? $envelopes : \func_get_args();
|
|
|
|
$event = new PersistEvent($envelopes);
|
|
$this->eventDispatcher->dispatch($event);
|
|
|
|
$this->storage->add($event->getEnvelopes());
|
|
|
|
$event = new PostPersistEvent($event->getEnvelopes());
|
|
$this->eventDispatcher->dispatch($event);
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function update($envelopes)
|
|
{
|
|
$envelopes = \is_array($envelopes) ? $envelopes : \func_get_args();
|
|
|
|
$event = new UpdateEvent($envelopes);
|
|
$this->eventDispatcher->dispatch($event);
|
|
|
|
$this->storage->update($event->getEnvelopes());
|
|
|
|
$event = new PostUpdateEvent($event->getEnvelopes());
|
|
$this->eventDispatcher->dispatch($event);
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function remove($envelopes)
|
|
{
|
|
$envelopes = \is_array($envelopes) ? $envelopes : \func_get_args();
|
|
|
|
$event = new RemoveEvent($envelopes);
|
|
$this->eventDispatcher->dispatch($event);
|
|
|
|
$this->storage->update($event->getEnvelopesToKeep());
|
|
$this->storage->remove($event->getEnvelopesToRemove());
|
|
|
|
$event = new PostRemoveEvent($event->getEnvelopesToRemove(), $event->getEnvelopesToKeep());
|
|
$this->eventDispatcher->dispatch($event);
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function clear()
|
|
{
|
|
$this->storage->clear();
|
|
}
|
|
}
|