HttpBundledPurger.php in Generic HTTP Purger 8

Namespace

Drupal\purge_purger_http\Plugin\Purge\Purger

File

src/Plugin/Purge/Purger/HttpBundledPurger.php

<?php

namespace Drupal\purge_purger_http\Plugin\Purge\Purger;

use Drupal\purge\Plugin\Purge\Invalidation\InvalidationInterface;
use Drupal\purge\Plugin\Purge\Purger\PurgerInterface;

/**
 * HTTP Bundled Purger.
 *
 * @PurgePurger(
 *   id = "httpbundled",
 *   label = @Translation("HTTP Bundled Purger"),
 *   configform = "\Drupal\purge_purger_http\Form\HttpBundledPurgerForm",
 *   cooldown_time = 0.0,
 *   description = @Translation("Configurable purger that sends a single HTTP request for a set of invalidation instructions."),
 *   multi_instance = TRUE,
 *   types = {},
 * )
 */
class HttpBundledPurger extends HttpPurgerBase implements PurgerInterface {

  /**
   * {@inheritdoc}
   */
  public function invalidate(array $invalidations) {

    // Create a simple closure to mass-update states on the objects.
    $set_state = function ($state) use ($invalidations) {
      foreach ($invalidations as $invalidation) {
        $invalidation
          ->setState($state);
      }
    };

    // Build up a single HTTP request, execute it and log errors.
    $token_data = [
      'invalidations' => $invalidations,
    ];
    $uri = $this
      ->getUri($token_data);
    $opt = $this
      ->getOptions($token_data);
    try {
      $this->client
        ->request($this->settings->request_method, $uri, $opt);
      $set_state(InvalidationInterface::SUCCEEDED);
    } catch (\Exception $e) {
      $set_state(InvalidationInterface::FAILED);

      // Log as much useful information as we can.
      $headers = $opt['headers'];
      unset($opt['headers']);
      $debug = json_encode(str_replace("\n", ' ', [
        'msg' => $e
          ->getMessage(),
        'uri' => $uri,
        'method' => $this->settings->request_method,
        'guzzle_opt' => $opt,
        'headers' => $headers,
      ]));
      $this
        ->logger()
        ->emergency("item failed due @e, details (JSON): @debug", [
        '@e' => get_class($e),
        '@debug' => $debug,
      ]);
    }
  }

}

Classes

Name	Description
HttpBundledPurger	HTTP Bundled Purger.