app/bundles/CampaignBundle/Tests/Functional/Entity/LeadEventLogRepositoryTest.php

<?php

declare(strict_types=1);

namespace Mautic\CampaignBundle\Tests\Functional\Entity;

use Mautic\CampaignBundle\Entity\LeadEventLog;
use Mautic\CampaignBundle\Entity\LeadEventLogRepository;
use Mautic\CoreBundle\Test\MauticMysqlTestCase;
use PHPUnit\Framework\Assert;

class LeadEventLogRepositoryTest extends MauticMysqlTestCase
{
    public function testThatRemoveEventLogsMethodRemovesLogs(): void
    {
        $eventId    = random_int(200, 2000);
        $connection = $this->em->getConnection();

        $leadEventLogRepository = $this->em->getRepository(LeadEventLog::class);
        \assert($leadEventLogRepository instanceof LeadEventLogRepository);

        $insertStatement = $connection->prepare('INSERT INTO `'.MAUTIC_TABLE_PREFIX.'campaign_lead_event_log` (`event_id`, `lead_id`, `rotation`, `is_scheduled`, `system_triggered`) VALUES (?, ?, ?, ?, ?);');

        $connection->executeQuery('SET FOREIGN_KEY_CHECKS=0;');
        foreach ($this->getLeadCampaignEventData($eventId) as $row) {
            $insertStatement->executeQuery($row);
        }
        $connection->executeQuery('SET FOREIGN_KEY_CHECKS=1;');

        Assert::assertCount(3, $leadEventLogRepository->findAll());

        $leadEventLogRepository->removeEventLogs([(string) $eventId]);

        Assert::assertCount(0, $leadEventLogRepository->findAll());
    }

    private function getLeadCampaignEventData(int $eventId): array
    {
        return [
            [$eventId, 100, 200, 1, 1],
            [$eventId, 101, 201, 1, 1],
            [$eventId, 102, 202, 1, 1],
        ];
    }
}