function varnish_image_purge_entity_update in Varnish purger 8

Same name and namespace in other branches

1. 8.2 modules/varnish_image_purge/varnish_image_purge.module \varnish_image_purge_entity_update()

Implements hook_entity_update().

File

modules/varnish_image_purge/varnish_image_purge.module, line 52

Contains varnish_image_purge.module.

Code

function varnish_image_purge_entity_update(EntityInterface $entity) {
  $bundle = $entity
    ->bundle();
  $entity_type = $entity
    ->getEntityTypeId();
  $entity_field_manager = \Drupal::service('entity_field.manager');
  $entity_types_to_purge = \Drupal::config('varnish_image_purge.configuration')
    ->get('entity_types');
  if (!(empty($entity_types_to_purge) || isset($entity_types_to_purge[$entity_type]) && in_array($bundle, $entity_types_to_purge[$entity_type]))) {
    return;
  }

  // Get the name(s) of the varnish purge configs, they get random suffix.
  // This is ugly, should be done better I guess.
  $query = \Drupal::database()
    ->select('config', 'c');
  $query
    ->fields('c', [
    'name',
  ]);
  $query
    ->condition('c.name', $query
    ->escapeLike('varnish_purger.settings') . '%', 'LIKE');
  $varnish_purgers = $query
    ->execute()
    ->fetchAllKeyed(0, 0);

  // Set the array to use for varnish purgers.
  $purgers = [];
  if (!isset($varnish_purgers)) {

    // There are no purgers enabled terminate early - the module is disabled.
    return;
  }

  // TODO: Does this exist? It's not using the purgers in ANY way.
  foreach ($varnish_purgers as $key => $value) {
    $config_purge = \Drupal::config($key);
    $purgers[$key]['hostname'] = $config_purge
      ->get('hostname');
    $purgers[$key]['port'] = $config_purge
      ->get('port');
  }

  //
  $class = \Drupal::entityTypeManager()
    ->getDefinition($entity_type)
    ->getOriginalClass();
  $interface = 'Drupal\\Core\\Entity\\FieldableEntityInterface';
  if (!in_array($interface, class_implements($class))) {

    // Not a fieldable entity - no chance to have image fields in - skipping.
    return;
  }
  $field_definitions = $entity_field_manager
    ->getFieldDefinitions($entity_type, $bundle);
  if (!isset($field_definitions)) {

    // No fields in an entity should be skipped as well.
    return;
  }
  $field_images = [];
  foreach ($field_definitions as $field_definition) {

    /* @var $field_definition Drupal\field\Entity\FieldConfig; */
    if ($field_definition
      ->getType() == 'image') {
      $field_images[] = $field_definition
        ->getName();
    }
  }
  if (empty($field_images)) {

    // No image fields on the entity
    return;
  }

  // Do the actual purging...

  /* @var $client Client */
  $client = \Drupal::service('http_client');

  // Generator for purge requests to be sent out.
  $requests = function () use ($client, $entity, $field_images) {
    $styles = ImageStyle::loadMultiple();
    foreach ($field_images as $field_image) {
      if ($entity->{$field_image}
        ->isEmpty()) {
        continue;
      }
      foreach ($entity->{$field_image} as $delta => $image_field) {
        $file = File::load($image_field->target_id);
        if (!$file instanceof FileInterface) {
          continue;
        }

        /* @var $style Drupal\image\Entity\ImageStyle; */
        foreach ($styles as $style) {
          $url = $style
            ->buildUrl($file
            ->getFileUri());
          (yield function () use ($client, $url) {
            return $client
              ->requestAsync('URIBAN', $url)
              ->then(function () {
            }, function ($reason) use ($url) {
              $message = $reason instanceof \Exception ? $reason
                ->getMessage() : (string) $reason;
              $logger = \Drupal::logger('varnish_image_purge');
              $logger
                ->error("URL not purged {$url} {$message}");
            });
          });
        }
      }
    }
  };

  // Prepare a POOL that will make the requests with a given concurrency.
  // TODO: Have the concurrency exposed as configuration somewhere.
  $concurrency = VarnishPurger::VARNISH_PURGE_CONCURRENCY;
  (new \GuzzleHttp\Pool($client, $requests(), [
    'concurrency' => $concurrency,
  ]))
    ->promise()
    ->wait();
}