namespace Drupal\entityqueue\Controller;
use Drupal\Core\Controller\ControllerBase;
+use Drupal\Core\Entity\EntityInterface;
+use Drupal\Core\Routing\RouteMatch;
use Drupal\entityqueue\EntityQueueInterface;
use Symfony\Component\HttpFoundation\Request;
use Drupal\Core\Ajax\AjaxResponse;
use Drupal\Core\Ajax\ReplaceCommand;
+use Drupal\entityqueue\EntitySubqueueInterface;
+use Drupal\Core\Url;
+use Drupal\Core\Routing\RouteMatchInterface;
+use Drupal\Core\Access\AccessResult;
/**
- * Returns responses for Views UI routes.
+ * Returns responses for Entityqueue UI routes.
*/
class EntityQueueUIController extends ControllerBase {
return $list_builder->render();
}
+ /**
+ * Provides a list of subqueues where an entity can be added.
+ *
+ * @param \Drupal\Core\Routing\RouteMatchInterface $route_match
+ * The route match.
+ * @param string $entity_type_id
+ * (optional) The entity type ID.
+ * @param \Drupal\Core\Entity\EntityInterface $entity
+ * (optional) An entity object.
+ *
+ * @return array
+ * Array of page elements to render.
+ */
+ public function subqueueListForEntity(RouteMatchInterface $route_match, $entity_type_id = NULL, EntityInterface $entity = NULL) {
+ if (!$entity) {
+ $entity = $route_match->getParameter($entity_type_id);
+ }
+
+ $queues = $this->getAvailableQueuesForEntity($entity);
+ $subqueues = $this->entityTypeManager()->getStorage('entity_subqueue')->loadByProperties(['queue' => array_keys($queues)]);
+ $list_builder = $this->entityTypeManager()->getListBuilder('entity_subqueue');
+
+ $build['#title'] = $this->t('Entityqueues for %title', ['%title' => $entity->label()]);
+ $build['#type'] = 'container';
+ $build['#attributes']['id'] = 'entity-subqueue-list';
+ $build['#attached']['library'][] = 'core/drupal.ajax';
+ $build['table'] = [
+ '#type' => 'table',
+ '#header' => $list_builder->buildHeader(),
+ '#rows' => [],
+ '#cache' => [],
+ '#empty' => $this->t('There are no queues available.'),
+ ];
+
+ /** @var \Drupal\entityqueue\EntitySubqueueInterface $subqueue */
+ foreach ($subqueues as $subqueue_id => $subqueue) {
+ $row = $list_builder->buildRow($subqueue);
+
+ // Check if entity is in queue
+ $subqueue_items = $subqueue->get('items')->getValue();
+ if (in_array($entity->id(), array_column($subqueue_items, 'target_id'), TRUE)) {
+ $row['operations']['data']['#links'] = [
+ 'remove-item' => [
+ 'title' => $this->t('Remove from queue'),
+ 'url' => Url::fromRoute('entity.entity_subqueue.remove_item', ['entity_queue' => $queues[$subqueue->bundle()]->id(), 'entity_subqueue' => $subqueue_id, 'entity' => $entity->id()]),
+ 'attributes' => [
+ 'class' => ['use-ajax'],
+ ],
+ ],
+ ];
+ }
+ else {
+ $row['operations']['data']['#links'] = [
+ 'add-item' => [
+ 'title' => $this->t('Add to queue'),
+ 'url' => Url::fromRoute('entity.entity_subqueue.add_item', ['entity_queue' => $queues[$subqueue->bundle()]->id(), 'entity_subqueue' => $subqueue_id, 'entity' => $entity->id()]),
+ 'attributes' => [
+ 'class' => ['use-ajax'],
+ ],
+ ],
+ ];
+ }
+
+ // Add an operation for editing the subqueue items.
+ // First, compute the destination to send the user back to the
+ // entityqueue tab they're currently on. We can't rely on <current>
+ // since if any of the AJAX links are used and the page is rebuilt,
+ // <current> will point to the most recent AJAX callback, not the
+ // original entityqueue tab.
+ $destination = Url::fromRoute("entity.$entity_type_id.entityqueue", [$entity_type_id => $entity->id()])->toString();
+ $row['operations']['data']['#links']['edit-subqueue-items'] = [
+ 'title' => $this->t('Edit subqueue items'),
+ 'url' => $subqueue->toUrl('edit-form', ['query' => ['destination' => $destination]]),
+ ];
+
+ $build['table']['#rows'][$subqueue->id()] = $row;
+ }
+
+ return $build;
+ }
+
/**
* Returns a form to add a new subqeue.
*
return $this->redirect('entity.entity_queue.collection');
}
+ /**
+ * Calls a method on an entity subqueue page and reloads the page.
+ *
+ * @param \Drupal\entityqueue\EntitySubqueueInterface $entity_subqueue
+ * The subqueue being acted upon.
+ * @param string $op
+ * The operation to perform, e.g., 'addItem' or 'removeItem'.
+ * @param \Symfony\Component\HttpFoundation\Request $request
+ * The current request.
+ *
+ * @return \Drupal\Core\Ajax\AjaxResponse|\Symfony\Component\HttpFoundation\RedirectResponse
+ * Either returns a rebuilt listing page as an AJAX response, or redirects
+ * back to the current page.
+ */
+ public function subqueueAjaxOperation(EntitySubqueueInterface $entity_subqueue, $op, Request $request) {
+ $entity_id = $request->get('entity');
+ $entity = $this->entityTypeManager()->getStorage($entity_subqueue->getQueue()->getTargetEntityTypeId())->load($entity_id);
+
+ // Perform the operation.
+ $entity_subqueue->$op($entity)->save();
+
+ // If the request is via AJAX, return the rendered list as JSON.
+ if ($request->request->get('js')) {
+ $route_match = RouteMatch::createFromRequest($request);
+ $list = $this->subqueueListForEntity($route_match, $entity->getEntityTypeId(), $entity);
+ $response = new AjaxResponse();
+ $response->addCommand(new ReplaceCommand('#entity-subqueue-list', $list));
+ return $response;
+ }
+
+ // Otherwise, redirect back to the page.
+ return $this->redirect('<current>');
+ }
+
+ /**
+ * Checks access for a specific request.
+ *
+ * @param \Drupal\Core\Routing\RouteMatchInterface $route_match
+ * The route match.
+ * @param string $entity_type_id
+ * (optional) The entity type ID.
+ *
+ * @return \Drupal\Core\Access\AccessResultInterface
+ * The access result.
+ */
+ public function access(RouteMatchInterface $route_match, $entity_type_id = NULL) {
+ /** @var \Drupal\Core\Entity\EntityInterface $entity */
+ $entity = $route_match->getParameter($entity_type_id);
+
+ if ($this->getAvailableQueuesForEntity($entity)) {
+ return AccessResult::allowed();
+ }
+
+ return AccessResult::forbidden();
+ }
+
+ /**
+ * Gets a list of queues which can hold this entity.
+ *
+ * @param \Drupal\Core\Entity\EntityInterface $entity
+ * An entity object.
+ *
+ * @return \Drupal\entityqueue\EntityQueueInterface[]
+ * An array of entity queues which can hold this entity.
+ */
+ protected function getAvailableQueuesForEntity(EntityInterface $entity) {
+ $storage = $this->entityTypeManager()->getStorage('entity_queue');
+
+ $queue_ids = $storage->getQuery()
+ ->condition('entity_settings.target_type', $entity->getEntityTypeId(), '=')
+ ->condition('status', TRUE)
+ ->execute();
+
+ $queues = $storage->loadMultiple($queue_ids);
+ $queues = array_filter($queues, function ($queue) use ($entity) {
+ /** @var \Drupal\entityqueue\EntityQueueInterface $queue */
+ $queue_settings = $queue->getEntitySettings();
+ $target_bundles = &$queue_settings['handler_settings']['target_bundles'];
+ return ($target_bundles === NULL || in_array($entity->bundle(), $target_bundles, TRUE));
+ });
+
+ return $queues;
+ }
+
}
projects / yaffs-website / blobdiff