Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Extend integration test

Browse Source 
[MAILPOET-4366]
This commit is contained in:
Jan Lysý
2022-08-09 13:01:31 +02:00
committed by Veljko V
parent a841671695
commit a39b73041c
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
mailpoet/tests/integration/Newsletter/Sending/ScheduledTasksRepositoryTest.php
View File

@@ -4,6 +4,7 @@ namespace MailPoet\Newsletter\Sending;
use MailPoet\Entities\ScheduledTaskEntity; use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Test\DataFactories\ScheduledTask as ScheduledTaskFactory; use MailPoet\Test\DataFactories\ScheduledTask as ScheduledTaskFactory;
use MailPoet\Test\DataFactories\SendingQueue;
use MailPoetVendor\Carbon\Carbon; use MailPoetVendor\Carbon\Carbon;
class ScheduledTasksRepositoryTest extends \MailPoetTest { class ScheduledTasksRepositoryTest extends \MailPoetTest {
@@ -13,11 +14,15 @@ class ScheduledTasksRepositoryTest extends \MailPoetTest {
/** @var ScheduledTaskFactory */ /** @var ScheduledTaskFactory */
private $scheduledTaskFactory; private $scheduledTaskFactory;
/** @var SendingQueue */
private $sendingQueueFactory;
public function _before() { public function _before() {
parent::_before(); parent::_before();
$this->cleanup(); $this->cleanup();
$this->repository = $this->diContainer->get(ScheduledTasksRepository::class); $this->repository = $this->diContainer->get(ScheduledTasksRepository::class);
$this->scheduledTaskFactory = new ScheduledTaskFactory(); $this->scheduledTaskFactory = new ScheduledTaskFactory();
$this->sendingQueueFactory = new SendingQueue();
} }
public function testItCanGetDueTasks() { public function testItCanGetDueTasks() {
@@ -63,6 +68,28 @@ class ScheduledTasksRepositoryTest extends \MailPoetTest {
$this->assertSame($expectedResult, $tasks); $this->assertSame($expectedResult, $tasks);
} }
public function testItCanGetRunningSendingTasks(): void {
// running task
$task = $this->scheduledTaskFactory->create(ScheduledTaskEntity::TYPE_SENDING, null, Carbon::now()->subDay());
$this->sendingQueueFactory->create($task);
$expectedResult[] = $task;
// deleted task
$task = $this->scheduledTaskFactory->create(ScheduledTaskEntity::TYPE_SENDING, null, Carbon::now()->subDay(), Carbon::now());
$this->sendingQueueFactory->create($task);
// deleted sending queue
$task = $this->scheduledTaskFactory->create(ScheduledTaskEntity::TYPE_SENDING, null, Carbon::now()->subDay());
$this->sendingQueueFactory->create($task, null, Carbon::now());
// scheduled in future
$task = $this->scheduledTaskFactory->create(ScheduledTaskEntity::TYPE_SENDING, ScheduledTaskEntity::STATUS_COMPLETED, Carbon::now()->addDay());
$this->sendingQueueFactory->create($task);
// wrong status
$task = $this->scheduledTaskFactory->create(ScheduledTaskEntity::TYPE_SENDING, ScheduledTaskEntity::STATUS_SCHEDULED, Carbon::now()->subDay());
$this->sendingQueueFactory->create($task);
$tasks = $this->repository->findRunningSendingTasks();
$this->assertSame($expectedResult, $tasks);
}
public function cleanup() { public function cleanup() {
$this->truncateEntity(ScheduledTaskEntity::class); $this->truncateEntity(ScheduledTaskEntity::class);
} }