eventdispatcher stage all
This commit is contained in:
kremsy
parent
3d7cddccd5
commit
86d3803993
@ -0,0 +1,320 @@
|
|||||||
|
<?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 Symfony\Component\EventDispatcher\Debug;
|
||||||
|
|
||||||
|
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
|
||||||
|
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
|
||||||
|
use Symfony\Component\EventDispatcher\Event;
|
||||||
|
use Symfony\Component\Stopwatch\Stopwatch;
|
||||||
|
use Psr\Log\LoggerInterface;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Collects some data about event listeners.
|
||||||
|
*
|
||||||
|
* This event dispatcher delegates the dispatching to another one.
|
||||||
|
*
|
||||||
|
* @author Fabien Potencier <fabien@symfony.com>
|
||||||
|
*/
|
||||||
|
class TraceableEventDispatcher implements TraceableEventDispatcherInterface
|
||||||
|
{
|
||||||
|
protected $logger;
|
||||||
|
protected $stopwatch;
|
||||||
|
|
||||||
|
private $called;
|
||||||
|
private $dispatcher;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constructor.
|
||||||
|
*
|
||||||
|
* @param EventDispatcherInterface $dispatcher An EventDispatcherInterface instance
|
||||||
|
* @param Stopwatch $stopwatch A Stopwatch instance
|
||||||
|
* @param LoggerInterface $logger A LoggerInterface instance
|
||||||
|
*/
|
||||||
|
public function __construct(EventDispatcherInterface $dispatcher, Stopwatch $stopwatch, LoggerInterface $logger = null)
|
||||||
|
{
|
||||||
|
$this->dispatcher = $dispatcher;
|
||||||
|
$this->stopwatch = $stopwatch;
|
||||||
|
$this->logger = $logger;
|
||||||
|
$this->called = array();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function addListener($eventName, $listener, $priority = 0)
|
||||||
|
{
|
||||||
|
$this->dispatcher->addListener($eventName, $listener, $priority);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function addSubscriber(EventSubscriberInterface $subscriber)
|
||||||
|
{
|
||||||
|
$this->dispatcher->addSubscriber($subscriber);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function removeListener($eventName, $listener)
|
||||||
|
{
|
||||||
|
return $this->dispatcher->removeListener($eventName, $listener);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function removeSubscriber(EventSubscriberInterface $subscriber)
|
||||||
|
{
|
||||||
|
return $this->dispatcher->removeSubscriber($subscriber);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function getListeners($eventName = null)
|
||||||
|
{
|
||||||
|
return $this->dispatcher->getListeners($eventName);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function hasListeners($eventName = null)
|
||||||
|
{
|
||||||
|
return $this->dispatcher->hasListeners($eventName);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function dispatch($eventName, Event $event = null)
|
||||||
|
{
|
||||||
|
if (null === $event) {
|
||||||
|
$event = new Event();
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->preProcess($eventName);
|
||||||
|
$this->preDispatch($eventName, $event);
|
||||||
|
|
||||||
|
$e = $this->stopwatch->start($eventName, 'section');
|
||||||
|
|
||||||
|
$this->dispatcher->dispatch($eventName, $event);
|
||||||
|
|
||||||
|
if ($e->isStarted()) {
|
||||||
|
$e->stop();
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->postDispatch($eventName, $event);
|
||||||
|
$this->postProcess($eventName);
|
||||||
|
|
||||||
|
return $event;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function getCalledListeners()
|
||||||
|
{
|
||||||
|
$called = array();
|
||||||
|
foreach ($this->called as $eventName => $listeners) {
|
||||||
|
foreach ($listeners as $listener) {
|
||||||
|
$info = $this->getListenerInfo($listener->getWrappedListener(), $eventName);
|
||||||
|
$called[$eventName.'.'.$info['pretty']] = $info;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return $called;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@inheritdoc}
|
||||||
|
*/
|
||||||
|
public function getNotCalledListeners()
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$allListeners = $this->getListeners();
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
if (null !== $this->logger) {
|
||||||
|
$this->logger->info(sprintf('An exception was thrown while getting the uncalled listeners (%s)', $e->getMessage()), array('exception' => $e));
|
||||||
|
}
|
||||||
|
|
||||||
|
// unable to retrieve the uncalled listeners
|
||||||
|
return array();
|
||||||
|
}
|
||||||
|
|
||||||
|
$notCalled = array();
|
||||||
|
foreach ($allListeners as $eventName => $listeners) {
|
||||||
|
foreach ($listeners as $listener) {
|
||||||
|
$called = false;
|
||||||
|
if (isset($this->called[$eventName])) {
|
||||||
|
foreach ($this->called[$eventName] as $l) {
|
||||||
|
if ($l->getWrappedListener() === $listener) {
|
||||||
|
$called = true;
|
||||||
|
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!$called) {
|
||||||
|
$info = $this->getListenerInfo($listener, $eventName);
|
||||||
|
$notCalled[$eventName.'.'.$info['pretty']] = $info;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return $notCalled;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Proxies all method calls to the original event dispatcher.
|
||||||
|
*
|
||||||
|
* @param string $method The method name
|
||||||
|
* @param array $arguments The method arguments
|
||||||
|
*
|
||||||
|
* @return mixed
|
||||||
|
*/
|
||||||
|
public function __call($method, $arguments)
|
||||||
|
{
|
||||||
|
return call_user_func_array(array($this->dispatcher, $method), $arguments);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Called before dispatching the event.
|
||||||
|
*
|
||||||
|
* @param string $eventName The event name
|
||||||
|
* @param Event $event The event
|
||||||
|
*/
|
||||||
|
protected function preDispatch($eventName, Event $event)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Called after dispatching the event.
|
||||||
|
*
|
||||||
|
* @param string $eventName The event name
|
||||||
|
* @param Event $event The event
|
||||||
|
*/
|
||||||
|
protected function postDispatch($eventName, Event $event)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
private function preProcess($eventName)
|
||||||
|
{
|
||||||
|
foreach ($this->dispatcher->getListeners($eventName) as $listener) {
|
||||||
|
$this->dispatcher->removeListener($eventName, $listener);
|
||||||
|
$info = $this->getListenerInfo($listener, $eventName);
|
||||||
|
$name = isset($info['class']) ? $info['class'] : $info['type'];
|
||||||
|
$this->dispatcher->addListener($eventName, new WrappedListener($listener, $name, $this->stopwatch));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private function postProcess($eventName)
|
||||||
|
{
|
||||||
|
$skipped = false;
|
||||||
|
foreach ($this->dispatcher->getListeners($eventName) as $listener) {
|
||||||
|
if (!$listener instanceof WrappedListener) { // #12845: a new listener was added during dispatch.
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
// Unwrap listener
|
||||||
|
$this->dispatcher->removeListener($eventName, $listener);
|
||||||
|
$this->dispatcher->addListener($eventName, $listener->getWrappedListener());
|
||||||
|
|
||||||
|
$info = $this->getListenerInfo($listener->getWrappedListener(), $eventName);
|
||||||
|
if ($listener->wasCalled()) {
|
||||||
|
if (null !== $this->logger) {
|
||||||
|
$this->logger->debug(sprintf('Notified event "%s" to listener "%s".', $eventName, $info['pretty']));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!isset($this->called[$eventName])) {
|
||||||
|
$this->called[$eventName] = new \SplObjectStorage();
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->called[$eventName]->attach($listener);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (null !== $this->logger && $skipped) {
|
||||||
|
$this->logger->debug(sprintf('Listener "%s" was not called for event "%s".', $info['pretty'], $eventName));
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($listener->stoppedPropagation()) {
|
||||||
|
if (null !== $this->logger) {
|
||||||
|
$this->logger->debug(sprintf('Listener "%s" stopped propagation of the event "%s".', $info['pretty'], $eventName));
|
||||||
|
}
|
||||||
|
|
||||||
|
$skipped = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns information about the listener
|
||||||
|
*
|
||||||
|
* @param object $listener The listener
|
||||||
|
* @param string $eventName The event name
|
||||||
|
*
|
||||||
|
* @return array Information about the listener
|
||||||
|
*/
|
||||||
|
private function getListenerInfo($listener, $eventName)
|
||||||
|
{
|
||||||
|
$info = array(
|
||||||
|
'event' => $eventName,
|
||||||
|
);
|
||||||
|
if ($listener instanceof \Closure) {
|
||||||
|
$info += array(
|
||||||
|
'type' => 'Closure',
|
||||||
|
'pretty' => 'closure',
|
||||||
|
);
|
||||||
|
} elseif (is_string($listener)) {
|
||||||
|
try {
|
||||||
|
$r = new \ReflectionFunction($listener);
|
||||||
|
$file = $r->getFileName();
|
||||||
|
$line = $r->getStartLine();
|
||||||
|
} catch (\ReflectionException $e) {
|
||||||
|
$file = null;
|
||||||
|
$line = null;
|
||||||
|
}
|
||||||
|
$info += array(
|
||||||
|
'type' => 'Function',
|
||||||
|
'function' => $listener,
|
||||||
|
'file' => $file,
|
||||||
|
'line' => $line,
|
||||||
|
'pretty' => $listener,
|
||||||
|
);
|
||||||
|
} elseif (is_array($listener) || (is_object($listener) && is_callable($listener))) {
|
||||||
|
if (!is_array($listener)) {
|
||||||
|
$listener = array($listener, '__invoke');
|
||||||
|
}
|
||||||
|
$class = is_object($listener[0]) ? get_class($listener[0]) : $listener[0];
|
||||||
|
try {
|
||||||
|
$r = new \ReflectionMethod($class, $listener[1]);
|
||||||
|
$file = $r->getFileName();
|
||||||
|
$line = $r->getStartLine();
|
||||||
|
} catch (\ReflectionException $e) {
|
||||||
|
$file = null;
|
||||||
|
$line = null;
|
||||||
|
}
|
||||||
|
$info += array(
|
||||||
|
'type' => 'Method',
|
||||||
|
'class' => $class,
|
||||||
|
'method' => $listener[1],
|
||||||
|
'file' => $file,
|
||||||
|
'line' => $line,
|
||||||
|
'pretty' => $class.'::'.$listener[1],
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $info;
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,106 @@
|
|||||||
|
<?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 Symfony\Component\EventDispatcher\DependencyInjection;
|
||||||
|
|
||||||
|
use Symfony\Component\DependencyInjection\ContainerBuilder;
|
||||||
|
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Compiler pass to register tagged services for an event dispatcher.
|
||||||
|
*/
|
||||||
|
class RegisterListenersPass implements CompilerPassInterface
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $dispatcherService;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $listenerTag;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $subscriberTag;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constructor.
|
||||||
|
*
|
||||||
|
* @param string $dispatcherService Service name of the event dispatcher in processed container
|
||||||
|
* @param string $listenerTag Tag name used for listener
|
||||||
|
* @param string $subscriberTag Tag name used for subscribers
|
||||||
|
*/
|
||||||
|
public function __construct($dispatcherService = 'event_dispatcher', $listenerTag = 'kernel.event_listener', $subscriberTag = 'kernel.event_subscriber')
|
||||||
|
{
|
||||||
|
$this->dispatcherService = $dispatcherService;
|
||||||
|
$this->listenerTag = $listenerTag;
|
||||||
|
$this->subscriberTag = $subscriberTag;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function process(ContainerBuilder $container)
|
||||||
|
{
|
||||||
|
if (!$container->hasDefinition($this->dispatcherService) && !$container->hasAlias($this->dispatcherService)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$definition = $container->findDefinition($this->dispatcherService);
|
||||||
|
|
||||||
|
foreach ($container->findTaggedServiceIds($this->listenerTag) as $id => $events) {
|
||||||
|
$def = $container->getDefinition($id);
|
||||||
|
if (!$def->isPublic()) {
|
||||||
|
throw new \InvalidArgumentException(sprintf('The service "%s" must be public as event listeners are lazy-loaded.', $id));
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($def->isAbstract()) {
|
||||||
|
throw new \InvalidArgumentException(sprintf('The service "%s" must not be abstract as event listeners are lazy-loaded.', $id));
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach ($events as $event) {
|
||||||
|
$priority = isset($event['priority']) ? $event['priority'] : 0;
|
||||||
|
|
||||||
|
if (!isset($event['event'])) {
|
||||||
|
throw new \InvalidArgumentException(sprintf('Service "%s" must define the "event" attribute on "%s" tags.', $id, $this->listenerTag));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!isset($event['method'])) {
|
||||||
|
$event['method'] = 'on'.preg_replace_callback(array(
|
||||||
|
'/(?<=\b)[a-z]/i',
|
||||||
|
'/[^a-z0-9]/i',
|
||||||
|
), function ($matches) { return strtoupper($matches[0]); }, $event['event']);
|
||||||
|
$event['method'] = preg_replace('/[^a-z0-9]/i', '', $event['method']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$definition->addMethodCall('addListenerService', array($event['event'], array($id, $event['method']), $priority));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach ($container->findTaggedServiceIds($this->subscriberTag) as $id => $attributes) {
|
||||||
|
$def = $container->getDefinition($id);
|
||||||
|
if (!$def->isPublic()) {
|
||||||
|
throw new \InvalidArgumentException(sprintf('The service "%s" must be public as event subscribers are lazy-loaded.', $id));
|
||||||
|
}
|
||||||
|
|
||||||
|
// We must assume that the class value has been correctly filled, even if the service is created by a factory
|
||||||
|
$class = $def->getClass();
|
||||||
|
|
||||||
|
$refClass = new \ReflectionClass($class);
|
||||||
|
$interface = 'Symfony\Component\EventDispatcher\EventSubscriberInterface';
|
||||||
|
if (!$refClass->implementsInterface($interface)) {
|
||||||
|
throw new \InvalidArgumentException(sprintf('Service "%s" must implement interface "%s".', $id, $interface));
|
||||||
|
}
|
||||||
|
|
||||||
|
$definition->addMethodCall('addSubscriberService', array($id, $class));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,171 @@
|
|||||||
|
<?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 Symfony\Component\EventDispatcher\Tests\Debug;
|
||||||
|
|
||||||
|
use Symfony\Component\EventDispatcher\Debug\TraceableEventDispatcher;
|
||||||
|
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
|
||||||
|
use Symfony\Component\EventDispatcher\EventDispatcher;
|
||||||
|
use Symfony\Component\EventDispatcher\Event;
|
||||||
|
use Symfony\Component\Stopwatch\Stopwatch;
|
||||||
|
|
||||||
|
class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
|
||||||
|
{
|
||||||
|
public function testAddRemoveListener()
|
||||||
|
{
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
|
||||||
|
$tdispatcher->addListener('foo', $listener = function () {; });
|
||||||
|
$listeners = $dispatcher->getListeners('foo');
|
||||||
|
$this->assertCount(1, $listeners);
|
||||||
|
$this->assertSame($listener, $listeners[0]);
|
||||||
|
|
||||||
|
$tdispatcher->removeListener('foo', $listener);
|
||||||
|
$this->assertCount(0, $dispatcher->getListeners('foo'));
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testGetListeners()
|
||||||
|
{
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
|
||||||
|
$tdispatcher->addListener('foo', $listener = function () {; });
|
||||||
|
$this->assertSame($dispatcher->getListeners('foo'), $tdispatcher->getListeners('foo'));
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testHasListeners()
|
||||||
|
{
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
|
||||||
|
$this->assertFalse($dispatcher->hasListeners('foo'));
|
||||||
|
$this->assertFalse($tdispatcher->hasListeners('foo'));
|
||||||
|
|
||||||
|
$tdispatcher->addListener('foo', $listener = function () {; });
|
||||||
|
$this->assertTrue($dispatcher->hasListeners('foo'));
|
||||||
|
$this->assertTrue($tdispatcher->hasListeners('foo'));
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testAddRemoveSubscriber()
|
||||||
|
{
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
|
||||||
|
$subscriber = new EventSubscriber();
|
||||||
|
|
||||||
|
$tdispatcher->addSubscriber($subscriber);
|
||||||
|
$listeners = $dispatcher->getListeners('foo');
|
||||||
|
$this->assertCount(1, $listeners);
|
||||||
|
$this->assertSame(array($subscriber, 'call'), $listeners[0]);
|
||||||
|
|
||||||
|
$tdispatcher->removeSubscriber($subscriber);
|
||||||
|
$this->assertCount(0, $dispatcher->getListeners('foo'));
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testGetCalledListeners()
|
||||||
|
{
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
$tdispatcher->addListener('foo', $listener = function () {; });
|
||||||
|
|
||||||
|
$this->assertEquals(array(), $tdispatcher->getCalledListeners());
|
||||||
|
$this->assertEquals(array('foo.closure' => array('event' => 'foo', 'type' => 'Closure', 'pretty' => 'closure')), $tdispatcher->getNotCalledListeners());
|
||||||
|
|
||||||
|
$tdispatcher->dispatch('foo');
|
||||||
|
|
||||||
|
$this->assertEquals(array('foo.closure' => array('event' => 'foo', 'type' => 'Closure', 'pretty' => 'closure')), $tdispatcher->getCalledListeners());
|
||||||
|
$this->assertEquals(array(), $tdispatcher->getNotCalledListeners());
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testLogger()
|
||||||
|
{
|
||||||
|
$logger = $this->getMock('Psr\Log\LoggerInterface');
|
||||||
|
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger);
|
||||||
|
$tdispatcher->addListener('foo', $listener1 = function () {; });
|
||||||
|
$tdispatcher->addListener('foo', $listener2 = function () {; });
|
||||||
|
|
||||||
|
$logger->expects($this->at(0))->method('debug')->with("Notified event \"foo\" to listener \"closure\".");
|
||||||
|
$logger->expects($this->at(1))->method('debug')->with("Notified event \"foo\" to listener \"closure\".");
|
||||||
|
|
||||||
|
$tdispatcher->dispatch('foo');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testLoggerWithStoppedEvent()
|
||||||
|
{
|
||||||
|
$logger = $this->getMock('Psr\Log\LoggerInterface');
|
||||||
|
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger);
|
||||||
|
$tdispatcher->addListener('foo', $listener1 = function (Event $event) { $event->stopPropagation(); });
|
||||||
|
$tdispatcher->addListener('foo', $listener2 = function () {; });
|
||||||
|
|
||||||
|
$logger->expects($this->at(0))->method('debug')->with("Notified event \"foo\" to listener \"closure\".");
|
||||||
|
$logger->expects($this->at(1))->method('debug')->with("Listener \"closure\" stopped propagation of the event \"foo\".");
|
||||||
|
$logger->expects($this->at(2))->method('debug')->with("Listener \"closure\" was not called for event \"foo\".");
|
||||||
|
|
||||||
|
$tdispatcher->dispatch('foo');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testDispatchCallListeners()
|
||||||
|
{
|
||||||
|
$called = array();
|
||||||
|
|
||||||
|
$dispatcher = new EventDispatcher();
|
||||||
|
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
|
||||||
|
$tdispatcher->addListener('foo', $listener1 = function () use (&$called) { $called[] = 'foo1'; });
|
||||||
|
$tdispatcher->addListener('foo', $listener2 = function () use (&$called) { $called[] = 'foo2'; });
|
||||||
|
|
||||||
|
$tdispatcher->dispatch('foo');
|
||||||
|
|
||||||
|
$this->assertEquals(array('foo1', 'foo2'), $called);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testDispatchNested()
|
||||||
|
{
|
||||||
|
$dispatcher = new TraceableEventDispatcher(new EventDispatcher(), new Stopwatch());
|
||||||
|
$loop = 1;
|
||||||
|
$dispatcher->addListener('foo', $listener1 = function () use ($dispatcher, &$loop) {
|
||||||
|
++$loop;
|
||||||
|
if (2 == $loop) {
|
||||||
|
$dispatcher->dispatch('foo');
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
$dispatcher->dispatch('foo');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testDispatchReusedEventNested()
|
||||||
|
{
|
||||||
|
$nestedCall = false;
|
||||||
|
$dispatcher = new TraceableEventDispatcher(new EventDispatcher(), new Stopwatch());
|
||||||
|
$dispatcher->addListener('foo', function (Event $e) use ($dispatcher) {
|
||||||
|
$dispatcher->dispatch('bar', $e);
|
||||||
|
});
|
||||||
|
$dispatcher->addListener('bar', function (Event $e) use (&$nestedCall) {
|
||||||
|
$nestedCall = true;
|
||||||
|
});
|
||||||
|
|
||||||
|
$this->assertFalse($nestedCall);
|
||||||
|
$dispatcher->dispatch('foo');
|
||||||
|
$this->assertTrue($nestedCall);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
class EventSubscriber implements EventSubscriberInterface
|
||||||
|
{
|
||||||
|
public static function getSubscribedEvents()
|
||||||
|
{
|
||||||
|
return array('foo' => 'call');
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,148 @@
|
|||||||
|
<?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 Symfony\Component\EventDispatcher\Tests\DependencyInjection;
|
||||||
|
|
||||||
|
use Symfony\Component\DependencyInjection\ContainerBuilder;
|
||||||
|
use Symfony\Component\EventDispatcher\DependencyInjection\RegisterListenersPass;
|
||||||
|
|
||||||
|
class RegisterListenersPassTest extends \PHPUnit_Framework_TestCase
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* Tests that event subscribers not implementing EventSubscriberInterface
|
||||||
|
* trigger an exception.
|
||||||
|
*
|
||||||
|
* @expectedException \InvalidArgumentException
|
||||||
|
*/
|
||||||
|
public function testEventSubscriberWithoutInterface()
|
||||||
|
{
|
||||||
|
// one service, not implementing any interface
|
||||||
|
$services = array(
|
||||||
|
'my_event_subscriber' => array(0 => array()),
|
||||||
|
);
|
||||||
|
|
||||||
|
$definition = $this->getMock('Symfony\Component\DependencyInjection\Definition');
|
||||||
|
$definition->expects($this->atLeastOnce())
|
||||||
|
->method('isPublic')
|
||||||
|
->will($this->returnValue(true));
|
||||||
|
$definition->expects($this->atLeastOnce())
|
||||||
|
->method('getClass')
|
||||||
|
->will($this->returnValue('stdClass'));
|
||||||
|
|
||||||
|
$builder = $this->getMock(
|
||||||
|
'Symfony\Component\DependencyInjection\ContainerBuilder',
|
||||||
|
array('hasDefinition', 'findTaggedServiceIds', 'getDefinition')
|
||||||
|
);
|
||||||
|
$builder->expects($this->any())
|
||||||
|
->method('hasDefinition')
|
||||||
|
->will($this->returnValue(true));
|
||||||
|
|
||||||
|
// We don't test kernel.event_listener here
|
||||||
|
$builder->expects($this->atLeastOnce())
|
||||||
|
->method('findTaggedServiceIds')
|
||||||
|
->will($this->onConsecutiveCalls(array(), $services));
|
||||||
|
|
||||||
|
$builder->expects($this->atLeastOnce())
|
||||||
|
->method('getDefinition')
|
||||||
|
->will($this->returnValue($definition));
|
||||||
|
|
||||||
|
$registerListenersPass = new RegisterListenersPass();
|
||||||
|
$registerListenersPass->process($builder);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function testValidEventSubscriber()
|
||||||
|
{
|
||||||
|
$services = array(
|
||||||
|
'my_event_subscriber' => array(0 => array()),
|
||||||
|
);
|
||||||
|
|
||||||
|
$definition = $this->getMock('Symfony\Component\DependencyInjection\Definition');
|
||||||
|
$definition->expects($this->atLeastOnce())
|
||||||
|
->method('isPublic')
|
||||||
|
->will($this->returnValue(true));
|
||||||
|
$definition->expects($this->atLeastOnce())
|
||||||
|
->method('getClass')
|
||||||
|
->will($this->returnValue('Symfony\Component\EventDispatcher\Tests\DependencyInjection\SubscriberService'));
|
||||||
|
|
||||||
|
$builder = $this->getMock(
|
||||||
|
'Symfony\Component\DependencyInjection\ContainerBuilder',
|
||||||
|
array('hasDefinition', 'findTaggedServiceIds', 'getDefinition', 'findDefinition')
|
||||||
|
);
|
||||||
|
$builder->expects($this->any())
|
||||||
|
->method('hasDefinition')
|
||||||
|
->will($this->returnValue(true));
|
||||||
|
|
||||||
|
// We don't test kernel.event_listener here
|
||||||
|
$builder->expects($this->atLeastOnce())
|
||||||
|
->method('findTaggedServiceIds')
|
||||||
|
->will($this->onConsecutiveCalls(array(), $services));
|
||||||
|
|
||||||
|
$builder->expects($this->atLeastOnce())
|
||||||
|
->method('getDefinition')
|
||||||
|
->will($this->returnValue($definition));
|
||||||
|
|
||||||
|
$builder->expects($this->atLeastOnce())
|
||||||
|
->method('findDefinition')
|
||||||
|
->will($this->returnValue($definition));
|
||||||
|
|
||||||
|
$registerListenersPass = new RegisterListenersPass();
|
||||||
|
$registerListenersPass->process($builder);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @expectedException \InvalidArgumentException
|
||||||
|
* @expectedExceptionMessage The service "foo" must be public as event listeners are lazy-loaded.
|
||||||
|
*/
|
||||||
|
public function testPrivateEventListener()
|
||||||
|
{
|
||||||
|
$container = new ContainerBuilder();
|
||||||
|
$container->register('foo', 'stdClass')->setPublic(false)->addTag('kernel.event_listener', array());
|
||||||
|
$container->register('event_dispatcher', 'stdClass');
|
||||||
|
|
||||||
|
$registerListenersPass = new RegisterListenersPass();
|
||||||
|
$registerListenersPass->process($container);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @expectedException \InvalidArgumentException
|
||||||
|
* @expectedExceptionMessage The service "foo" must be public as event subscribers are lazy-loaded.
|
||||||
|
*/
|
||||||
|
public function testPrivateEventSubscriber()
|
||||||
|
{
|
||||||
|
$container = new ContainerBuilder();
|
||||||
|
$container->register('foo', 'stdClass')->setPublic(false)->addTag('kernel.event_subscriber', array());
|
||||||
|
$container->register('event_dispatcher', 'stdClass');
|
||||||
|
|
||||||
|
$registerListenersPass = new RegisterListenersPass();
|
||||||
|
$registerListenersPass->process($container);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @expectedException \InvalidArgumentException
|
||||||
|
* @expectedExceptionMessage The service "foo" must not be abstract as event listeners are lazy-loaded.
|
||||||
|
*/
|
||||||
|
public function testAbstractEventListener()
|
||||||
|
{
|
||||||
|
$container = new ContainerBuilder();
|
||||||
|
$container->register('foo', 'stdClass')->setAbstract(true)->addTag('kernel.event_listener', array());
|
||||||
|
$container->register('event_dispatcher', 'stdClass');
|
||||||
|
|
||||||
|
$registerListenersPass = new RegisterListenersPass();
|
||||||
|
$registerListenersPass->process($container);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
class SubscriberService implements \Symfony\Component\EventDispatcher\EventSubscriberInterface
|
||||||
|
{
|
||||||
|
public static function getSubscribedEvents()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user