Cavemanon/piratepoet
7
Fork 0
Code Pull Requests Actions Releases 16 Activity

Add unsubscriptions to the response

Browse Source 
[MAILPOET-2653]
This commit is contained in:
Pavel Dohnal
2020-06-25 13:36:53 +02:00
committed by Veljko V
parent 1923dc8257
commit a01e19c805
1 changed files with 35 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
lib/API/JSON/ResponseBuilders/SubscribersResponseBuilder.php
View File

@ -4,7 +4,9 @@ namespace MailPoet\API\JSON\ResponseBuilders;
use MailPoet\Entities\SegmentEntity; use MailPoet\Entities\SegmentEntity;
use MailPoet\Entities\SubscriberCustomFieldEntity; use MailPoet\Entities\SubscriberCustomFieldEntity;
use MailPoet\Entities\NewsletterEntity;
use MailPoet\Entities\SubscriberEntity; use MailPoet\Entities\SubscriberEntity;
use MailPoet\Statistics\StatisticsUnsubscribesRepository;
use MailPoet\Subscribers\SubscriberSegmentRepository; use MailPoet\Subscribers\SubscriberSegmentRepository;
class SubscribersResponseBuilder { class SubscribersResponseBuilder {
@ -12,8 +14,15 @@ class SubscribersResponseBuilder {
/** @var SubscriberSegmentRepository */ /** @var SubscriberSegmentRepository */
private $subscriberSegmentRepository; private $subscriberSegmentRepository;
public function __construct(SubscriberSegmentRepository $subscriberSegmentRepository) { /** @var StatisticsUnsubscribesRepository */
private $statisticsUnsubscribesRepository;
public function __construct(
SubscriberSegmentRepository $subscriberSegmentRepository,
StatisticsUnsubscribesRepository $statisticsUnsubscribesRepository
) {
$this->subscriberSegmentRepository = $subscriberSegmentRepository; $this->subscriberSegmentRepository = $subscriberSegmentRepository;
$this->statisticsUnsubscribesRepository = $statisticsUnsubscribesRepository;
} }
public function build(SubscriberEntity $subscriberEntity): array { public function build(SubscriberEntity $subscriberEntity): array {
@ -22,7 +31,7 @@ class SubscribersResponseBuilder {
'wp_user_id' => $subscriberEntity->getWpUserId(), 'wp_user_id' => $subscriberEntity->getWpUserId(),
'is_woocommerce_user' => $subscriberEntity->getIsWoocommerceUser(), 'is_woocommerce_user' => $subscriberEntity->getIsWoocommerceUser(),
'subscriptions' => $this->buildSubscriptions($subscriberEntity), 'subscriptions' => $this->buildSubscriptions($subscriberEntity),
'unsubscribes' => [],// TODO 'unsubscribes' => $this->buildUnsubscribes($subscriberEntity),
// TODO custom fields // TODO custom fields
'status' => $subscriberEntity->getStatus(), 'status' => $subscriberEntity->getStatus(),
'last_name' => $subscriberEntity->getLastName(), 'last_name' => $subscriberEntity->getLastName(),
@ -35,7 +44,7 @@ class SubscribersResponseBuilder {
private function buildSubscriptions(SubscriberEntity $subscriberEntity): array { private function buildSubscriptions(SubscriberEntity $subscriberEntity): array {
$result = []; $result = [];
$subscriptions = $this->subscriberSegmentRepository->findAll(['subscriber' => $subscriberEntity]); $subscriptions = $this->subscriberSegmentRepository->findBy(['subscriber' => $subscriberEntity]);
foreach ($subscriptions as $subscription) { foreach ($subscriptions as $subscription) {
$segment = $subscription->getSegment(); $segment = $subscription->getSegment();
if ($segment instanceof SegmentEntity) { if ($segment instanceof SegmentEntity) {
@ -48,4 +57,27 @@ class SubscribersResponseBuilder {
} }
return $result; return $result;
} }
private function buildUnsubscribes(SubscriberEntity $subscriberEntity): array {
$unsubscribes = $this->statisticsUnsubscribesRepository->findBy([
'subscriberId' => $subscriberEntity->getId(),
], [
'createdAt' => 'desc',
]);
$result = [];
foreach ($unsubscribes as $unsubscribe) {
$mapped = [
'source' => $unsubscribe->getSource(),
'meta' => $unsubscribe->getMeta(),
'createdAt' => $unsubscribe->getCreatedAt(),
];
$newsletter = $unsubscribe->getNewsletter();
if ($newsletter instanceof NewsletterEntity) {
$mapped['newsletterId'] = $newsletter->getId();
$mapped['newsletterSubject'] = $newsletter->getSubject();
}
$result[] = $mapped;
}
return $result;
}
} }