ErrorEmittingDispatcherTest.php

<?php
/**
 * @see       https://github.com/phly/phly-event-dispatcher for the canonical source repository
 * @copyright Copyright (c) 2019 Matthew Weier O'Phinney (https:/mwop.net)
 * @license   https://github.com/phly/phly-event-dispatcher/blob/master/LICENSE.md New BSD License
 */

declare(strict_types=1);

namespace PhlyTest\EventDispatcher;

use Phly\EventDispatcher\ErrorEmittingDispatcher;
use Phly\EventDispatcher\ErrorEvent;
use PHPUnit\Framework\TestCase;
use Prophecy\Argument;
use Prophecy\PhpUnit\ProphecyTrait;
use Prophecy\Prophecy\ObjectProphecy;
use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\EventDispatcher\ListenerProviderInterface;
use RuntimeException;

class ErrorEmittingDispatcherTest extends TestCase
{
    use ProphecyTrait;
    use CommonDispatcherTests;

    public function setUp(): void
    {
        $this->provider = $this->prophesize(ListenerProviderInterface::class);
        $this->dispatcher = new ErrorEmittingDispatcher($this->provider->reveal());
    }

    public function getDispatcher() : EventDispatcherInterface
    {
        return $this->dispatcher;
    }

    public function getListenerProvider() : ObjectProphecy
    {
        return $this->provider;
    }

    public function testDispatchesErrorEventIfAListenerRaisesAnExceptionAndThenReThrows(): void
    {
        $event                = new TestAsset\TestEvent();
        $exception            = new RuntimeException('TRIGGERED');
        $errorRaisingListener = function (TestAsset\TestEvent $event) use ($exception): void {
            throw $exception;
        };

        $errorSpy      = (object) ['caught' => 0];
        $errorListener = function (ErrorEvent $e) use ($errorSpy, $exception, $event, $errorRaisingListener): void {
            TestCase::assertSame($event, $e->getEvent());
            TestCase::assertSame($errorRaisingListener, $e->getListener());
            TestCase::assertSame($exception, $e->getThrowable());
            $errorSpy->caught += 1;
        };

        $this->provider
            ->getListenersForEvent($event)
            ->willReturn([$errorRaisingListener])
            ->shouldBeCalledTimes(1);

        $this->provider
            ->getListenersForEvent(Argument::type(ErrorEvent::class))
            ->willReturn([$errorListener])
            ->shouldBeCalledTimes(1);

        $this->expectException(RuntimeException::class);
        $this->expectExceptionMessage('TRIGGERED');
        $this->dispatcher->dispatch($event);
    }
}