Make limit parameter optional
Unification function parameters with a similar method from the repository. [MAILPOET-4367]
This commit is contained in:
@@ -239,7 +239,7 @@ class ScheduledTasksRepository extends Repository {
|
||||
/**
|
||||
* @return ScheduledTaskEntity[]
|
||||
*/
|
||||
public function findScheduledSendingTasks(int $limit): array {
|
||||
public function findScheduledSendingTasks(?int $limit = null): array {
|
||||
$now = Carbon::createFromTimestamp($this->wp->currentTime('timestamp'));
|
||||
return $this->doctrineRepository->createQueryBuilder('st')
|
||||
->select('st')
|
||||
|
@@ -198,7 +198,7 @@ class ScheduledTasksRepositoryTest extends \MailPoetTest {
|
||||
$task = $this->scheduledTaskFactory->create(SendingQueueWorker::TASK_TYPE, ScheduledTaskEntity::STATUS_SCHEDULED, Carbon::now()->addDay());
|
||||
$this->sendingQueueFactory->create($task);
|
||||
|
||||
$tasks = $this->repository->findScheduledSendingTasks(5);
|
||||
$tasks = $this->repository->findScheduledSendingTasks();
|
||||
$this->assertSame($expectedResult, $tasks);
|
||||
}
|
||||
|
||||
|
@@ -157,7 +157,7 @@ class SendingTest extends \MailPoetTest {
|
||||
$this->sending->status = ScheduledTask::STATUS_SCHEDULED;
|
||||
$this->sending->scheduled_at = Carbon::createFromTimestamp(WPFunctions::get()->currentTime('timestamp'))->subHours(1);
|
||||
$this->sending->save();
|
||||
$tasks = $this->scheduledTaskRepository->findScheduledSendingTasks(5);
|
||||
$tasks = $this->scheduledTaskRepository->findScheduledSendingTasks();
|
||||
expect($tasks)->notEmpty();
|
||||
foreach ($tasks as $task) {
|
||||
expect($task)->isInstanceOf(ScheduledTaskEntity::class);
|
||||
@@ -181,7 +181,7 @@ class SendingTest extends \MailPoetTest {
|
||||
public function testItDoesNotGetPaused() {
|
||||
$this->_after();
|
||||
$this->createNewSendingTask(['status' => ScheduledTask::STATUS_PAUSED]);
|
||||
expect($this->scheduledTaskRepository->findScheduledSendingTasks(5))->count(0);
|
||||
expect($this->scheduledTaskRepository->findScheduledSendingTasks())->count(0);
|
||||
}
|
||||
|
||||
public function testItGetsRunningQueues() {
|
||||
|
Reference in New Issue
Block a user