View source
<?php
namespace Drupal\email_confirmer;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Config\ConfigFactoryInterface;
use Drupal\Component\Datetime\TimeInterface;
class EmailConfirmerManager implements EmailConfirmerManagerInterface {
protected $entityTypeManager;
protected $config;
protected $time;
public function __construct(EntityTypeManagerInterface $entity_type_manager, ConfigFactoryInterface $config_factory, TimeInterface $time) {
$this->entityTypeManager = $entity_type_manager;
$this->config = $config_factory
->get('email_confirmer.settings');
$this->time = $time;
}
public function confirm($email, array $data = [], $realm = '') {
$confirmation = $this
->getConfirmation($email, 'pending', $realm);
if (!$confirmation) {
$confirmation = $this
->createConfirmation($email);
}
if (!empty($realm)) {
$confirmation
->setRealm($realm);
}
foreach ($data as $key => $value) {
$confirmation
->setProperty($key, $value);
}
$confirmation
->sendRequest();
$confirmation
->save();
return $confirmation;
}
public function getConfirmations($email, $status = FALSE, $limit = 0, $realm = '') {
$results = [];
$confirmation_query = $this->entityTypeManager
->getStorage('email_confirmer_confirmation')
->getQuery();
if (!empty($realm)) {
$confirmation_query
->condition('realm', $realm);
}
if ($limit) {
$confirmation_query
->range(0, $limit);
}
switch ($status) {
case 'expired':
$confirmation_query
->condition('created', $this->time
->getRequestTime() - $this->config
->get('hash_expiration'), '<');
break;
case 'cancelled':
$confirmation_query
->condition('status', EmailConfirmationInterface::CANCELLED);
break;
case 'confirmed':
$confirmation_query
->condition('confirmed', EmailConfirmationInterface::CONFIRMED);
break;
case 'pending':
$confirmation_query
->condition('status', EmailConfirmationInterface::ACTIVE)
->condition('confirmed', EmailConfirmationInterface::UNCONFIRMED)
->condition('created', $this->time
->getRequestTime() - $this->config
->get('hash_expiration'), '>');
break;
}
$old_confirmations = $confirmation_query
->condition('email', $email)
->sort('created', 'DESC')
->execute();
$confirmation_storage = $this->entityTypeManager
->getStorage('email_confirmer_confirmation');
if (is_array($old_confirmations) && count($old_confirmations)) {
$results = array_values($confirmation_storage
->loadMultiple($old_confirmations));
}
return $results;
}
public function getConfirmation($email, $status = FALSE, $realm = '') {
$confirmation = NULL;
$confirmations = $this
->getConfirmations($email, $status, 1, $realm);
if (count($confirmations)) {
$confirmation = $confirmations[0];
}
return $confirmation;
}
public function createConfirmation($email) {
return $this->entityTypeManager
->getStorage('email_confirmer_confirmation')
->create([
'email' => $email,
]);
}
}