Daemon.php — MailPoet – Newsletters, Email Marketing, and Automation 5.37.0

mailpoet / lib / Cron / Daemon.php

mailpoet / lib / Cron Last commit date

ActionScheduler 1 week ago CliCommands 2 months ago Triggers 3 months ago Workers 2 days ago CronHelper.php 3 months ago CronTrigger.php 2 years ago CronWorkerInterface.php 3 years ago CronWorkerRunner.php 3 months ago CronWorkerScheduler.php 11 months ago Daemon.php 2 days ago DaemonActionSchedulerRunner.php 1 week ago DaemonHttpRunner.php 3 months ago Supervisor.php 3 years ago index.php 3 years ago

Daemon.php

138 lines

1	<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing
2
3	namespace MailPoet\Cron;
4
5	if (!defined('ABSPATH')) exit;
6
7
8	use MailPoet\Cron\Workers\WorkersFactory;
9	use MailPoet\Logging\LoggerFactory;
10	use MailPoet\Mailer\SendingLimitReachedException;
11	use MailPoet\Util\Helpers;
12	use MailPoetVendor\Doctrine\ORM\EntityManager;
13
14	class Daemon {
15	public $timer;
16
17	/** @var CronHelper */
18	private $cronHelper;
19
20	/** @var CronWorkerRunner */
21	private $cronWorkerRunner;
22
23	/** @var EntityManager */
24	private $entityManager;
25
26	/** @var WorkersFactory */
27	private $workersFactory;
28
29	/** @var LoggerFactory */
30	private $loggerFactory;
31
32	public function __construct(
33	CronHelper $cronHelper,
34	CronWorkerRunner $cronWorkerRunner,
35	EntityManager $entityManager,
36	WorkersFactory $workersFactory,
37	LoggerFactory $loggerFactory
38	) {
39	$this->timer = microtime(true);
40	$this->workersFactory = $workersFactory;
41	$this->cronWorkerRunner = $cronWorkerRunner;
42	$this->entityManager = $entityManager;
43	$this->cronHelper = $cronHelper;
44	$this->loggerFactory = $loggerFactory;
45	}
46
47	public function run($settingsDaemonData) {
48	$settingsDaemonData['run_started_at'] = time();
49	$this->cronHelper->saveDaemon($settingsDaemonData);
50
51	$errors = [];
52	foreach ($this->getWorkers() as $worker) {
53	if (wp_is_maintenance_mode()) {
54	// stop execution when in maintenance mode
55	break;
56	}
57
58	try {
59	// Clear the entity manager memory for every cron run.
60	// This avoids using stale data and prevents memory leaks.
61	$this->entityManager->clear();
62
63	if ($worker instanceof CronWorkerInterface) {
64	$this->cronWorkerRunner->run($worker);
65	} else {
66	$worker->process($this->timer); // BC for workers not implementing CronWorkerInterface
67	}
68	} catch (\Exception $e) {
69	Helpers::mySqlGoneAwayExceptionHandler($e);
70
71	$workerClass = is_object($worker) ? get_class($worker) : '';
72	$workerClassNameParts = explode('\\', $workerClass);
73	$workerName = end($workerClassNameParts);
74
75	// Expected sending state, not an error — sending resumes once the frequency interval passes.
76	if ($e instanceof SendingLimitReachedException) {
77	$this->loggerFactory->getLogger(LoggerFactory::TOPIC_CRON)->info($e->getMessage(), ['worker' => $workerName]);
78	continue;
79	}
80
81	$errors[] = [
82	'worker' => $workerName,
83	'message' => $e->getMessage(),
84	];
85
86	if ($e->getCode() === CronHelper::DAEMON_EXECUTION_LIMIT_REACHED) {
87	break;
88	}
89
90	$this->loggerFactory->getLogger(LoggerFactory::TOPIC_CRON)->error($e->getMessage(), ['error' => $e, 'worker' => $workerName]);
91	}
92	}
93
94	if (!empty($errors)) {
95	$this->cronHelper->saveDaemonLastError($errors);
96	}
97
98	// Log successful execution
99	$this->cronHelper->saveDaemonRunCompleted(time());
100	}
101
102	private function getWorkers() {
103	yield $this->workersFactory->createStatsNotificationsWorker(); // not CronWorkerInterface compatible
104	yield $this->workersFactory->createScheduleWorker(); // not CronWorkerInterface compatible
105	yield $this->workersFactory->createQueueWorker(); // not CronWorkerInterface compatible
106	yield $this->workersFactory->createSendingServiceKeyCheckWorker();
107	yield $this->workersFactory->createPremiumKeyCheckWorker();
108	yield $this->workersFactory->createSubscribersStatsReportWorker();
109	yield $this->workersFactory->createBounceWorker();
110	yield $this->workersFactory->createExportFilesCleanupWorker();
111	yield $this->workersFactory->createLogCleanupWorker();
112	yield $this->workersFactory->createSendingTaskSubscribersCleanupWorker();
113	yield $this->workersFactory->createBounceTaskSubscribersCleanupWorker();
114	yield $this->workersFactory->createSendingQueueBodyCleanupWorker();
115	yield $this->workersFactory->createInactiveSubscribersMaintenanceWorker();
116	yield $this->workersFactory->createUnconfirmedSubscribersCleanupWorker();
117	yield $this->workersFactory->createUnsubscribeTokensWorker();
118	yield $this->workersFactory->createWooCommerceSyncWorker();
119	yield $this->workersFactory->createAuthorizedSendingEmailsCheckWorker();
120	yield $this->workersFactory->createWooCommercePastOrdersWorker();
121	yield $this->workersFactory->createStatsNotificationsWorkerForAutomatedEmails();
122	yield $this->workersFactory->createSubscriberLinkTokensWorker();
123	yield $this->workersFactory->createSubscribersLastEngagementWorker();
124	yield $this->workersFactory->createSubscribersCountCacheRecalculationWorker();
125	yield $this->workersFactory->createReEngagementEmailsSchedulerWorker();
126	yield $this->workersFactory->createNewsletterTemplateThumbnailsWorker();
127	yield $this->workersFactory->createAbandonedCartWorker();
128	yield $this->workersFactory->createBackfillEngagementDataWorker();
129	yield $this->workersFactory->createSubscribersSegmentsCountSyncWorker();
130	yield $this->workersFactory->createMixpanelWorker();
131	yield $this->workersFactory->createTracksWorker();
132	yield $this->workersFactory->createStatisticsExportWorker();
133	yield $this->workersFactory->createBulkConfirmationEmailResendWorker();
134	yield $this->workersFactory->createSubscriberLimitNotificationWorker();
135	yield $this->workersFactory->createSubscribersEngagementScoreWorker();
136	}
137	}
138