?HAMA

Navigation

Breadcrumbs

/ / home / nshryvcy / himaltourism.com / wp-content / plugins / mailpoet / lib / Subscribers

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 4.56 KB

/home/nshryvcy/himaltourism.com/wp-content/plugins/mailpoet/lib/Subscribers/SubscribersCountsController.php

Text Base64

<?php declare(strict_types = 1);

namespace MailPoet\Subscribers;

if (!defined('ABSPATH')) exit;

use MailPoet\Cache\TransientCache;
use MailPoet\Entities\SegmentEntity;
use MailPoet\InvalidStateException;
use MailPoet\Segments\SegmentsRepository;
use MailPoet\Segments\SegmentSubscribersRepository;
use MailPoet\Tags\TagRepository;

class SubscribersCountsController {
  /** @var SegmentsRepository */
  private $segmentsRepository;

/** @var SegmentSubscribersRepository */
  private $segmentSubscribersRepository;

/** @var TagRepository */
  private $tagRepository;

/** @var TransientCache */
  private $transientCache;

public function __construct(
    SegmentsRepository $segmentsRepository,
    SegmentSubscribersRepository $segmentSubscribersRepository,
    TagRepository $subscriberTagRepository,
    TransientCache $transientCache
  ) {

$this->segmentSubscribersRepository = $segmentSubscribersRepository;
    $this->transientCache = $transientCache;
    $this->segmentsRepository = $segmentsRepository;
    $this->tagRepository = $subscriberTagRepository;
  }

public function getSubscribersWithoutSegmentStatisticsCount(): array {
    $result = $this->transientCache->getItem(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY, 0)['item'] ?? null;
    if (!$result) {
      $result = $this->recalculateSubscribersWithoutSegmentStatisticsCache();
    }
    return $result;
  }

public function getSegmentStatisticsCount(SegmentEntity $segment): array {
    $result = $this->transientCache->getItem(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY, (int)$segment->getId())['item'] ?? null;
    if (!$result) {
      $result = $this->recalculateSegmentStatisticsCache($segment);
    }
    return $result;
  }

public function getSegmentGlobalStatusStatisticsCount(SegmentEntity $segment): array {
    $result = $this->transientCache->getItem(TransientCache::SUBSCRIBERS_GLOBAL_STATUS_STATISTICS_COUNT_KEY, (int)$segment->getId())['item'] ?? null;
    if (!$result) {
      $result = $this->recalculateSegmentGlobalStatusStatisticsCache($segment);
    }
    return $result;
  }

public function getSegmentStatisticsCountById(int $segmentId): array {
    $result = $this->transientCache->getItem(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY, $segmentId)['item'] ?? null;
    if (!$result) {
      $segment = $this->segmentsRepository->findOneById($segmentId);
      if (!$segment) {
        throw new InvalidStateException();
      }
      $result = $this->recalculateSegmentStatisticsCache($segment);
    }
    return $result;
  }

public function recalculateSegmentGlobalStatusStatisticsCache(SegmentEntity $segment): array {
    $result = $this->segmentSubscribersRepository->getSubscribersGlobalStatusStatisticsCount($segment);
    $this->transientCache->setItem(
      TransientCache::SUBSCRIBERS_GLOBAL_STATUS_STATISTICS_COUNT_KEY,
      $result,
      (int)$segment->getId()
    );
    return $result;
  }

public function recalculateSegmentStatisticsCache(SegmentEntity $segment): array {
    $result = $this->segmentSubscribersRepository->getSubscribersStatisticsCount($segment);
    $this->transientCache->setItem(
      TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY,
      $result,
      (int)$segment->getId()
    );
    return $result;
  }

public function recalculateSubscribersWithoutSegmentStatisticsCache(): array {
    $result = $this->segmentSubscribersRepository->getSubscribersWithoutSegmentStatisticsCount();
    $this->transientCache->setItem(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY, $result, 0);
    return $result;
  }

public function removeRedundancyFromStatisticsCache() {
    $segments = $this->segmentsRepository->findAll();
    $segmentIds = array_map(function (SegmentEntity $segment): int {
      return (int)$segment->getId();
    }, $segments);
    foreach ($this->transientCache->getItems(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY) as $id => $item) {
      if (!in_array($id, $segmentIds)) {
        $this->transientCache->invalidateItem(TransientCache::SUBSCRIBERS_STATISTICS_COUNT_KEY, $id);
      }
    }
    foreach ($this->transientCache->getItems(TransientCache::SUBSCRIBERS_GLOBAL_STATUS_STATISTICS_COUNT_KEY) as $id => $item) {
      if (!in_array($id, $segmentIds)) {
        $this->transientCache->invalidateItem(TransientCache::SUBSCRIBERS_GLOBAL_STATUS_STATISTICS_COUNT_KEY, $id);
      }
    }
  }

/**
   * @return array<int, array{id: int, name: string, subscribersCount: int}>
   */
  public function getTagsStatisticsCount(?string $status, bool $isDeleted): array {
    return $this->tagRepository->getSubscriberStatisticsCount($status, $isDeleted);
  }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 3 × Files: 20

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
ConfirmationEmailTemplate DIR	-	drwxr-xr-x	2023-04-04 05:35:40	Edit Download recursive recursive
ImportExport DIR	-	drwxr-xr-x	2023-04-04 05:35:40	Edit Download recursive recursive
Statistics DIR	-	drwxr-xr-x	2023-04-04 05:35:40	Edit Download recursive recursive
ConfirmationEmailCustomizer.php	3.17 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
ConfirmationEmailMailer.php	7.19 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
InactiveSubscribersController.php	7.10 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
index.php	0 B	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
LinkTokens.php	1.32 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
NewSubscriberNotificationMailer.php	3.24 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
RequiredCustomFieldValidator.php	2.53 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
Source.php	1.16 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberActions.php	4.83 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberCustomFieldRepository.php	1.19 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberIPsRepository.php	1.76 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberListingRepository.php	15.01 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberPersonalDataEraser.php	2.41 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberSaveController.php	11.32 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscribersCountsController.php	4.56 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberSegmentRepository.php	4.54 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscribersEmailCountsController.php	4.58 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscribersRepository.php	17.28 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberSubscribeController.php	10.16 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubscriberTagRepository.php	370 B	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive