[EventDispatcher] added EventDispatcher::getListenerPriority()

This commit is contained in:
Fabien Potencier 2015-10-11 10:30:48 +02:00
parent 45b2382f46
commit 068e9559d0
11 changed files with 127 additions and 118 deletions

View File

@ -294,27 +294,21 @@ class JsonDescriptor extends Descriptor
{ {
$data = array(); $data = array();
$registeredListeners = $eventDispatcher->getListeners($event, true); $registeredListeners = $eventDispatcher->getListeners($event);
if (null !== $event) { if (null !== $event) {
krsort($registeredListeners); foreach ($registeredListeners as $listener) {
foreach ($registeredListeners as $priority => $listeners) { $l = $this->getCallableData($listener);
foreach ($listeners as $listener) { $l['priority'] = $eventDispatcher->getListenerPriority($event, $listener);
$listener = $this->getCallableData($listener); $data[] = $l;
$listener['priority'] = $priority;
$data[] = $listener;
}
} }
} else { } else {
ksort($registeredListeners); ksort($registeredListeners);
foreach ($registeredListeners as $eventListened => $eventListeners) { foreach ($registeredListeners as $eventListened => $eventListeners) {
krsort($eventListeners); foreach ($eventListeners as $eventListener) {
foreach ($eventListeners as $priority => $listeners) { $l = $this->getCallableData($eventListener);
foreach ($listeners as $listener) { $l['priority'] = $eventDispatcher->getListenerPriority($eventListened, $eventListener);
$listener = $this->getCallableData($listener); $data[$eventListened][] = $l;
$listener['priority'] = $priority;
$data[$eventListened][] = $listener;
}
} }
} }
} }

View File

@ -273,30 +273,23 @@ class MarkdownDescriptor extends Descriptor
$this->write(sprintf('# %s', $title)."\n"); $this->write(sprintf('# %s', $title)."\n");
$registeredListeners = $eventDispatcher->getListeners($event, true); $registeredListeners = $eventDispatcher->getListeners($event);
if (null !== $event) { if (null !== $event) {
krsort($registeredListeners); foreach ($registeredListeners as $order => $listener) {
$order = 1; $this->write("\n".sprintf('## Listener %d', $order + 1)."\n");
foreach ($registeredListeners as $priority => $listeners) { $this->describeCallable($listener);
foreach ($listeners as $listener) { $this->write(sprintf('- Priority: `%d`', $eventDispatcher->getListenerPriority($event, $listener))."\n");
$this->write("\n".sprintf('## Listener %d', $order++)."\n");
$this->describeCallable($listener);
$this->write(sprintf('- Priority: `%d`', $priority)."\n");
}
} }
} else { } else {
ksort($registeredListeners); ksort($registeredListeners);
foreach ($registeredListeners as $eventListened => $eventListeners) { foreach ($registeredListeners as $eventListened => $eventListeners) {
$this->write("\n".sprintf('## %s', $eventListened)."\n"); $this->write("\n".sprintf('## %s', $eventListened)."\n");
krsort($eventListeners);
$order = 1; foreach ($eventListeners as $order => $eventListener) {
foreach ($eventListeners as $priority => $listeners) { $this->write("\n".sprintf('### Listener %d', $order + 1)."\n");
foreach ($listeners as $listener) { $this->describeCallable($eventListener);
$this->write("\n".sprintf('### Listener %d', $order++)."\n"); $this->write(sprintf('- Priority: `%d`', $eventDispatcher->getListenerPriority($eventListened, $eventListener))."\n");
$this->describeCallable($listener);
$this->write(sprintf('- Priority: `%d`', $priority)."\n");
}
} }
} }
} }

View File

@ -358,15 +358,14 @@ class TextDescriptor extends Descriptor
$options['output']->title($title); $options['output']->title($title);
$registeredListeners = $eventDispatcher->getListeners($event, true); $registeredListeners = $eventDispatcher->getListeners($event);
if (null !== $event) { if (null !== $event) {
$this->renderEventListenerTable($registeredListeners, $options['output']); $this->renderEventListenerTable($eventDispatcher, $event, $registeredListeners, $options['output']);
} else { } else {
ksort($registeredListeners); ksort($registeredListeners);
foreach ($registeredListeners as $eventListened => $eventListeners) { foreach ($registeredListeners as $eventListened => $eventListeners) {
$options['output']->section(sprintf('"%s" event', $eventListened)); $options['output']->section(sprintf('"%s" event', $eventListened));
$this->renderEventListenerTable($eventListeners, $options['output']); $this->renderEventListenerTable($eventDispatcher, $eventListened, $eventListeners, $options['output']);
} }
} }
} }
@ -382,17 +381,14 @@ class TextDescriptor extends Descriptor
/** /**
* @param array $array * @param array $array
*/ */
private function renderEventListenerTable(array $eventListeners, SymfonyStyle $renderer) private function renderEventListenerTable(EventDispatcherInterface $eventDispatcher, $event, array $eventListeners, SymfonyStyle $renderer)
{ {
$tableHeaders = array('Order', 'Callable', 'Priority'); $tableHeaders = array('Order', 'Callable', 'Priority');
$tableRows = array(); $tableRows = array();
krsort($eventListeners);
$order = 1; $order = 1;
foreach ($eventListeners as $priority => $listeners) { foreach ($eventListeners as $order => $listener) {
foreach ($listeners as $listener) { $tableRows[] = array(sprintf('#%d', $order + 1), $this->formatCallable($listener), $eventDispatcher->getListenerPriority($event, $listener));
$tableRows[] = array(sprintf('#%d', $order++), $this->formatCallable($listener), $priority);
}
} }
$renderer->table($tableHeaders, $tableRows); $renderer->table($tableHeaders, $tableRows);

View File

@ -449,9 +449,9 @@ class XmlDescriptor extends Descriptor
$dom = new \DOMDocument('1.0', 'UTF-8'); $dom = new \DOMDocument('1.0', 'UTF-8');
$dom->appendChild($eventDispatcherXML = $dom->createElement('event-dispatcher')); $dom->appendChild($eventDispatcherXML = $dom->createElement('event-dispatcher'));
$registeredListeners = $eventDispatcher->getListeners($event, true); $registeredListeners = $eventDispatcher->getListeners($event);
if (null !== $event) { if (null !== $event) {
$this->appendEventListenerDocument($eventDispatcherXML, $registeredListeners); $this->appendEventListenerDocument($eventDispatcher, $event, $eventDispatcherXML, $registeredListeners);
} else { } else {
ksort($registeredListeners); ksort($registeredListeners);
@ -459,7 +459,7 @@ class XmlDescriptor extends Descriptor
$eventDispatcherXML->appendChild($eventXML = $dom->createElement('event')); $eventDispatcherXML->appendChild($eventXML = $dom->createElement('event'));
$eventXML->setAttribute('name', $eventListened); $eventXML->setAttribute('name', $eventListened);
$this->appendEventListenerDocument($eventXML, $eventListeners); $this->appendEventListenerDocument($eventDispatcher, $eventListened, $eventXML, $eventListeners);
} }
} }
@ -470,16 +470,13 @@ class XmlDescriptor extends Descriptor
* @param \DOMElement $element * @param \DOMElement $element
* @param array $eventListeners * @param array $eventListeners
*/ */
private function appendEventListenerDocument(\DOMElement $element, array $eventListeners) private function appendEventListenerDocument(EventDispatcherInterface $eventDispatcher, $event, \DOMElement $element, array $eventListeners)
{ {
krsort($eventListeners); foreach ($eventListeners as $listener) {
foreach ($eventListeners as $priority => $listeners) { $callableXML = $this->getCallableDocument($listener);
foreach ($listeners as $listener) { $callableXML->childNodes->item(0)->setAttribute('priority', $eventDispatcher->getListenerPriority($event, $listener));
$callableXML = $this->getCallableDocument($listener);
$callableXML->childNodes->item(0)->setAttribute('priority', $priority);
$element->appendChild($element->ownerDocument->importNode($callableXML->childNodes->item(0), true)); $element->appendChild($element->ownerDocument->importNode($callableXML->childNodes->item(0), true));
}
} }
} }

View File

@ -17,6 +17,7 @@
], ],
"require": { "require": {
"php": ">=5.3.9", "php": ">=5.3.9",
"symfony/event-dispatcher": "~2.8|~3.0.0",
"symfony/security": "~2.8|~3.0.0", "symfony/security": "~2.8|~3.0.0",
"symfony/security-acl": "~2.7|~3.0.0", "symfony/security-acl": "~2.7|~3.0.0",
"symfony/http-kernel": "~2.2|~3.0.0" "symfony/http-kernel": "~2.2|~3.0.0"

View File

@ -118,7 +118,7 @@ class ContainerAwareEventDispatcher extends EventDispatcher
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
public function getListeners($eventName = null, $withPriorities = false) public function getListeners($eventName = null)
{ {
if (null === $eventName) { if (null === $eventName) {
foreach ($this->listenerIds as $serviceEventName => $args) { foreach ($this->listenerIds as $serviceEventName => $args) {
@ -128,7 +128,17 @@ class ContainerAwareEventDispatcher extends EventDispatcher
$this->lazyLoad($eventName); $this->lazyLoad($eventName);
} }
return parent::getListeners($eventName, $withPriorities); return parent::getListeners($eventName);
}
/**
* {@inheritdoc}
*/
public function getListenerPriority($eventName, $listener)
{
$this->lazyLoad($eventName);
return parent::getListenerPriority($eventName, $listener);
} }
/** /**

View File

@ -94,9 +94,17 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
public function getListeners($eventName = null, $withPriorities = false) public function getListeners($eventName = null)
{ {
return $this->dispatcher->getListeners($eventName, $withPriorities); return $this->dispatcher->getListeners($eventName);
}
/**
* {@inheritdoc}
*/
public function getListenerPriority($eventName, $listener)
{
return $this->dispatcher->getListenerPriority($eventName, $listener);
} }
/** /**
@ -141,8 +149,7 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
$called = array(); $called = array();
foreach ($this->called as $eventName => $listeners) { foreach ($this->called as $eventName => $listeners) {
foreach ($listeners as $listener) { foreach ($listeners as $listener) {
$priority = $this->getListenerPriority($eventName, $listener); $info = $this->getListenerInfo($listener->getWrappedListener(), $eventName);
$info = $this->getListenerInfo($listener->getWrappedListener(), $eventName, $priority);
$called[$eventName.'.'.$info['pretty']] = $info; $called[$eventName.'.'.$info['pretty']] = $info;
} }
} }
@ -156,7 +163,7 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
public function getNotCalledListeners() public function getNotCalledListeners()
{ {
try { try {
$allListeners = $this->getListeners(null, true); $allListeners = $this->getListeners();
} catch (\Exception $e) { } catch (\Exception $e) {
if (null !== $this->logger) { if (null !== $this->logger) {
$this->logger->info('An exception was thrown while getting the uncalled listeners.', array('exception' => $e)); $this->logger->info('An exception was thrown while getting the uncalled listeners.', array('exception' => $e));
@ -167,24 +174,22 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
} }
$notCalled = array(); $notCalled = array();
foreach ($allListeners as $eventName => $priorities) { foreach ($allListeners as $eventName => $listeners) {
foreach ($priorities as $priority => $listeners) { foreach ($listeners as $listener) {
foreach ($listeners as $listener) { $called = false;
$called = false; if (isset($this->called[$eventName])) {
if (isset($this->called[$eventName])) { foreach ($this->called[$eventName] as $l) {
foreach ($this->called[$eventName] as $l) { if ($l->getWrappedListener() === $listener) {
if ($l->getWrappedListener() === $listener) { $called = true;
$called = true;
break; break;
}
} }
} }
}
if (!$called) { if (!$called) {
$info = $this->getListenerInfo($listener, $eventName, $priority); $info = $this->getListenerInfo($listener, $eventName);
$notCalled[$eventName.'.'.$info['pretty']] = $info; $notCalled[$eventName.'.'.$info['pretty']] = $info;
}
} }
} }
} }
@ -286,11 +291,11 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
* *
* @return array Information about the listener * @return array Information about the listener
*/ */
private function getListenerInfo($listener, $eventName, $priority = null) private function getListenerInfo($listener, $eventName)
{ {
$info = array( $info = array(
'event' => $eventName, 'event' => $eventName,
'priority' => $priority, 'priority' => $this->getListenerPriority($eventName, $listener),
); );
if ($listener instanceof \Closure) { if ($listener instanceof \Closure) {
$info += array( $info += array(
@ -339,28 +344,6 @@ class TraceableEventDispatcher implements TraceableEventDispatcherInterface
return $info; return $info;
} }
private function getListenerPriority($eventName, $listenerConfig)
{
try {
$allListeners = $this->getListeners(null, true);
} catch (\Exception $e) {
if (null !== $this->logger) {
$this->logger->info('An exception was thrown while getting the listeners.', array('exception' => $e));
}
return;
}
$listenerWrapper = $listenerConfig->getWrappedListener();
foreach ($allListeners[$eventName] as $priority => $listeners) {
foreach ($listeners as $listener) {
if (is_array($listenerWrapper) && $listenerWrapper[0] === $listener[0]) {
return $priority;
}
}
}
}
private function sortListenersByPriority($a, $b) private function sortListenersByPriority($a, $b)
{ {
if (is_int($a['priority']) && !is_int($b['priority'])) { if (is_int($a['priority']) && !is_int($b['priority'])) {

View File

@ -52,16 +52,8 @@ class EventDispatcher implements EventDispatcherInterface
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
public function getListeners($eventName = null, $withPriorities = false) public function getListeners($eventName = null)
{ {
if (true === $withPriorities) {
if (null !== $eventName) {
return isset($this->listeners[$eventName]) ? $this->listeners[$eventName] : array();
}
return array_filter($this->listeners);
}
if (null !== $eventName) { if (null !== $eventName) {
if (!isset($this->listeners[$eventName])) { if (!isset($this->listeners[$eventName])) {
return array(); return array();
@ -83,6 +75,29 @@ class EventDispatcher implements EventDispatcherInterface
return array_filter($this->sorted); return array_filter($this->sorted);
} }
/**
* Gets the listener priority for a specific event.
*
* Returns null if the event or the listener does not exist.
*
* @param string $eventName The name of the event
* @param callable $listener The listener to remove
*
* @return int|null The event listener priority
*/
public function getListenerPriority($eventName, $listener)
{
if (!isset($this->listeners[$eventName])) {
return;
}
foreach ($this->listeners[$eventName] as $priority => $listeners) {
if (false !== ($key = array_search($listener, $listeners, true))) {
return $priority;
}
}
}
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
@ -177,8 +192,6 @@ class EventDispatcher implements EventDispatcherInterface
*/ */
private function sortListeners($eventName) private function sortListeners($eventName)
{ {
$this->sorted[$eventName] = array();
krsort($this->listeners[$eventName]); krsort($this->listeners[$eventName]);
$this->sorted[$eventName] = call_user_func_array('array_merge', $this->listeners[$eventName]); $this->sorted[$eventName] = call_user_func_array('array_merge', $this->listeners[$eventName]);
} }

View File

@ -78,9 +78,17 @@ class ImmutableEventDispatcher implements EventDispatcherInterface
/** /**
* {@inheritdoc} * {@inheritdoc}
*/ */
public function getListeners($eventName = null, $withPriorities = false) public function getListeners($eventName = null)
{ {
return $this->dispatcher->getListeners($eventName, $withPriorities); return $this->dispatcher->getListeners($eventName);
}
/**
* {@inheritdoc}
*/
public function getListenerPriority($eventName, $listener)
{
return $this->dispatcher->getListenerPriority($eventName, $listener);
} }
/** /**

View File

@ -108,6 +108,20 @@ abstract class AbstractEventDispatcherTest extends \PHPUnit_Framework_TestCase
$this->assertSame($expected, $this->dispatcher->getListeners()); $this->assertSame($expected, $this->dispatcher->getListeners());
} }
public function testGetListenerPriority()
{
$listener1 = new TestEventListener();
$listener2 = new TestEventListener();
$this->dispatcher->addListener('pre.foo', $listener1, -10);
$this->dispatcher->addListener('pre.foo', $listener2);
$this->assertSame(-10, $this->dispatcher->getListenerPriority('pre.foo', $listener1));
$this->assertSame(0, $this->dispatcher->getListenerPriority('pre.foo', $listener2));
$this->assertNull($this->dispatcher->getListenerPriority('pre.bar', $listener2));
$this->assertNull($this->dispatcher->getListenerPriority('pre.foo', function () {}));
}
public function testDispatch() public function testDispatch()
{ {
$this->dispatcher->addListener('pre.foo', array($this->listener, 'preFoo')); $this->dispatcher->addListener('pre.foo', array($this->listener, 'preFoo'));

View File

@ -25,7 +25,7 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
$dispatcher = new EventDispatcher(); $dispatcher = new EventDispatcher();
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch()); $tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
$tdispatcher->addListener('foo', $listener = function () {; }); $tdispatcher->addListener('foo', $listener = function () {});
$listeners = $dispatcher->getListeners('foo'); $listeners = $dispatcher->getListeners('foo');
$this->assertCount(1, $listeners); $this->assertCount(1, $listeners);
$this->assertSame($listener, $listeners[0]); $this->assertSame($listener, $listeners[0]);
@ -39,7 +39,7 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
$dispatcher = new EventDispatcher(); $dispatcher = new EventDispatcher();
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch()); $tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
$tdispatcher->addListener('foo', $listener = function () {; }); $tdispatcher->addListener('foo', $listener = function () {});
$this->assertSame($dispatcher->getListeners('foo'), $tdispatcher->getListeners('foo')); $this->assertSame($dispatcher->getListeners('foo'), $tdispatcher->getListeners('foo'));
} }
@ -51,7 +51,7 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
$this->assertFalse($dispatcher->hasListeners('foo')); $this->assertFalse($dispatcher->hasListeners('foo'));
$this->assertFalse($tdispatcher->hasListeners('foo')); $this->assertFalse($tdispatcher->hasListeners('foo'));
$tdispatcher->addListener('foo', $listener = function () {; }); $tdispatcher->addListener('foo', $listener = function () {});
$this->assertTrue($dispatcher->hasListeners('foo')); $this->assertTrue($dispatcher->hasListeners('foo'));
$this->assertTrue($tdispatcher->hasListeners('foo')); $this->assertTrue($tdispatcher->hasListeners('foo'));
} }
@ -76,7 +76,7 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
{ {
$dispatcher = new EventDispatcher(); $dispatcher = new EventDispatcher();
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch()); $tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch());
$tdispatcher->addListener('foo', $listener = function () {; }); $tdispatcher->addListener('foo', $listener = function () {});
$this->assertEquals(array(), $tdispatcher->getCalledListeners()); $this->assertEquals(array(), $tdispatcher->getCalledListeners());
$this->assertEquals(array('foo.closure' => array('event' => 'foo', 'type' => 'Closure', 'pretty' => 'closure', 'priority' => 0)), $tdispatcher->getNotCalledListeners()); $this->assertEquals(array('foo.closure' => array('event' => 'foo', 'type' => 'Closure', 'pretty' => 'closure', 'priority' => 0)), $tdispatcher->getNotCalledListeners());
@ -107,8 +107,8 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
$dispatcher = new EventDispatcher(); $dispatcher = new EventDispatcher();
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger); $tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger);
$tdispatcher->addListener('foo', $listener1 = function () {; }); $tdispatcher->addListener('foo', $listener1 = function () {});
$tdispatcher->addListener('foo', $listener2 = function () {; }); $tdispatcher->addListener('foo', $listener2 = function () {});
$logger->expects($this->at(0))->method('debug')->with('Notified event "foo" to listener "closure".'); $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".'); $logger->expects($this->at(1))->method('debug')->with('Notified event "foo" to listener "closure".');
@ -123,7 +123,7 @@ class TraceableEventDispatcherTest extends \PHPUnit_Framework_TestCase
$dispatcher = new EventDispatcher(); $dispatcher = new EventDispatcher();
$tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger); $tdispatcher = new TraceableEventDispatcher($dispatcher, new Stopwatch(), $logger);
$tdispatcher->addListener('foo', $listener1 = function (Event $event) { $event->stopPropagation(); }); $tdispatcher->addListener('foo', $listener1 = function (Event $event) { $event->stopPropagation(); });
$tdispatcher->addListener('foo', $listener2 = function () {; }); $tdispatcher->addListener('foo', $listener2 = function () {});
$logger->expects($this->at(0))->method('debug')->with('Notified event "foo" to listener "closure".'); $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(1))->method('debug')->with('Listener "closure" stopped propagation of the event "foo".');