OwlCyberSecurity - MANAGER
Edit File: SubscribersStatsReport.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 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 ) { parent::__construct(); $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::now()->millisecond(0); // 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)); } }