Files
piratepoet/lib/Cron/CronTrigger.php
2016-08-05 13:03:31 -04:00

70 lines
2.1 KiB
PHP

<?php
namespace MailPoet\Cron;
use MailPoet\Cron\Workers\Scheduler as SchedulerWorker;
use MailPoet\Cron\Workers\SendingQueue\SendingQueue as SendingQueueWorker;
use MailPoet\Mailer\MailerLog;
use MailPoet\Models\Setting;
if(!defined('ABSPATH')) exit;
class CronTrigger {
const METHOD_WORDPRESS = 'WordPress';
const METHOD_MAILPOET = 'MailPoet';
const SETTING_NAME = 'cron_trigger';
function __construct() {
$this->method = self::getCurrentMethod();
}
function init() {
try {
// configure task scheduler only outside of cli environment
if(php_sapi_name() === 'cli') return;
switch($this->method) {
case self::METHOD_MAILPOET:
return $this->configureMailpoetTrigger();
case self::METHOD_WORDPRESS:
return $this->configureWordpressTrigger();
default:
throw new \Exception(__('Task scheduler is not configured'));
};
} catch(\Exception $e) {
// ignore exceptions as they should not prevent the rest of the site from loading
}
}
function configureMailpoetTrigger() {
$supervisor = new Supervisor();
$supervisor->checkDaemon();
}
function configureWordpressTrigger() {
$scheduled_queues = SchedulerWorker::getScheduledQueues();
$running_queues = SendingQueueWorker::getRunningQueues();
$sending_limit_reached = MailerLog::isSendingLimitReached();
// run cron only when:
// 1) there are scheduled queues ready to be processed
// 2) queues are already being processed
// 3) sending limit has not been reached
if(($scheduled_queues || $running_queues) && !$sending_limit_reached) {
return $this->configureMailpoetTrigger();
}
// in all other cases stop (delete) the daemon
$cron_daemon = CronHelper::getDaemon();
if($cron_daemon) {
CronHelper::deleteDaemon();
}
}
static function getAvailableMethods() {
return array(
'mailpoet' => self::METHOD_MAILPOET,
'wordpress' => self::METHOD_WORDPRESS
);
}
static function getCurrentMethod() {
return Setting::getValue('cron_trigger.method');
}
}