DataInconsistencyController.php
2 days ago
DataInconsistencyRepository.php
2 days ago
index.php
2 years ago
DataInconsistencyController.php
88 lines
| 1 | <?php declare(strict_types = 1); |
| 2 | |
| 3 | namespace MailPoet\Util\DataInconsistency; |
| 4 | |
| 5 | if (!defined('ABSPATH')) exit; |
| 6 | |
| 7 | |
| 8 | use MailPoet\UnexpectedValueException; |
| 9 | |
| 10 | class DataInconsistencyController { |
| 11 | const ORPHANED_SENDING_TASKS = 'orphaned_sending_tasks'; |
| 12 | const ORPHANED_SENDING_TASK_SUBSCRIBERS = 'orphaned_sending_task_subscribers'; |
| 13 | const SENDING_QUEUE_WITHOUT_NEWSLETTER = 'sending_queue_without_newsletter'; |
| 14 | const ORPHANED_SUBSCRIPTIONS = 'orphaned_subscriptions'; |
| 15 | const ORPHANED_SUBSCRIBER_CUSTOM_FIELDS = 'orphaned_subscriber_custom_fields'; |
| 16 | const ORPHANED_SUBSCRIBER_TAGS = 'orphaned_subscriber_tags'; |
| 17 | const ORPHANED_LINKS = 'orphaned_links'; |
| 18 | const ORPHANED_NEWSLETTER_POSTS = 'orphaned_newsletter_posts'; |
| 19 | const SENDING_QUEUE_WITHOUT_TASK = 'sending_queue_without_task'; |
| 20 | |
| 21 | const SUPPORTED_INCONSISTENCY_CHECKS = [ |
| 22 | self::ORPHANED_SENDING_TASKS, |
| 23 | self::ORPHANED_SENDING_TASK_SUBSCRIBERS, |
| 24 | self::SENDING_QUEUE_WITHOUT_NEWSLETTER, |
| 25 | self::ORPHANED_SUBSCRIPTIONS, |
| 26 | self::ORPHANED_SUBSCRIBER_CUSTOM_FIELDS, |
| 27 | self::ORPHANED_SUBSCRIBER_TAGS, |
| 28 | self::ORPHANED_LINKS, |
| 29 | self::ORPHANED_NEWSLETTER_POSTS, |
| 30 | ]; |
| 31 | |
| 32 | private DataInconsistencyRepository $repository; |
| 33 | |
| 34 | public function __construct( |
| 35 | DataInconsistencyRepository $repository |
| 36 | ) { |
| 37 | $this->repository = $repository; |
| 38 | } |
| 39 | |
| 40 | public function getInconsistentDataStatus(): array { |
| 41 | $result = [ |
| 42 | self::ORPHANED_SENDING_TASKS => $this->repository->getOrphanedSendingTasksCount(), |
| 43 | self::ORPHANED_SENDING_TASK_SUBSCRIBERS => $this->repository->getOrphanedScheduledTasksSubscribersCount(), |
| 44 | self::SENDING_QUEUE_WITHOUT_NEWSLETTER => $this->repository->getSendingQueuesWithoutNewsletterCount(), |
| 45 | self::ORPHANED_SUBSCRIPTIONS => $this->repository->getOrphanedSubscriptionsCount(), |
| 46 | self::ORPHANED_SUBSCRIBER_CUSTOM_FIELDS => $this->repository->getOrphanedSubscriberCustomFieldsCount(), |
| 47 | self::ORPHANED_SUBSCRIBER_TAGS => $this->repository->getOrphanedSubscriberTagsCount(), |
| 48 | self::ORPHANED_LINKS => $this->repository->getOrphanedNewsletterLinksCount(), |
| 49 | self::ORPHANED_NEWSLETTER_POSTS => $this->repository->getOrphanedNewsletterPostsCount(), |
| 50 | ]; |
| 51 | $result['total'] = array_sum($result); |
| 52 | return $result; |
| 53 | } |
| 54 | |
| 55 | /** |
| 56 | * Damage that is worth reporting but has no safe automatic fix, so it is kept out of |
| 57 | * getInconsistentDataStatus() and the "Fix" actions built from it. |
| 58 | */ |
| 59 | public function getUnfixableDataStatus(): array { |
| 60 | return [ |
| 61 | self::SENDING_QUEUE_WITHOUT_TASK => $this->repository->getSendingQueuesWithoutTaskCount(), |
| 62 | ]; |
| 63 | } |
| 64 | |
| 65 | public function fixInconsistentData(string $inconsistency): void { |
| 66 | if (!in_array($inconsistency, self::SUPPORTED_INCONSISTENCY_CHECKS, true)) { |
| 67 | throw new UnexpectedValueException(__('Unsupported data inconsistency check.', 'mailpoet')); |
| 68 | } |
| 69 | if ($inconsistency === self::ORPHANED_SENDING_TASKS) { |
| 70 | $this->repository->cleanupOrphanedSendingTasks(); |
| 71 | } elseif ($inconsistency === self::ORPHANED_SENDING_TASK_SUBSCRIBERS) { |
| 72 | $this->repository->cleanupOrphanedScheduledTaskSubscribers(); |
| 73 | } elseif ($inconsistency === self::SENDING_QUEUE_WITHOUT_NEWSLETTER) { |
| 74 | $this->repository->cleanupSendingQueuesWithoutNewsletter(); |
| 75 | } elseif ($inconsistency === self::ORPHANED_SUBSCRIPTIONS) { |
| 76 | $this->repository->cleanupOrphanedSubscriptions(); |
| 77 | } elseif ($inconsistency === self::ORPHANED_SUBSCRIBER_CUSTOM_FIELDS) { |
| 78 | $this->repository->cleanupOrphanedSubscriberCustomFields(); |
| 79 | } elseif ($inconsistency === self::ORPHANED_SUBSCRIBER_TAGS) { |
| 80 | $this->repository->cleanupOrphanedSubscriberTags(); |
| 81 | } elseif ($inconsistency === self::ORPHANED_LINKS) { |
| 82 | $this->repository->cleanupOrphanedNewsletterLinks(); |
| 83 | } elseif ($inconsistency === self::ORPHANED_NEWSLETTER_POSTS) { |
| 84 | $this->repository->cleanupOrphanedNewsletterPosts(); |
| 85 | } |
| 86 | } |
| 87 | } |
| 88 |