Blocks
11 months ago
Coupons
2 months ago
Endpoints
4 months ago
Patterns
2 months ago
PersonalizationTags
1 month ago
ProductCollection
2 months ago
Templates
3 months ago
AutomationEmailContextProvider.php
3 months ago
AutomationEmailPreviewOrderProvider.php
3 months ago
BlockEmailContentDetector.php
3 months ago
Cli.php
1 month ago
DependencyNotice.php
1 year ago
EditorPageRenderer.php
2 months ago
EmailApiController.php
2 months ago
EmailEditor.php
4 months ago
EmailEditorPreviewEmail.php
10 months ago
Logger.php
11 months ago
MailPoetCssInliner.php
9 months ago
MailpoetCssInlinerFactory.php
1 year ago
PersonalizationTagManager.php
1 month ago
index.php
2 years ago
EmailApiController.php
304 lines
| 1 | <?php declare(strict_types = 1); |
| 2 | |
| 3 | namespace MailPoet\EmailEditor\Integrations\MailPoet; |
| 4 | |
| 5 | if (!defined('ABSPATH')) exit; |
| 6 | |
| 7 | |
| 8 | use MailPoet\Entities\NewsletterEntity; |
| 9 | use MailPoet\Entities\NewsletterOptionEntity; |
| 10 | use MailPoet\Entities\NewsletterOptionFieldEntity; |
| 11 | use MailPoet\Entities\NewsletterSegmentEntity; |
| 12 | use MailPoet\Entities\SegmentEntity; |
| 13 | use MailPoet\Newsletter\NewslettersRepository; |
| 14 | use MailPoet\Newsletter\Options\NewsletterOptionFieldsRepository; |
| 15 | use MailPoet\Newsletter\Options\NewsletterOptionsRepository; |
| 16 | use MailPoet\Newsletter\Segment\NewsletterSegmentRepository; |
| 17 | use MailPoet\Newsletter\Sharing\ShareVisibility; |
| 18 | use MailPoet\Newsletter\Url as NewsletterUrl; |
| 19 | use MailPoet\NotFoundException; |
| 20 | use MailPoet\UnexpectedValueException; |
| 21 | use MailPoet\Validator\Builder; |
| 22 | use MailPoetVendor\Doctrine\ORM\EntityManager; |
| 23 | |
| 24 | class EmailApiController { |
| 25 | /** @var NewslettersRepository */ |
| 26 | private $newsletterRepository; |
| 27 | |
| 28 | /** @var NewsletterUrl */ |
| 29 | private $newsletterUrl; |
| 30 | |
| 31 | /** @var NewsletterOptionFieldsRepository */ |
| 32 | private $newsletterOptionFieldsRepository; |
| 33 | |
| 34 | /** @var NewsletterOptionsRepository */ |
| 35 | private $newsletterOptionsRepository; |
| 36 | |
| 37 | /** @var NewsletterSegmentRepository */ |
| 38 | private $newsletterSegmentRepository; |
| 39 | |
| 40 | /** @var EntityManager */ |
| 41 | private $entityManager; |
| 42 | |
| 43 | /** @var ShareVisibility */ |
| 44 | private $shareVisibility; |
| 45 | |
| 46 | public function __construct( |
| 47 | NewslettersRepository $newsletterRepository, |
| 48 | NewsletterUrl $newsletterUrl, |
| 49 | NewsletterOptionFieldsRepository $newsletterOptionFieldsRepository, |
| 50 | NewsletterOptionsRepository $newsletterOptionsRepository, |
| 51 | NewsletterSegmentRepository $newsletterSegmentRepository, |
| 52 | EntityManager $entityManager, |
| 53 | ShareVisibility $shareVisibility |
| 54 | ) { |
| 55 | $this->newsletterRepository = $newsletterRepository; |
| 56 | $this->newsletterUrl = $newsletterUrl; |
| 57 | $this->newsletterOptionFieldsRepository = $newsletterOptionFieldsRepository; |
| 58 | $this->newsletterOptionsRepository = $newsletterOptionsRepository; |
| 59 | $this->newsletterSegmentRepository = $newsletterSegmentRepository; |
| 60 | $this->entityManager = $entityManager; |
| 61 | $this->shareVisibility = $shareVisibility; |
| 62 | } |
| 63 | |
| 64 | /** |
| 65 | * @param array $postEmailData - WP_Post data |
| 66 | * @return array - MailPoet specific email data that will be attached to the post API response |
| 67 | */ |
| 68 | public function getEmailData($postEmailData): array { |
| 69 | $newsletter = $this->newsletterRepository->findOneBy(['wpPost' => $postEmailData['id']]); |
| 70 | $isAutomationNewsletter = $newsletter && ($newsletter->isAutomation() || $newsletter->isAutomationTransactional()); |
| 71 | $showInArchive = $newsletter |
| 72 | ? $newsletter->getOptionValue(NewsletterOptionFieldEntity::NAME_EXCLUDE_FROM_ARCHIVE) !== '1' |
| 73 | : true; |
| 74 | return [ |
| 75 | 'id' => $newsletter ? $newsletter->getId() : null, |
| 76 | 'type' => $newsletter ? $newsletter->getType() : '', |
| 77 | 'subject' => $newsletter ? $newsletter->getSubject() : '', |
| 78 | 'preheader' => $newsletter ? $newsletter->getPreheader() : '', |
| 79 | 'sender_name' => $newsletter ? $newsletter->getSenderName() : '', |
| 80 | 'sender_address' => $newsletter ? $newsletter->getSenderAddress() : '', |
| 81 | 'reply_to_name' => $newsletter ? $newsletter->getReplyToName() : '', |
| 82 | 'reply_to_address' => $newsletter ? $newsletter->getReplyToAddress() : '', |
| 83 | 'preview_url' => $this->newsletterUrl->getViewInBrowserUrl($newsletter), |
| 84 | 'deleted_at' => $newsletter && $newsletter->getDeletedAt() !== null ? $newsletter->getDeletedAt()->format('c') : null, |
| 85 | 'scheduled_at' => $newsletter ? $newsletter->getOptionValue(NewsletterOptionFieldEntity::NAME_SCHEDULED_AT) : null, |
| 86 | 'utm_campaign' => $newsletter ? $newsletter->getGaCampaign() : '', |
| 87 | 'segment_ids' => $newsletter ? $newsletter->getSegmentIds() : [], |
| 88 | 'is_automation_newsletter' => $isAutomationNewsletter, |
| 89 | 'share_url' => $newsletter && $this->shareVisibility->isSupported($newsletter) |
| 90 | ? $this->newsletterUrl->getPublicShareUrl($newsletter) |
| 91 | : '', |
| 92 | 'share_visibility' => $newsletter |
| 93 | ? $this->shareVisibility->getConfiguredVisibility($newsletter) |
| 94 | : ShareVisibility::VISIBILITY_DEFAULT, |
| 95 | 'effective_share_visibility' => $newsletter |
| 96 | ? $this->shareVisibility->getEffectiveVisibility($newsletter) |
| 97 | : $this->shareVisibility->getDefaultVisibility(), |
| 98 | 'can_share' => $newsletter ? $this->shareVisibility->canShare($newsletter) : false, |
| 99 | 'show_in_archive' => $showInArchive, |
| 100 | ]; |
| 101 | } |
| 102 | |
| 103 | /** |
| 104 | * Update MailPoet specific data we store with Emails. |
| 105 | */ |
| 106 | public function saveEmailData(array $data, \WP_Post $emailPost): void { |
| 107 | $newsletter = $this->newsletterRepository->findOneById($data['id']); |
| 108 | if (!$newsletter) { |
| 109 | throw new NotFoundException('Newsletter was not found'); |
| 110 | } |
| 111 | if ($newsletter->getWpPostId() !== $emailPost->ID) { |
| 112 | throw new UnexpectedValueException('Newsletter ID does not match the post ID'); |
| 113 | } |
| 114 | |
| 115 | $newsletter->setSubject($data['subject']); |
| 116 | $newsletter->setPreheader($data['preheader']); |
| 117 | |
| 118 | if (array_key_exists('sender_name', $data)) { |
| 119 | $newsletter->setSenderName($data['sender_name']); |
| 120 | } |
| 121 | |
| 122 | if (array_key_exists('sender_address', $data)) { |
| 123 | $newsletter->setSenderAddress($data['sender_address']); |
| 124 | } |
| 125 | |
| 126 | if (array_key_exists('reply_to_name', $data)) { |
| 127 | $newsletter->setReplyToName($data['reply_to_name']); |
| 128 | } |
| 129 | |
| 130 | if (array_key_exists('reply_to_address', $data)) { |
| 131 | $newsletter->setReplyToAddress($data['reply_to_address']); |
| 132 | } |
| 133 | |
| 134 | if (isset($data['utm_campaign'])) { |
| 135 | $newsletter->setGaCampaign($data['utm_campaign']); |
| 136 | } |
| 137 | |
| 138 | if (isset($data['deleted_at'])) { |
| 139 | if (empty($data['deleted_at'])) { |
| 140 | $data['deleted_at'] = null; |
| 141 | } else { |
| 142 | $data['deleted_at'] = new \DateTime($data['deleted_at']); |
| 143 | } |
| 144 | $newsletter->setDeletedAt($data['deleted_at']); |
| 145 | } |
| 146 | |
| 147 | if (array_key_exists('scheduled_at', $data)) { |
| 148 | $this->updateScheduledAtOption($newsletter, $data['scheduled_at']); |
| 149 | } |
| 150 | |
| 151 | if (array_key_exists('share_visibility', $data)) { |
| 152 | $this->updateOption( |
| 153 | $newsletter, |
| 154 | NewsletterOptionFieldEntity::NAME_SHARE_VISIBILITY, |
| 155 | $this->shareVisibility->sanitize((string)$data['share_visibility']) |
| 156 | ); |
| 157 | } |
| 158 | |
| 159 | if (array_key_exists('show_in_archive', $data)) { |
| 160 | $this->updateShowInArchiveOption($newsletter, $data['show_in_archive']); |
| 161 | } |
| 162 | |
| 163 | if (isset($data['segment_ids']) && is_array($data['segment_ids'])) { |
| 164 | $this->updateSegments($newsletter, $data['segment_ids']); |
| 165 | $this->entityManager->refresh($newsletter); |
| 166 | } |
| 167 | |
| 168 | $this->newsletterRepository->flush(); |
| 169 | } |
| 170 | |
| 171 | private function updateShowInArchiveOption(NewsletterEntity $newsletter, $showInArchiveValue): void { |
| 172 | if (!is_bool($showInArchiveValue)) { |
| 173 | throw new UnexpectedValueException('Invalid show_in_archive value. Expected a boolean.'); |
| 174 | } |
| 175 | |
| 176 | if ($newsletter->getType() !== NewsletterEntity::TYPE_STANDARD) { |
| 177 | return; |
| 178 | } |
| 179 | |
| 180 | $this->updateOption( |
| 181 | $newsletter, |
| 182 | NewsletterOptionFieldEntity::NAME_EXCLUDE_FROM_ARCHIVE, |
| 183 | $showInArchiveValue ? '0' : '1' |
| 184 | ); |
| 185 | } |
| 186 | |
| 187 | private function updateOption($newsletter, string $optionName, $optionValue): void { |
| 188 | $optionField = $this->newsletterOptionFieldsRepository->findOneBy([ |
| 189 | 'name' => $optionName, |
| 190 | 'newsletterType' => $newsletter->getType(), |
| 191 | ]); |
| 192 | |
| 193 | if (!$optionField) { |
| 194 | return; |
| 195 | } |
| 196 | |
| 197 | $option = $this->newsletterOptionsRepository->findOneBy([ |
| 198 | 'newsletter' => $newsletter, |
| 199 | 'optionField' => $optionField, |
| 200 | ]); |
| 201 | |
| 202 | if (!$option) { |
| 203 | $option = new NewsletterOptionEntity($newsletter, $optionField); |
| 204 | $this->newsletterOptionsRepository->persist($option); |
| 205 | $newsletter->getOptions()->add($option); |
| 206 | } |
| 207 | |
| 208 | $option->setValue($optionValue); |
| 209 | } |
| 210 | |
| 211 | private function updateScheduledAtOption($newsletter, $scheduledAtValue): void { |
| 212 | // Validate the scheduled_at value |
| 213 | if ($scheduledAtValue !== null && $scheduledAtValue !== '') { |
| 214 | try { |
| 215 | new \DateTime($scheduledAtValue); |
| 216 | } catch (\Exception $e) { |
| 217 | throw new UnexpectedValueException('Invalid scheduled_at format. Expected a valid datetime string.'); |
| 218 | } |
| 219 | } |
| 220 | |
| 221 | $this->updateOption($newsletter, NewsletterOptionFieldEntity::NAME_SCHEDULED_AT, $scheduledAtValue); |
| 222 | |
| 223 | // Also update the isScheduled option |
| 224 | $this->updateOption( |
| 225 | $newsletter, |
| 226 | NewsletterOptionFieldEntity::NAME_IS_SCHEDULED, |
| 227 | $scheduledAtValue !== null && $scheduledAtValue !== '' ? '1' : '0' |
| 228 | ); |
| 229 | } |
| 230 | |
| 231 | /** |
| 232 | * @param array $segmentIds Array of segment IDs |
| 233 | */ |
| 234 | private function updateSegments($newsletter, array $segmentIds): void { |
| 235 | // Normalize segment IDs to integers for consistent strict comparison |
| 236 | $segmentIds = array_map('intval', $segmentIds); |
| 237 | |
| 238 | // Remove existing segments that are not in the new list |
| 239 | $existingSegments = $newsletter->getNewsletterSegments(); |
| 240 | foreach ($existingSegments as $newsletterSegment) { |
| 241 | $segment = $newsletterSegment->getSegment(); |
| 242 | if (!$segment || !in_array($segment->getId(), $segmentIds, true)) { |
| 243 | $this->entityManager->remove($newsletterSegment); |
| 244 | } |
| 245 | } |
| 246 | |
| 247 | // Add new segments |
| 248 | foreach ($segmentIds as $segmentId) { |
| 249 | $segmentIdInt = (int)$segmentId; |
| 250 | $segment = $this->entityManager->getReference(SegmentEntity::class, $segmentIdInt); |
| 251 | if (!$segment) { |
| 252 | continue; |
| 253 | } |
| 254 | |
| 255 | // Check if the newsletter-segment relationship already exists |
| 256 | $existingRelation = $this->newsletterSegmentRepository->findOneBy([ |
| 257 | 'newsletter' => $newsletter, |
| 258 | 'segment' => $segment, |
| 259 | ]); |
| 260 | |
| 261 | if (!$existingRelation) { |
| 262 | $newsletterSegment = new NewsletterSegmentEntity($newsletter, $segment); |
| 263 | $this->entityManager->persist($newsletterSegment); |
| 264 | } |
| 265 | } |
| 266 | $this->entityManager->flush(); |
| 267 | } |
| 268 | |
| 269 | public function trashEmail(\WP_Post $wpPost) { |
| 270 | $newsletter = $this->newsletterRepository->findOneBy(['wpPost' => $wpPost->ID]); |
| 271 | if (!$newsletter) { |
| 272 | throw new NotFoundException('Newsletter was not found'); |
| 273 | } |
| 274 | if ($newsletter->getWpPostId() !== $wpPost->ID) { |
| 275 | throw new UnexpectedValueException('Newsletter ID does not match the post ID'); |
| 276 | } |
| 277 | $this->newsletterRepository->bulkTrash([$newsletter->getId()]); |
| 278 | } |
| 279 | |
| 280 | public function getEmailDataSchema(): array { |
| 281 | return Builder::object([ |
| 282 | 'id' => Builder::integer()->nullable(), |
| 283 | 'type' => Builder::string(), |
| 284 | 'subject' => Builder::string(), |
| 285 | 'preheader' => Builder::string(), |
| 286 | 'sender_name' => Builder::string(), |
| 287 | 'sender_address' => Builder::string(), |
| 288 | 'reply_to_name' => Builder::string(), |
| 289 | 'reply_to_address' => Builder::string(), |
| 290 | 'preview_url' => Builder::string(), |
| 291 | 'deleted_at' => Builder::string()->nullable(), |
| 292 | 'scheduled_at' => Builder::string()->nullable(), |
| 293 | 'utm_campaign' => Builder::string(), |
| 294 | 'segment_ids' => Builder::array(), |
| 295 | 'is_automation_newsletter' => Builder::boolean(), |
| 296 | 'share_url' => Builder::string(), |
| 297 | 'share_visibility' => Builder::string(), |
| 298 | 'effective_share_visibility' => Builder::string(), |
| 299 | 'can_share' => Builder::boolean(), |
| 300 | 'show_in_archive' => Builder::boolean(), |
| 301 | ])->toArray(); |
| 302 | } |
| 303 | } |
| 304 |