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

mailpoet / lib / Cron / Daemon.php

mailpoet / lib / Cron Last commit date

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

Daemon.php

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