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

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testSubscribedEvents()	0	16	2
A	testOnWorkerMessageHandled()	0	11	1
A	testOnWorkerMessageFailed()	0	11	1

<?php

declare(strict_types=1);

namespace TMV\Laminas\Messenger\Test\Subscriber;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\Persistence\ManagerRegistry;
use PHPUnit\Framework\TestCase;
use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
use TMV\Laminas\Messenger\Subscriber\DoctrineClearEntityManagerWorkerSubscriber;

class DoctrineClearEntityManagerWorkerSubscriberTest extends TestCase
{
    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();
    }
}