TMV\Laminas\Messenger\Test\Subscriber\DoctrineClearEntityManagerWorkerSubscriberTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

<?php

class DoctrineClearEntityManagerWorkerSubscriberTest extends TestCase
{
    use ProphecyTrait;

    public function testSubscribedEvents(): void
    {
        $managerRegistry = $this->prophesize(ManagerRegistry::class);
        $subscriber = new DoctrineClearEntityManagerWorkerSubscriber($managerRegistry->reveal());

        $events = [];
        foreach (DoctrineClearEntityManagerWorkerSubscriber::getSubscribedEvents() as $key => $value) {
            $events[$key] = $value;
            $this->assertIsCallable([$subscriber, $value]);
        }

        $this->assertSame([
            WorkerMessageHandledEvent::class => 'onWorkerMessageHandled',
            WorkerMessageFailedEvent::class => 'onWorkerMessageFailed',
        ], $events);
    }

    public function testOnWorkerMessageHandled(): void
    {
        $entityManager = $this->prophesize(EntityManagerInterface::class);
        $managerRegistry = $this->prophesize(ManagerRegistry::class);

        $managerRegistry->getManagers()->willReturn([$entityManager->reveal()]);
        $entityManager->clear()->shouldBeCalled();

        $subscriber = new DoctrineClearEntityManagerWorkerSubscriber($managerRegistry->reveal());
        $subscriber->onWorkerMessageHandled();
    }

    public function testOnWorkerMessageFailed(): void
    {
        $entityManager = $this->prophesize(EntityManagerInterface::class);
        $managerRegistry = $this->prophesize(ManagerRegistry::class);

        $managerRegistry->getManagers()->willReturn([$entityManager->reveal()]);
        $entityManager->clear()->shouldBeCalled();

        $subscriber = new DoctrineClearEntityManagerWorkerSubscriber($managerRegistry->reveal());
        $subscriber->onWorkerMessageFailed();