66 lines
1.9 KiB
PHP
66 lines
1.9 KiB
PHP
|
<?php declare(strict_types = 1);
|
||
|
|
|
||
|
|
namespace MailPoet\Cron\Workers;
|
||
|
|
|
||
|
|
if (!defined('ABSPATH')) exit;
|
||
|
|
|
||
|
|
|
||
|
|
use MailPoet\Config\ServicesChecker;
|
||
|
|
use MailPoet\Cron\CronWorkerScheduler;
|
||
|
|
use MailPoet\Entities\ScheduledTaskEntity;
|
||
|
|
use MailPoet\Services\SubscribersCountReporter;
|
||
|
|
use MailPoet\WP\Functions as WPFunctions;
|
||
|
|
use MailPoetVendor\Carbon\Carbon;
|
||
|
|
|
||
|
|
class SubscribersStatsReport extends SimpleWorker {
|
||
|
|
const TASK_TYPE = 'subscribers_stats_report';
|
||
|
|
|
||
|
|
/** @var SubscribersCountReporter */
|
||
|
|
private $subscribersCountReporter;
|
||
|
|
|
||
|
|
/** @var ServicesChecker */
|
||
|
|
private $serviceChecker;
|
||
|
|
|
||
|
|
/** @var CronWorkerScheduler */
|
||
|
|
private $workerScheduler;
|
||
|
|
|
||
|
|
public function __construct(
|
||
|
|
SubscribersCountReporter $subscribersCountReporter,
|
||
|
|
ServicesChecker $servicesChecker,
|
||
|
|
CronWorkerScheduler $workerScheduler,
|
||
|
|
WPFunctions $wp
|
||
|
|
) {
|
||
|
|
parent::__construct($wp);
|
||
|
|
$this->subscribersCountReporter = $subscribersCountReporter;
|
||
|
|
$this->serviceChecker = $servicesChecker;
|
||
|
|
$this->workerScheduler = $workerScheduler;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function checkProcessingRequirements() {
|
||
|
|
return (bool)$this->serviceChecker->getValidAccountKey();
|
||
|
|
}
|
||
|
|
|
||
|
|
public function processTaskStrategy(ScheduledTaskEntity $task, $timer): bool {
|
||
|
|
$key = $this->serviceChecker->getValidAccountKey();
|
||
|
|
if ($key === null) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
$result = $this->subscribersCountReporter->report($key);
|
||
|
|
// We have a valid key, but request failed
|
||
|
|
if ($result === false) {
|
||
|
|
$this->workerScheduler->rescheduleProgressively($task);
|
||
|
|
}
|
||
|
|
return $result;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function getNextRunDate() {
|
||
|
|
$date = Carbon::createFromTimestamp($this->wp->currentTime('timestamp'));
|
||
|
|
// Spread the check within 6 hours after midnight so that all plugins don't ping the service at the same time
|
||
|
|
return $date->startOfDay()
|
||
|
|
->addDay()
|
||
|
|
->addHours(rand(0, 5))
|
||
|
|
->addMinutes(rand(0, 59))
|
||
|
|
->addSeconds(rand(0, 59));
|
||
|
|
}
|
||
|
|
}
|