72 lines
2.5 KiB
PHP
72 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace MailPoet\Test\Cron\Workers;
|
|
|
|
use Codeception\Stub;
|
|
use MailPoet\Cron\CronHelper;
|
|
use MailPoet\Cron\Workers\SimpleWorkerMockImplementation as MockSimpleWorker;
|
|
use MailPoet\DI\ContainerWrapper;
|
|
use MailPoet\Models\ScheduledTask;
|
|
use MailPoet\Settings\SettingsRepository;
|
|
use MailPoet\WP\Functions as WPFunctions;
|
|
use MailPoetVendor\Carbon\Carbon;
|
|
use MailPoetVendor\Idiorm\ORM;
|
|
|
|
require_once __DIR__ . '/SimpleWorkerMockImplementation.php';
|
|
|
|
class SimpleWorkerTest extends \MailPoetTest {
|
|
public $worker;
|
|
public $cron_helper;
|
|
public function _before() {
|
|
parent::_before();
|
|
$this->cron_helper = ContainerWrapper::getInstance()->get(CronHelper::class);
|
|
$this->worker = new MockSimpleWorker();
|
|
}
|
|
|
|
public function testItRequiresTaskTypeToConstruct() {
|
|
$worker = Stub::make(
|
|
'MailPoet\Cron\Workers\SimpleWorker',
|
|
[],
|
|
$this
|
|
);
|
|
$worker_class = get_class($worker);
|
|
try {
|
|
new $worker_class();
|
|
$this->fail('SimpleWorker did not throw an exception');
|
|
} catch (\Exception $e) {
|
|
expect($e->getMessage())->equals('Constant TASK_TYPE is not defined on subclass ' . $worker_class);
|
|
}
|
|
}
|
|
|
|
public function testItSchedulesTask() {
|
|
expect(ScheduledTask::where('type', MockSimpleWorker::TASK_TYPE)->findMany())->isEmpty();
|
|
(new MockSimpleWorker())->schedule();
|
|
expect(ScheduledTask::where('type', MockSimpleWorker::TASK_TYPE)->findMany())->notEmpty();
|
|
}
|
|
|
|
public function testItDoesNotScheduleTaskTwice() {
|
|
$worker = new MockSimpleWorker();
|
|
expect(count(ScheduledTask::where('type', MockSimpleWorker::TASK_TYPE)->findMany()))->equals(0);
|
|
$worker->schedule();
|
|
expect(count(ScheduledTask::where('type', MockSimpleWorker::TASK_TYPE)->findMany()))->equals(1);
|
|
$worker->schedule();
|
|
expect(count(ScheduledTask::where('type', MockSimpleWorker::TASK_TYPE)->findMany()))->equals(1);
|
|
}
|
|
|
|
public function testItCalculatesNextRunDateWithinNextWeekBoundaries() {
|
|
$current_date = Carbon::createFromTimestamp(WPFunctions::get()->currentTime('timestamp'));
|
|
/** @var Carbon $next_run_date */
|
|
$next_run_date = (new MockSimpleWorker())->getNextRunDate();
|
|
$difference = $next_run_date->diffInDays($current_date);
|
|
// Subtract days left in the current week
|
|
$difference -= (Carbon::DAYS_PER_WEEK - (int)$current_date->format('N'));
|
|
expect($difference)->lessOrEquals(7);
|
|
expect($difference)->greaterOrEquals(0);
|
|
}
|
|
|
|
public function _after() {
|
|
$this->di_container->get(SettingsRepository::class)->truncate();
|
|
ORM::raw_execute('TRUNCATE ' . ScheduledTask::$_table);
|
|
}
|
|
}
|