Repository URL to install this package:
|
Version:
2.0.3 ▾
|
<?php
namespace Drupal\dds_content\Controller;
use Drupal\Component\Utility\Crypt;
use Drupal\Component\Utility\Html;
use Drupal\Component\Utility\Tags;
use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Database\Connection;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\KeyValueStore\KeyValueStoreInterface;
use Drupal\Core\Site\Settings;
use Drupal\path_alias\AliasManager;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
/**
* Defines a route controller for entity autocomplete form elements.
*/
class DDSContentEntityAutocompleteController extends ControllerBase {
/**
* The key value store.
*
* @var \Drupal\Core\KeyValueStore\KeyValueStoreInterface
*/
protected $keyValue;
/**
* The database connection service.
*
* @var \Drupal\Core\Database\Connection
*/
protected $database;
/**
* The path alias manager service.
*
* @var \Drupal\path_alias\AliasManager
*/
protected $pathAliasManager;
/**
* {@inheritdoc}
*/
public function __construct(
KeyValueStoreInterface $key_value,
Connection $database,
AliasManager $alias_manager,
EntityTypeManagerInterface $entity_type_manager
) {
$this->keyValue = $key_value;
$this->database = $database;
$this->pathAliasManager = $alias_manager;
$this->entityTypeManager = $entity_type_manager;
}
/**
* {@inheritdoc}
*/
public static function create(ContainerInterface $container) {
return new static(
$container->get('keyvalue')->get('entity_autocomplete'),
$container->get('database'),
$container->get('path_alias.manager'),
$container->get('entity_type.manager')
);
}
/**
* Autocomplete the label of an entity.
*
* @param string $target_type
* The ID of the target entity type.
* @param string $selection_handler
* The plugin ID of the entity reference selection handler.
* @param string $selection_settings_key
* The hashed key of the key/value entry that holds the selection handler
* settings.
*
* @return \Symfony\Component\HttpFoundation\JsonResponse
* The matched entity labels as a JSON response.
*
* @throws \Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException
* Thrown if the selection settings key is not found in the key/value store
* or if it does not match the stored data.
*/
public function handleAutocomplete($target_type, $selection_handler, $selection_settings_key) {
$request = \Drupal::request();
$matches = [];
// Get the typed string from the URL, if it exists.
if ($input = $request->query->get('q')) {
$typed_string = Tags::explode($input);
$typed_string = mb_strtolower(array_pop($typed_string));
// Selection settings are passed in as a hashed key of a serialized array
// stored in the key/value store.
$selection_settings = $this->keyValue->get($selection_settings_key, FALSE);
if ($selection_settings !== FALSE) {
$selection_settings_hash = Crypt::hmacBase64(serialize($selection_settings) . $target_type . $selection_handler, Settings::getHashSalt());
if ($selection_settings_hash !== $selection_settings_key) {
// Disallow access when the selection settings hash does not match the
// passed-in key.
throw new AccessDeniedHttpException('Invalid selection settings key.');
}
}
else {
// Disallow access when the selection settings key is not found in the
// key/value store.
throw new AccessDeniedHttpException();
}
try {
$query = $this->database->select('node_field_data', 'n');
$query->fields('n', ['nid', 'title']);
$query->condition('n.title', $typed_string . '%', 'LIKE');
$query->range(0, 10);
$execute = $query->execute();
if (!is_null($execute)) {
$nodes = $execute->fetchAll();
foreach ($nodes as $node) {
$key = $node->title . ' (' . $node->nid . ')';
// Strip things like starting/trailing white spaces,
// line breaks and tags.
$key = preg_replace('/\s\s+/', ' ', str_replace("\n", '', trim(Html::decodeEntities(strip_tags($key)))));
// Names containing commas or quotes must be wrapped in quotes.
$key = Tags::encode($key);
$matches['node' . $node->nid] = [
'value' => $key,
'label' => $node->title,
];
}
}
$query = $this->database->select('media_field_data', 'm');
$query->fields('m', ['mid', 'name']);
$query->condition('m.name', $typed_string . '%', 'LIKE');
$query->condition('m.bundle', 'dds_file');
$query->range(0, 10);
$execute = $query->execute();
if (!is_null($execute)) {
$medias = $this->entityTypeManager->getStorage('media')->loadMultiple($execute->fetchCol());
foreach ($medias as $media) {
if (!is_null($media) && $media->hasField('field_media_file')) {
/** @var \Drupal\file\Entity\File $file */
$file = $media->get('field_media_file')->entity;
if (is_null($file)) {
continue;
}
$matches['media' . $media->id()] = [
'value' => file_url_transform_relative(file_create_url($file->getFileUri())),
'label' => $media->label(),
];
}
}
}
if (count($matches) < 10) {
$query = $this->database->select('node_field_data', 'n');
$query->fields('n', ['nid', 'title']);
$query->condition('n.title', '%' . $typed_string . '%', 'LIKE');
$query->range(0, 10);
$execute = $query->execute();
if (!is_null($execute)) {
$nodes = $execute->fetchAll();
foreach ($nodes as $node) {
$key = $node->title . ' (' . $node->nid . ')';
// Strip things like starting/trailing white spaces,
// line breaks and tags.
$key = preg_replace('/\s\s+/', ' ', str_replace("\n", '', trim(Html::decodeEntities(strip_tags($key)))));
// Names containing commas or quotes must be wrapped in quotes.
$key = Tags::encode($key);
$matches['node' . $node->nid] = [
'value' => $key,
'label' => $node->title,
];
}
}
$query = $this->database->select('media_field_data', 'm');
$query->fields('m', ['mid', 'name']);
$query->condition('m.name', '%' . $typed_string . '%', 'LIKE');
$query->condition('m.bundle', 'dds_file');
$query->range(0, 10);
$execute = $query->execute();
if (!is_null($execute)) {
$medias = $this->entityTypeManager->getStorage('media')->loadMultiple($execute->fetchCol());
foreach ($medias as $media) {
if (!is_null($media) && $media->hasField('field_media_file')) {
/** @var \Drupal\file\Entity\File $file */
$file = $media->get('field_media_file')->entity;
if (is_null($file)) {
continue;
}
$matches['media' . $media->id()] = [
'value' => file_url_transform_relative(file_create_url($file->getFileUri())),
'label' => $media->label(),
];
}
}
}
}
if (count($matches) > 10) {
$matches = array_slice($matches, 0, 10);
}
}
catch (\Exception $e) {
\Drupal::logger('dds_content')->error($e->getMessage());
}
}
return new JsonResponse(array_values($matches));
}
}