meteor.module

<?php

/**
 * @file
 * The Meteor SSO support module.
 *
 * @see OPERATION.md
 */

use Drupal\Core\Session\AccountInterface;
use Drupal\Core\Session\AccountProxyInterface;
use Drupal\field\FieldStorageConfigInterface;
use Drupal\meteor\IdentityListener;
use Drupal\user\UserInterface;

/**
 * Send a notification to a Meteor server.
 *
 * @param string $path
 *   The path reached in meteor.
 * @param array $query
 *   Optional query params.
 */
function _meteor_notify($path, $query = []) {
  /** @var \Drupal\meteor\Notifier $notifier */
  $notifier = \Drupal::service('meteor.notifier');
  $notifier->notify($path, $query);
}

/**
 * Send a notification to a Meteor server about a user event.
 *
 * @param string $event
 *   The name of an event: an EventListener string constant.
 * @param \Drupal\Core\Session\AccountInterface $account
 *   Optional. A user account.
 * @param int $delay
 *   Optional. A delay to send the notification.
 *
 * @see \Drupal\meteor\IdentityListener
 */
function _meteor_notify_user_event($event, AccountInterface $account = NULL, $delay = 0) {
  $query = [
    'event' => strval($event),
  ];

  $userId = $account instanceof AccountInterface ? intval($account->id()) : NULL;
  if (isset($userId)) {
    $query['userId'] = $userId;
  }

  if (isset($usDelay)) {
    $query['delay'] = abs(intval($usDelay));
  }

  _meteor_notify('drupalUserEvent', $query);
}

/**
 * Implements hook_field_storage_delete().
 *
 * One or more fields were deleted. If it happend on the user entity:
 * - all user accounts need to refresh their "whoami" information,
 * - they do not need to renew their login.
 */
function meteor_field_storage_config_delete(FieldStorageConfigInterface $entity) {
  if ($entity->getTargetEntityTypeId() != 'user') {
    return;
  }

  _meteor_notify_user_event(IdentityListener::FIELD_DELETE);
}

/**
 * Implements hook_field_storage_insert().
 *
 * One or more fields were added. If it happend on the user entity:
 * - all user accounts need to refresh their "whoami" information,
 * - they do not need to renew their login.
 */
function meteor_field_storage_config_insert(FieldStorageConfigInterface $entity) {
  if ($entity->getTargetEntityTypeId() != 'user') {
    return;
  }

  _meteor_notify_user_event(IdentityListener::FIELD_INSERT);
}

/**
 * Implements hook_field_storage_update().
 *
 * One or more fields were modified. If it happened on the user entity:
 * - all user accounts need to refresh their "whoami" information,
 * - they do not need to renew their login.
 */
function meteor_field_storage_config_update(FieldStorageConfigInterface $entity) {
  if ($entity->getTargetEntityTypeId() != 'user') {
    return;
  }

  _meteor_notify_user_event(IdentityListener::FIELD_UPDATE);
}

/**
 * Implements hook_user_delete().
 *
 * Note: this is the hook used on user cancel-as-delete.
 */
function meteor_user_delete(AccountInterface $account) {
  _meteor_notify_user_event(IdentityListener::USER_DELETE, $account);
}

/**
 * Implements hook_user_login().
 */
function meteor_user_login(AccountInterface $account) {
  _meteor_notify_user_event(IdentityListener::USER_LOGIN, $account, 1000);
}

/**
 * Implements hook_user_logout().
 */
function meteor_user_logout(AccountProxyInterface $account) {
  _meteor_notify_user_event(IdentityListener::USER_LOGOUT, $account->getAccount());
}

/**
 * Implements hook_ENTITY_TYPE_update().
 *
 * Note: this is the hook used on user cancel-as-blocked.
 *
 * Deletion is not entirely complete at this point: wait for one second for a
 * better chance for the transaction to be complete and user cache to be
 * flushed.
 */
function meteor_user_update(UserInterface $account) {
  _meteor_notify_user_event(IdentityListener::USER_UPDATE, $account, 1000);
}