Add cron worker for inactive subscribers

[MAILPOET-1791]
2019-04-16 15:07:08 +02:00
parent 7b433a4273
commit 7eb0e23d22
2 changed files with 132 additions and 0 deletions
--- a/tests/integration/Cron/Workers/InactiveSubscribersTest.php
+++ b/tests/integration/Cron/Workers/InactiveSubscribersTest.php
@ -0,0 +1,85 @@
+<?php
+namespace MailPoet\Test\Cron\Workers;
+
+use Carbon\Carbon;
+use Codeception\Stub;
+use MailPoet\Cron\CronHelper;
+use MailPoet\Cron\Workers\InactiveSubscribers;
+use MailPoet\Models\ScheduledTask;
+use MailPoet\Settings\SettingsController;
+use MailPoet\Subscribers\InactiveSubscribersController;
+
+class InactiveSubscribersTest extends \MailPoetTest {
+
+  /** @var SettingsController */
+  private $settings;
+
+  function _before() {
+    $this->settings = new SettingsController();
+    \ORM::raw_execute('TRUNCATE ' . ScheduledTask::$_table);
+    parent::_before();
+  }
+
+  function testItSchedulesNextRunWhenThereIsNothingToDo() {
+    $this->settings->set('deactivate_subscriber_after_inactive_days', 0);
+    $controller_mock = Stub::make(InactiveSubscribersController::class, [
+      'markInactiveSubscribers' => Stub\Expected::never(),
+      'markActiveSubscribers' => Stub\Expected::never(),
+    ], $this);
+
+    $worker = new InactiveSubscribers($controller_mock, $this->settings);
+    $worker->processTaskStrategy(ScheduledTask::createOrUpdate([]));
+
+    $task = ScheduledTask::where('type', InactiveSubscribers::TASK_TYPE)
+      ->where('status', ScheduledTask::STATUS_SCHEDULED)
+      ->findOne();
+
+    expect($task)->isInstanceOf(ScheduledTask::class);
+    expect($task->scheduled_at)->greaterThan(new Carbon());
+  }
+
+  function testItSchedulesNextRunWhenFinished() {
+    $this->settings->set('deactivate_subscriber_after_inactive_days', 5);
+    $controller_mock = Stub::make(InactiveSubscribersController::class, [
+      'markInactiveSubscribers' => Stub\Expected::once(1),
+      'markActiveSubscribers' => Stub\Expected::once(1),
+    ], $this);
+
+    $worker = new InactiveSubscribers($controller_mock, $this->settings);
+    $worker->processTaskStrategy(ScheduledTask::createOrUpdate([]));
+
+    $task = ScheduledTask::where('type', InactiveSubscribers::TASK_TYPE)
+      ->where('status', ScheduledTask::STATUS_SCHEDULED)
+      ->findOne();
+
+    expect($task)->isInstanceOf(ScheduledTask::class);
+    expect($task->scheduled_at)->greaterThan(new Carbon());
+  }
+
+  function testRunBatchesUntilItIsFinished() {
+    $this->settings->set('deactivate_subscriber_after_inactive_days', 5);
+    $controller_mock = Stub::make(InactiveSubscribersController::class, [
+      'markInactiveSubscribers' => Stub::consecutive(InactiveSubscribers::BATCH_SIZE, InactiveSubscribers::BATCH_SIZE, 1, 'ok'),
+      'markActiveSubscribers' => Stub::consecutive(InactiveSubscribers::BATCH_SIZE, 1, 'ok'),
+    ], $this);
+
+    $worker = new InactiveSubscribers($controller_mock, $this->settings);
+    $worker->processTaskStrategy(ScheduledTask::createOrUpdate([]));
+
+    expect($controller_mock->markInactiveSubscribers(5, 1000))->equals('ok');
+    expect($controller_mock->markActiveSubscribers(5, 1000))->equals('ok');
+  }
+
+  function testThrowsAnExceptionWhenTimeIsOut() {
+    $this->settings->set('deactivate_subscriber_after_inactive_days', 5);
+    $controller_mock = Stub::make(InactiveSubscribersController::class, [
+      'markInactiveSubscribers' => Stub\Expected::once(InactiveSubscribers::BATCH_SIZE),
+      'markActiveSubscribers' => Stub\Expected::never(),
+    ], $this);
+
+    $worker = new InactiveSubscribers($controller_mock, $this->settings, microtime(true) - (CronHelper::DAEMON_EXECUTION_LIMIT - 1));
+    sleep(1);
+    $this->setExpectedException(\Exception::class, 'Maximum execution time has been reached.');
+    $worker->processTaskStrategy(ScheduledTask::createOrUpdate([]));
+  }
+}