social_lms_integrator-1.0.0-beta4/modules/social_lms_integrator_iteration_invite/src/SocialLMSIntegratorIterationInviteBulkHelper.php

<?php

namespace Drupal\social_lms_integrator_iteration_invite;

use Drupal\Core\Cache\Cache;
use Drupal\Core\Url;
use Drupal\social_lms_integrator_enrollment\Entity\IterationEnrollment;
use Drupal\social_lms_integrator_enrollment\IterationEnrollmentInterface;
use Drupal\user\UserInterface;
use Symfony\Component\HttpFoundation\RedirectResponse;

/**
 * Class SocialLMSIntegratorIterationBulkInvite.
 *
 * @package Drupal\social_lms_integrator_iteration_invite
 */
class SocialLMSIntegratorIterationInviteBulkHelper {

  /**
   * Send the invites to existing users in a batch.
   *
   * @param array $users
   *   Array containing users.
   * @param string $nid
   *   The node id.
   * @param array $context
   *   The context.
   *
   * @throws \Drupal\Component\Plugin\Exception\InvalidPluginDefinitionException
   * @throws \Drupal\Component\Plugin\Exception\PluginNotFoundException
   * @throws \Drupal\Core\Entity\EntityStorageException
   */
  public static function bulkInviteUsers(array $users, $nid, array &$context) {
    $results = [];

    foreach ($users as $uid => $target_id) {
      // Default values.
      $fields = [
        'field_iteration' => $nid,
        'field_enrollment_status' => '0',
        'field_request_or_invite_status' => IterationEnrollmentInterface::INVITE_PENDING_REPLY,
        'user_id' => $uid,
        'field_account' => $uid,
      ];

      // Check if this user has been invited before. It might be that the user
      // declined the invite, or that the invite is now invalid and expired.
      // We simply delete the outdated invite and create a new one.
      $conditions = [
        'field_account' => $uid,
        'field_iteration' => $nid,
      ];
      $iterationEnrollmentStorage = \Drupal::entityTypeManager()->getStorage('iteration_enrollment');
      $existing_enrollment = $iterationEnrollmentStorage->loadByProperties($conditions);

      if (!empty($existing_enrollment)) {
        /** @var \Drupal\social_lms_integrator_enrollment\Entity\IterationEnrollment $enrollment */
        $enrollment = end($existing_enrollment);
        // Of course, only delete the previous invite if it was declined
        // or if it was invalid or expired.
        $status_checks = [
          IterationEnrollmentInterface::REQUEST_OR_INVITE_DECLINED,
          IterationEnrollmentInterface::INVITE_INVALID_OR_EXPIRED,
        ];
        if (in_array($enrollment->field_request_or_invite_status->value, $status_checks)) {
          $enrollment->delete();
          unset($existing_enrollment[$enrollment->id()]);
        }
      }

      // Clear the cache.
      $tags = [];
      $tags[] = 'iteration_enrollment:' . $nid . '-' . $uid;
      $tags[] = 'iteration_content_list:entity:' . $uid;
      Cache::invalidateTags($tags);

      // Create a new enrollment for the iteration.
      $enrollment = IterationEnrollment::create($fields);
      // In order for the notifications to be sent correctly we're updating the
      // owner here. The account is still linked to the actual enrollee.
      // The owner is always used as the actor.
      // @see activity_creator_message_insert().
      $enrollment->setOwnerId(\Drupal::currentUser()->id());
      // Add the node id to the results so we have the nid available in the
      // finished callback so we can redirect to the correct node.
      $results[$nid] = $enrollment->save();
    }

    $context['results'] = $results;
  }

  /**
   * Send the invites to emails in a batch.
   *
   * @param array $emails
   *   Array containing emails.
   * @param string $nid
   *   The node id.
   * @param array $context
   *   The context.
   *
   * @throws \Drupal\Core\Entity\EntityStorageException
   */
  public static function bulkInviteEmails(array $emails, $nid, array &$context) {
    $results = [];

    foreach ($emails as $email) {
      $user = user_load_by_mail($email);

      // Default values.
      $fields = [
        'field_iteration' => $nid,
        'field_enrollment_status' => '0',
        'field_request_or_invite_status' => IterationEnrollmentInterface::INVITE_PENDING_REPLY,
      ];

      if ($user instanceof UserInterface) {
        // Add user information.
        $fields['user_id'] = $user->id();
        $fields['field_account'] = $user->id();

        // Clear the cache.
        $tags = [];
        $tags[] = 'iteration_enrollment:' . $nid . '-' . $user->id();
        $tags[] = 'iteration_content_list:entity:' . $user->id();
        Cache::invalidateTags($tags);
      }
      else {
        // Add email address.
        $fields['field_email'] = $email;
      }

      // Create a new enrollment for the iteration.
      $enrollment = IterationEnrollment::create($fields);
      // In order for the notifications to be sent correctly we're updating the
      // owner here. The account is still linked to the actual enrollee.
      // The owner is always used as the actor.
      // @see activity_creator_message_insert().
      $enrollment->setOwnerId(\Drupal::currentUser()->id());
      // Add the node id to the results so we have the nid available in the
      // finished callback so we can redirect to the correct node.
      $results[$nid] = $enrollment->save();
    }

    $context['results'] = $results;
  }

  /**
   * Send the invites to emails in a batch.
   *
   * @param array $users
   *   Array containing user ids or user emails.
   * @param string $nid
   *   The node id.
   * @param array $context
   *   The context.
   *
   * @throws \Drupal\Core\Entity\EntityStorageException
   */
  public static function bulkInviteUsersEmails(array $users, $nid, array &$context) {
    $results = [];

    foreach ($users as $user) {
      // @todo Should be merged with extractEmailsFrom from InviteEmailBaseForm.
      // Remove select2 ID parameter.
      $user = str_replace('$ID:', '', $user);
      preg_match_all("/[\._a-zA-Z0-9+-]+@[\._a-zA-Z0-9+-]+/i", $user, $email);
      $email = $email[0];

      // If the user is an email.
      if ($email) {
        $user = user_load_by_mail($email);

        // Default values.
        $fields = [
          'field_iteration' => $nid,
          'field_enrollment_status' => '0',
          'field_request_or_invite_status' => IterationEnrollmentInterface::INVITE_PENDING_REPLY,
        ];

        if ($user instanceof UserInterface) {
          // Add user information.
          $fields['user_id'] = $user->id();
          $fields['field_account'] = $user->id();

          // Clear the cache.
          $tags = [];
          $tags[] = 'iteration_enrollment:' . $nid . '-' . $user->id();
          $tags[] = 'iteration_content_list:entity:' . $user->id();
          Cache::invalidateTags($tags);
        }
        else {
          // Add email address.
          $fields['field_email'] = $email;
        }

      }
      // If the user is a UID.
      else {
        // Default values.
        $fields = [
          'field_iteration' => $nid,
          'field_enrollment_status' => '0',
          'field_request_or_invite_status' => IterationEnrollmentInterface::INVITE_PENDING_REPLY,
          'user_id' => $user,
          'field_account' => $user,
        ];

        // Check if this user has been invited before. It might be that the user
        // declined the invite, or that the invite is now invalid and expired.
        // We simply delete the outdated invite and create a new one.
        $conditions = [
          'field_account' => $user,
          'field_iteration' => $nid,
        ];
        $iterationEnrollmentStorage = \Drupal::entityTypeManager()->getStorage('iteration_enrollment');
        $existing_enrollment = $iterationEnrollmentStorage->loadByProperties($conditions);

        if (!empty($existing_enrollment)) {
          /** @var \Drupal\social_lms_integrator_enrollment\Entity\IterationEnrollment $enrollment */
          $enrollment = end($existing_enrollment);
          // Of course, only delete the previous invite if it was declined
          // or if it was invalid or expired.
          $status_checks = [
            IterationEnrollmentInterface::REQUEST_OR_INVITE_DECLINED,
            IterationEnrollmentInterface::INVITE_INVALID_OR_EXPIRED,
          ];
          if (in_array($enrollment->field_request_or_invite_status->value, $status_checks)) {
            $enrollment->delete();
            unset($existing_enrollment[$enrollment->id()]);
          }
        }

        // Clear the cache.
        $tags = [];
        $tags[] = 'iteration_enrollment:' . $nid . '-' . $user;
        $tags[] = 'iteration_content_list:entity:' . $user;
        Cache::invalidateTags($tags);
      }

      // Create a new enrollment for the iteration.
      $enrollment = IterationEnrollment::create($fields);
      // In order for the notifications to be sent correctly we're updating the
      // owner here. The account is still linked to the actual enrollee.
      // The owner is always used as the actor.
      // @see activity_creator_message_insert().
      $enrollment->setOwnerId(\Drupal::currentUser()->id());
      // Add the node id to the results so we have the nid available in the
      // finished callback so we can redirect to the correct node.
      $results[$nid] = $enrollment->save();
    }

    $context['results'] = $results;
  }

  /**
   * Callback when the batch for inviting emails for an iteration has finished.
   */
  public static function bulkInviteUserEmailsFinished($success, $results, $operations) {
    $nid = NULL;

    // We got the node iteration id in the results array so we will use that
    // to provide the param in in redirect url.
    if (!empty($results)) {
      // We don't care about resetting the array first.
      $nid = key($results);
    }

    if ($success && !empty($results)) {
      \Drupal::messenger()->addStatus(t('Invite(s) have been successfully sent.'));
    }
    elseif ($success && empty($results)) {
      \Drupal::messenger()->AddStatus(t('No invites were sent, recipients already received one before.'));
    }
    else {
      \Drupal::messenger()->addError(t('There was an unexpected error.'));
    }

    // Redirect back to the iteration if we found the node ID.
    if ($nid) {
      return new RedirectResponse(Url::fromRoute('entity.node.canonical', ['node' => $nid])
        ->toString());
    }

    // If something went wrong, we have to redirect back to the frontpage.
    return new RedirectResponse(Url::fromRoute('<front>')
      ->toString());
  }

}