Build listings response

[MAILPOET-2657]

lib/API/JSON/ResponseBuilders/SubscribersResponseBuilder.php

@@ -10,8 +10,10 @@ use MailPoet\Entities\SubscriberEntity;
 use MailPoet\Statistics\StatisticsUnsubscribesRepository;
 use MailPoet\Subscribers\SubscriberCustomFieldRepository;
 use MailPoet\Subscribers\SubscriberSegmentRepository;
+use MailPoetVendor\Doctrine\ORM\EntityManager;
 
 class SubscribersResponseBuilder {
+  const DATE_FORMAT = 'Y-m-d H:i:s';
 
   /** @var SubscriberSegmentRepository */
   private $subscriberSegmentRepository;
@@ -25,7 +27,11 @@ class SubscribersResponseBuilder {
   /** @var SubscriberCustomFieldRepository */
   private $subscriberCustomFieldRepository;
 
+  /** @var EntityManager */
+  private $entityManager;
+
   public function __construct(
+    EntityManager $entityManager,
     SubscriberSegmentRepository $subscriberSegmentRepository,
     CustomFieldsRepository $customFieldsRepository,
     SubscriberCustomFieldRepository $subscriberCustomFieldRepository,
@@ -35,6 +41,28 @@ class SubscribersResponseBuilder {
     $this->statisticsUnsubscribesRepository = $statisticsUnsubscribesRepository;
     $this->customFieldsRepository = $customFieldsRepository;
     $this->subscriberCustomFieldRepository = $subscriberCustomFieldRepository;
+    $this->entityManager = $entityManager;
+  }
+
+  public function buildForListing(array $subscribers): array {
+    $this->prefetchSegments($subscribers);
+    $data = [];
+    foreach ($subscribers as $subscriber) {
+      $data[] = $this->buildListingItem($subscriber);
+    }
+    return $data;
+  }
+
+  private function buildListingItem(SubscriberEntity $subscriber): array {
+    return [
+      'id' => (string)$subscriber->getId(), // (string) for BC
+      'email' => $subscriber->getEmail(),
+      'first_name' => $subscriber->getFirstName(),
+      'last_name' => $subscriber->getLastName(),
+      'subscriptions' => $this->buildSubscriptions($subscriber),
+      'status' => $subscriber->getStatus(),
+      'created_at' => ($createdAt = $subscriber->getCreatedAt()) ? $createdAt->format(self::DATE_FORMAT) : null,
+    ];
   }
 
   public function build(SubscriberEntity $subscriberEntity): array {
@@ -60,7 +88,7 @@ class SubscribersResponseBuilder {
       $segment = $subscription->getSegment();
       if ($segment instanceof SegmentEntity) {
         $result[] = [
-          'segment_id' => $segment->getId(),
+          'segment_id' => (string)$segment->getId(),
           'status' => $subscription->getStatus(),
           'updated_at' => $subscription->getUpdatedAt(),
         ];
@@ -105,4 +133,19 @@ class SubscribersResponseBuilder {
     }
     return $data;
   }
+
+  /**
+   * @param SubscriberEntity[] $subscribers
+   */
+  private function prefetchSegments(array $subscribers) {
+    $this->entityManager->createQueryBuilder()
+      ->select('PARTIAL s.{id}, ssg, sg')
+      ->from(SubscriberEntity::class, 's')
+      ->join('s.subscriberSegments', 'ssg')
+      ->join('ssg.segment', 'sg')
+      ->where('s.id IN (:subscribers)')
+      ->setParameter('subscribers', $subscribers)
+      ->getQuery()
+      ->getResult();
+  }
 }

lib/API/JSON/v1/Subscribers.php

@@ -25,6 +25,7 @@ use MailPoet\Subscribers\ConfirmationEmailMailer;
 use MailPoet\Subscribers\RequiredCustomFieldValidator;
 use MailPoet\Subscribers\Source;
 use MailPoet\Subscribers\SubscriberActions;
+use MailPoet\Subscribers\SubscriberListingRepository;
 use MailPoet\Subscribers\SubscribersRepository;
 use MailPoet\Subscription\Captcha;
 use MailPoet\Subscription\CaptchaSession;
@@ -85,6 +86,9 @@ class Subscribers extends APIEndpoint {
   /** @var SubscribersResponseBuilder */
   private $subscribersResponseBuilder;
 
+  /** @var SubscriberListingRepository */
+  private $newsletterListingRepository;
+
   public function __construct(
     Listing\BulkActionController $bulkActionController,
     SubscribersListings $subscribersListings,
@@ -100,6 +104,7 @@ class Subscribers extends APIEndpoint {
     Unsubscribes $unsubscribesTracker,
     SubscribersRepository $subscribersRepository,
     SubscribersResponseBuilder $subscribersResponseBuilder,
+    SubscriberListingRepository $newsletterListingRepository,
     FieldNameObfuscator $fieldNameObfuscator
   ) {
     $this->bulkActionController = $bulkActionController;
@@ -117,6 +122,7 @@ class Subscribers extends APIEndpoint {
     $this->unsubscribesTracker = $unsubscribesTracker;
     $this->subscribersRepository = $subscribersRepository;
     $this->subscribersResponseBuilder = $subscribersResponseBuilder;
+    $this->newsletterListingRepository = $newsletterListingRepository;
   }
 
   public function get($data = []) {
@@ -131,9 +137,18 @@ class Subscribers extends APIEndpoint {
   }
 
   public function listing($data = []) {
-
     if (!isset($data['filter']['segment'])) {
-      $listingData = $this->listingHandler->get('\MailPoet\Models\Subscriber', $data);
+      $definition = $this->listingHandler->getListingDefinition($data);
+      $items = $this->newsletterListingRepository->getData($definition);
+      $count = $this->newsletterListingRepository->getCount($definition);
+      $filters = $this->newsletterListingRepository->getFilters($definition);
+      $groups = $this->newsletterListingRepository->getGroups($definition);
+
+      return $this->successResponse($this->subscribersResponseBuilder->buildForListing($items), [
+        'count' => $count,
+        'filters' => $filters,
+        'groups' => $groups,
+      ]);
     } else {
       $listingData = $this->subscribersListings->getListingsInSegment($data);
     }

lib/Subscribers/SubscriberListingRepository.php

@@ -3,6 +3,7 @@
 namespace MailPoet\Subscribers;
 
 use MailPoet\Entities\SubscriberEntity;
+use MailPoet\Listing\ListingDefinition;
 use MailPoet\Listing\ListingRepository;
 use MailPoetVendor\Doctrine\ORM\QueryBuilder;
 
@@ -59,4 +60,12 @@ class SubscriberListingRepository extends ListingRepository {
     $queryBuilder->addOrderBy("s.$sortBy", $sortOrder);
   }
 
+  public function getGroups(ListingDefinition $definition): array {
+    return [];// TODO
+  }
+
+  public function getFilters(ListingDefinition $definition): array {
+    return [];//TODO
+  }
+
 }