View source
<?php
namespace Drupal\gdpr_tasks\Controller;
use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Entity\EntityStorageException;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Messenger\MessengerInterface;
use Drupal\Core\Queue\QueueFactory;
use Drupal\Core\Session\AccountInterface;
use Drupal\Core\Session\AccountProxyInterface;
use Drupal\gdpr_tasks\TaskManager;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\gdpr_tasks\Form\CreateGdprRequestOnBehalfOfUserForm;
class GDPRController extends ControllerBase {
protected $taskManager;
protected $queue;
public static function create(ContainerInterface $container) {
return new static($container
->get('entity_type.manager'), $container
->get('current_user'), $container
->get('messenger'), $container
->get('gdpr_tasks.manager'), $container
->get('queue'));
}
public function __construct(EntityTypeManagerInterface $entity_type_manager, AccountProxyInterface $current_user, MessengerInterface $messenger, TaskManager $task_manager, QueueFactory $queue) {
$this->entityTypeManager = $entity_type_manager;
$this->currentUser = $current_user;
$this->messenger = $messenger;
$this->taskManager = $task_manager;
$this->queue = $queue
->get('gdpr_tasks_process_gdpr_sar');
}
public function summaryPage() {
return [
'#markup' => $this
->t('Summary'),
];
}
public function requestPage(AccountInterface $user, $gdpr_task_type) {
$tasks = $this->taskManager
->getUserTasks($user, $gdpr_task_type);
$pending = FALSE;
$statuses = [
'requested',
'processed',
'reviewing',
];
foreach ($tasks as $task) {
if (in_array($task->status
->getString(), $statuses, TRUE)) {
$pending = TRUE;
}
}
if ($pending) {
$this->messenger
->addWarning('You already have a pending task.');
}
else {
if ($this
->currentUser()
->id() !== $user
->id()) {
return [
'form' => $this
->formBuilder()
->getForm(CreateGdprRequestOnBehalfOfUserForm::class),
];
}
$values = [
'type' => $gdpr_task_type,
'user_id' => $user
->id(),
];
$newTask = $this->entityTypeManager
->getStorage('gdpr_task')
->create($values);
try {
$newTask
->save();
$this->messenger
->addStatus($this
->t('Your request has been logged.'));
if ($gdpr_task_type === 'gdpr_sar') {
$this->queue
->createQueue();
$this->queue
->createItem($newTask
->id());
}
} catch (EntityStorageException $exception) {
$this->messenger
->addError($this
->t('There was an error while logging your request.'));
$this->loggerFactory
->get('gdpr_tasks')
->error($this
->t('Error while trying to create a(n) "@taskType" GDPR task for user "@userName (@userId)."', [
'@taskType' => $gdpr_task_type,
'@userName' => $user
->getDisplayName(),
'@userId' => $user
->id(),
]));
}
}
return $this
->redirect('view.gdpr_tasks_my_data_requests.page_1', [
'user' => $user
->id(),
]);
}
}