You are here

protected function AcquiaPurgeProcessorAjax::registerUserAsQueueOwner in Acquia Purge 7

Register the current user as processing owner.

1 call to AcquiaPurgeProcessorAjax::registerUserAsQueueOwner()
AcquiaPurgeProcessorAjax::onItemsQueued in lib/processor/AcquiaPurgeProcessorAjax.php
Implements event onItemsQueued.

File

lib/processor/AcquiaPurgeProcessorAjax.php, line 272
Contains AcquiaPurgeProcessorAjax.

Class

AcquiaPurgeProcessorAjax
Process the queue using a AJAX client-side UI.

Code

protected function registerUserAsQueueOwner() {

  // Prevent registration on the CLI or as anonymous user.
  if (php_sapi_name() === 'cli' || !user_is_logged_in()) {
    return;
  }

  // Fetch the list of queue owners as stored in state data.
  $uiusers = $this->service
    ->state()
    ->get('uiusers', array())
    ->get();

  // Register the current user when its not yet registered.
  global $user;
  if (!in_array($user->name, $uiusers)) {
    $uiusers[] = $user->name;
    $this->service
      ->state()
      ->get('uiusers', array())
      ->set($uiusers);
  }
}