public function FollowTagActivityContext::getRecipientsWhoFollowTaxonomy in Open Social 10.0.x

Same name and namespace in other branches

1. 10.3.x modules/social_features/social_follow_taxonomy/modules/social_follow_tag/src/Plugin/ActivityContext/FollowTagActivityContext.php \Drupal\social_follow_tag\Plugin\ActivityContext\FollowTagActivityContext::getRecipientsWhoFollowTaxonomy()
2. 10.1.x modules/social_features/social_follow_taxonomy/modules/social_follow_tag/src/Plugin/ActivityContext/FollowTagActivityContext.php \Drupal\social_follow_tag\Plugin\ActivityContext\FollowTagActivityContext::getRecipientsWhoFollowTaxonomy()
3. 10.2.x modules/social_features/social_follow_taxonomy/modules/social_follow_tag/src/Plugin/ActivityContext/FollowTagActivityContext.php \Drupal\social_follow_tag\Plugin\ActivityContext\FollowTagActivityContext::getRecipientsWhoFollowTaxonomy()

Returns recipients from followed taxonomies.

Overrides FollowTaxonomyActivityContext::getRecipientsWhoFollowTaxonomy

File

modules/social_features/social_follow_taxonomy/modules/social_follow_tag/src/Plugin/ActivityContext/FollowTagActivityContext.php, line 24

Class

FollowTagActivityContext

Provides a 'FollowTagActivityContext' activity context plugin.

Namespace

Drupal\social_follow_tag\Plugin\ActivityContext

Code

public function getRecipientsWhoFollowTaxonomy(array $related_entity, array $data) {
  $recipients = [];
  $entity = $this->entityTypeManager
    ->getStorage($related_entity['target_type'])
    ->load($related_entity['target_id']);
  if (!empty($entity)) {
    $tids = $this
      ->taxonomyTermsList($entity);
  }
  if (empty($tids)) {
    return [];
  }
  $storage = $this->entityTypeManager
    ->getStorage('flagging');
  $flaggings = $storage
    ->loadByProperties([
    'flag_id' => 'follow_term',
    'entity_type' => 'taxonomy_term',
    'entity_id' => $tids,
  ]);
  foreach ($flaggings as $flagging) {

    /** @var \Drupal\flag\FlaggingInterface $flagging */
    $recipient = $flagging
      ->getOwner();

    // It could happen that a notification has been queued but the content or
    // account has since been deleted. In that case we can find no recipient.
    if (!$recipient instanceof UserInterface) {
      continue;
    }

    // Do not send notification for inactive user.
    if ($recipient
      ->isBlocked() || !$recipient
      ->getLastLoginTime()) {
      continue;
    }
    $group = _social_group_get_current_group($entity);
    if ($group instanceof GroupInterface) {
      if (!$group
        ->getMember($recipient)) {

        // We don't send notifications to content creator.
        if ($recipient
          ->id() !== $entity
          ->getOwnerId()) {
          if (!in_array($recipient
            ->id(), array_column($recipients, 'target_id'))) {
            $recipients[] = [
              'target_type' => 'user',
              'target_id' => $recipient
                ->id(),
            ];
          }
        }
      }
    }
  }
  return $recipients;
}