class InitSubscriber in Acquia Connector 3.x

Class InitSubscriber.

Init (i.e., hook_init()) subscriber that displays a message asking you to connect to Acquia if you haven't already.

@package Drupal\acquia_connector\EventSubscriber

Hierarchy

• class \Drupal\acquia_connector\EventSubscriber\InitSubscriber implements \Symfony\Component\EventDispatcher\EventSubscriberInterface

1 string reference to 'InitSubscriber'

acquia_connector.services.yml in ./acquia_connector.services.yml

acquia_connector.services.yml

1 service uses InitSubscriber

acquia_connector.init_subscriber in ./acquia_connector.services.yml

Drupal\acquia_connector\EventSubscriber\InitSubscriber

File

src/EventSubscriber/InitSubscriber.php, line 24

Namespace

Drupal\acquia_connector\EventSubscriber

class InitSubscriber implements EventSubscriberInterface {

  /**
   * The config factory.
   *
   * @var \Drupal\Core\Config\ConfigFactoryInterface
   */
  protected $configFactory;

  /**
   * The state factory.
   *
   * @var \Drupal\Core\State\StateInterface
   */
  protected $state;

  /**
   * The cache backend.
   *
   * @var \Drupal\Core\Cache\CacheBackendInterface
   */
  protected $cache;

  /**
   * The spi backend.
   *
   * @var \Drupal\acquia_connector\Controller\SpiController
   */
  protected $spiController;

  /**
   * InitSubscriber constructor.
   *
   * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
   *   Config factory.
   * @param \Drupal\Core\State\StateInterface $state
   *   State.
   * @param \Drupal\Core\Cache\CacheBackendInterface $cache
   *   Cache backend.
   * @param \Drupal\acquia_connector\Controller\SpiController $spi_controller
   *   SPI backend.
   */
  public function __construct(ConfigFactoryInterface $config_factory, StateInterface $state, CacheBackendInterface $cache, SpiController $spi_controller) {
    $this->configFactory = $config_factory;
    $this->state = $state;
    $this->cache = $cache;
    $this->spiController = $spi_controller;
  }

  /**
   * Display a message asking the user to connect to Acquia.
   *
   * @param \Symfony\Component\HttpKernel\Event\GetResponseEvent $event
   *   Event.
   */
  public function onKernelRequest(GetResponseEvent $event) {
    acquia_connector_auto_connect();
    acquia_connector_show_free_tier_promo();

    // Move site data to State API.
    $site_name = $this->state
      ->get('spi.site_name');
    $current_site_name = $this->spiController
      ->checkAcquiaHosted() ? getenv('AH_SITE_ENVIRONMENT') . '_' . getenv('AH_SITE_NAME') : '';
    if (empty($site_name) || $site_name != $current_site_name) {
      $config = $this->configFactory
        ->getEditable('acquia_connector.settings');

      // Handle site name.
      $site_name = $this->spiController
        ->checkAcquiaHosted() ? getenv('AH_SITE_ENVIRONMENT') . '_' . getenv('AH_SITE_NAME') : $config
        ->get('spi.site_name');
      $site_machine_name = $this->spiController
        ->getAcquiaHostedMachineName() ?? $config
        ->get('spi.site_machine_name');
      if ($site_name) {
        $this->state
          ->set('spi.site_name', $site_name);
        $config
          ->clear('spi.site_name')
          ->save();
        $this->state
          ->set('spi.site_machine_name', $site_machine_name);
        $config
          ->clear('spi.site_machine_name')
          ->save();
      }
    }
  }

  /**
   * Refresh subscription information.
   *
   * @param \Symfony\Component\HttpKernel\Event\FilterControllerEvent $event
   *   Event.
   */
  public function onKernelController(FilterControllerEvent $event) {
    if ($event
      ->getRequest()->attributes
      ->get('_route') != 'update.manual_status') {
      return;
    }
    $controller = $event
      ->getController();

    /*
     * $controller passed can be either a class or a Closure.
     * This is not usual in Symfony but it may happen.
     * If it is a class, it comes in array format
     */
    if (!is_array($controller)) {
      return;
    }
    if ($controller[0] instanceof UpdateController) {

      // Refresh subscription information, so we are sure about our update
      // status. We send a heartbeat here so that all of our status information
      // gets updated locally via the return data.
      $subscription = new Subscription();
      $subscription
        ->update();
    }
  }

  /**
   * {@inheritdoc}
   */
  public static function getSubscribedEvents() {
    $events[KernelEvents::REQUEST][] = [
      'onKernelRequest',
    ];
    $events[KernelEvents::CONTROLLER][] = [
      'onKernelController',
    ];
    return $events;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
InitSubscriber::$cache	protected	property	The cache backend.
InitSubscriber::$configFactory	protected	property	The config factory.
InitSubscriber::$spiController	protected	property	The spi backend.
InitSubscriber::$state	protected	property	The state factory.
InitSubscriber::getSubscribedEvents	public static	function
InitSubscriber::onKernelController	public	function	Refresh subscription information.
InitSubscriber::onKernelRequest	public	function	Display a message asking the user to connect to Acquia.
InitSubscriber::__construct	public	function	InitSubscriber constructor.