Charsets.php
3 years ago
Hosts.php
2 months ago
Pages.php
9 months ago
SettingsChangeHandler.php
2 weeks ago
SettingsController.php
4 days ago
SettingsRepository.php
1 year ago
TrackingConfig.php
5 months ago
UserFlagsController.php
1 year ago
UserFlagsRepository.php
3 years ago
index.php
3 years ago
SettingsChangeHandler.php
141 lines
| 1 | <?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing |
| 2 | |
| 3 | namespace MailPoet\Settings; |
| 4 | |
| 5 | if (!defined('ABSPATH')) exit; |
| 6 | |
| 7 | |
| 8 | use MailPoet\Cron\CronWorkerScheduler; |
| 9 | use MailPoet\Cron\Workers\InactiveSubscribersMaintenance; |
| 10 | use MailPoet\Cron\Workers\UnconfirmedSubscribersCleanup; |
| 11 | use MailPoet\Cron\Workers\WooCommerceSync; |
| 12 | use MailPoet\Entities\ScheduledTaskEntity; |
| 13 | use MailPoet\Mailer\Mailer; |
| 14 | use MailPoet\Newsletter\Sending\ScheduledTasksRepository; |
| 15 | use MailPoet\Services\Bridge; |
| 16 | use MailPoet\Services\SubscribersCountReporter; |
| 17 | use MailPoetVendor\Carbon\Carbon; |
| 18 | |
| 19 | class SettingsChangeHandler { |
| 20 | |
| 21 | /** @var ScheduledTasksRepository */ |
| 22 | private $scheduledTasksRepository; |
| 23 | |
| 24 | /** @var SettingsController */ |
| 25 | private $settingsController; |
| 26 | |
| 27 | /** @var Bridge */ |
| 28 | private $bridge; |
| 29 | |
| 30 | /** @var SubscribersCountReporter */ |
| 31 | private $subscribersCountReporter; |
| 32 | |
| 33 | /** @var CronWorkerScheduler */ |
| 34 | private $cronWorkerScheduler; |
| 35 | |
| 36 | public function __construct( |
| 37 | ScheduledTasksRepository $scheduledTasksRepository, |
| 38 | SettingsController $settingsController, |
| 39 | Bridge $bridge, |
| 40 | SubscribersCountReporter $subscribersCountReporter, |
| 41 | CronWorkerScheduler $cronWorkerScheduler |
| 42 | ) { |
| 43 | $this->scheduledTasksRepository = $scheduledTasksRepository; |
| 44 | $this->settingsController = $settingsController; |
| 45 | $this->bridge = $bridge; |
| 46 | $this->subscribersCountReporter = $subscribersCountReporter; |
| 47 | $this->cronWorkerScheduler = $cronWorkerScheduler; |
| 48 | } |
| 49 | |
| 50 | public function onSubscribeOldWoocommerceCustomersChange(): void { |
| 51 | $task = $this->scheduledTasksRepository->findOneBy([ |
| 52 | 'type' => WooCommerceSync::TASK_TYPE, |
| 53 | 'status' => ScheduledTaskEntity::STATUS_SCHEDULED, |
| 54 | 'deletedAt' => null, |
| 55 | ], ['createdAt' => 'DESC']); |
| 56 | if (!($task instanceof ScheduledTaskEntity)) { |
| 57 | $task = $this->createScheduledTask(WooCommerceSync::TASK_TYPE); |
| 58 | } |
| 59 | $datetime = Carbon::now()->millisecond(0); |
| 60 | $task->setScheduledAt($datetime->subMinute()); |
| 61 | $this->scheduledTasksRepository->persist($task); |
| 62 | $this->scheduledTasksRepository->flush(); |
| 63 | } |
| 64 | |
| 65 | public function onInactiveSubscribersIntervalChange(): void { |
| 66 | // Start a clean pass from subscriber 0 with the new interval: remove any pending run |
| 67 | // (scheduled or in-progress) instead of resuming one that was partway through the old interval. |
| 68 | $pendingTasks = array_merge( |
| 69 | $this->scheduledTasksRepository->findBy([ |
| 70 | 'type' => InactiveSubscribersMaintenance::TASK_TYPE, |
| 71 | 'status' => ScheduledTaskEntity::STATUS_SCHEDULED, |
| 72 | 'deletedAt' => null, |
| 73 | ]), |
| 74 | $this->scheduledTasksRepository->findBy([ |
| 75 | 'type' => InactiveSubscribersMaintenance::TASK_TYPE, |
| 76 | 'status' => null, |
| 77 | 'deletedAt' => null, |
| 78 | ]) |
| 79 | ); |
| 80 | $pendingTaskIds = array_map(function(ScheduledTaskEntity $task): int { |
| 81 | return (int)$task->getId(); |
| 82 | }, $pendingTasks); |
| 83 | if ($pendingTaskIds) { |
| 84 | $this->scheduledTasksRepository->deleteByIds($pendingTaskIds); |
| 85 | } |
| 86 | |
| 87 | $task = $this->createScheduledTask(InactiveSubscribersMaintenance::TASK_TYPE); |
| 88 | $task->setScheduledAt(Carbon::now()->millisecond(0)->subMinute()); |
| 89 | $this->scheduledTasksRepository->persist($task); |
| 90 | $this->scheduledTasksRepository->flush(); |
| 91 | } |
| 92 | |
| 93 | public function onUnconfirmedSubscribersCleanupEnable(): void { |
| 94 | $this->cronWorkerScheduler->scheduleImmediatelyIfNotRunning(UnconfirmedSubscribersCleanup::TASK_TYPE); |
| 95 | } |
| 96 | |
| 97 | public function onMSSActivate($newSettings) { |
| 98 | // see mailpoet/assets/js/src/wizard/create_sender_settings.jsx:freeAddress |
| 99 | $httpHost = isset($_SERVER['HTTP_HOST']) && is_string($_SERVER['HTTP_HOST']) ? sanitize_text_field(wp_unslash($_SERVER['HTTP_HOST'])) : ''; |
| 100 | $domain = str_replace('www.', '', $httpHost); |
| 101 | if ( |
| 102 | isset($newSettings['sender']['address']) |
| 103 | && !empty($newSettings['reply_to']['address']) |
| 104 | && ($newSettings['sender']['address'] === ('wordpress@' . $domain)) |
| 105 | ) { |
| 106 | $sender = [ |
| 107 | 'name' => $newSettings['reply_to']['name'] ?? '', |
| 108 | 'address' => $newSettings['reply_to']['address'], |
| 109 | ]; |
| 110 | $this->settingsController->set('sender', $sender); |
| 111 | $this->settingsController->set('reply_to', null); |
| 112 | } |
| 113 | } |
| 114 | |
| 115 | private function createScheduledTask(string $type): ScheduledTaskEntity { |
| 116 | $task = new ScheduledTaskEntity(); |
| 117 | $task->setType($type); |
| 118 | $task->setStatus(ScheduledTaskEntity::STATUS_SCHEDULED); |
| 119 | return $task; |
| 120 | } |
| 121 | |
| 122 | public function updateApiKeyState($settings) { |
| 123 | $apiKey = $settings[Mailer::MAILER_CONFIG_SETTING_NAME]['mailpoet_api_key'] ?? null; |
| 124 | $premiumKey = $settings['premium']['premium_key'] ?? null; |
| 125 | if (!empty($apiKey)) { |
| 126 | $apiKeyState = $this->bridge->checkMSSKey($apiKey); |
| 127 | $this->bridge->storeMSSKeyAndState($apiKey, $apiKeyState); |
| 128 | } |
| 129 | if (!empty($premiumKey)) { |
| 130 | $premiumState = $this->bridge->checkPremiumKey($premiumKey); |
| 131 | $this->bridge->storePremiumKeyAndState($premiumKey, $premiumState); |
| 132 | } |
| 133 | if ($apiKey && !empty($apiKeyState) && in_array($apiKeyState['state'], [Bridge::KEY_VALID, Bridge::KEY_VALID_UNDERPRIVILEGED], true)) { |
| 134 | return $this->subscribersCountReporter->report($apiKey); |
| 135 | } |
| 136 | if ($premiumKey && !empty($premiumState) && in_array($premiumState['state'], [Bridge::KEY_VALID, Bridge::KEY_VALID_UNDERPRIVILEGED], true)) { |
| 137 | return $this->subscribersCountReporter->report($premiumKey); |
| 138 | } |
| 139 | } |
| 140 | } |
| 141 |