Create a new repository

[MAILPOET-2439]

lib/Cron/Workers/StatsNotifications/StatsNotificationsRepository.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace MailPoet\Cron\Workers\StatsNotifications;
+
+use MailPoet\Doctrine\Repository;
+use MailPoet\Entities\StatsNotificationEntity;
+
+class StatsNotificationsRepository extends Repository {
+  protected function getEntityClassName() {
+    return StatsNotificationEntity::class;
+  }
+
+  /**
+   * @param int $newsletter_id
+   * @return array
+   */
+  public function findAllForNewsletter($newsletter_id) {
+    return $this->doctrine_repository
+      ->createQueryBuilder('stn')
+      ->join('stn.task', 'tasks')
+      ->join('stn.newsletter', 'n')
+      ->addSelect('tasks')
+      ->where('tasks.type = :taskType')
+      ->setParameter('taskType', Worker::TASK_TYPE)
+      ->andWhere('n.id = :newsletterId')
+      ->setParameter('newsletterId', $newsletter_id)
+      ->getQuery()
+      ->getResult();
+  }
+}

lib/DI/ContainerConfigurator.php

@@ -130,6 +130,7 @@ class ContainerConfigurator implements IContainerConfigurator {
     $container->autowire(\MailPoet\Cron\Workers\WorkersFactory::class)->setPublic(true);
     $container->autowire(\MailPoet\Cron\Workers\SendingQueue\SendingErrorHandler::class)->setPublic(true);
     $container->autowire(\MailPoet\Cron\Workers\StatsNotifications\Scheduler::class);
+    $container->autowire(\MailPoet\Cron\Workers\StatsNotifications\StatsNotificationsRepository::class);
     $container->autowire(\MailPoet\Cron\CronTrigger::class)->setPublic(true);
     // Custom field
     $container->autowire(\MailPoet\CustomFields\ApiDataSanitizer::class);