Skip to content
Snippets Groups Projects
Commit 7540ed0b authored by Stefan Auditor's avatar Stefan Auditor
Browse files

Issue #3525556 by sanduhrs: Move hook implementations to class

parent de6fa578
Branches
No related tags found
1 merge request!15Resolve #3525556 "Move hook implementations"
Pipeline #502833 passed
Stage: build
Stage: validate
Stage: test
Show whitespace changes
Inline Side-by-side
phpstan-baseline.neon 0 → 100644
+ 6
− 0
View file @ 7540ed0b
parameters:
ignoreErrors:
-
message: "#^\\\\Drupal calls should be avoided in classes, use dependency injection instead$#"
count: 21
path: src/Hook/WebhooksHooks.php
src/Hook/WebhooksHooks.php 0 → 100644
+ 319
− 0
View file @ 7540ed0b
<?php
declare(strict_types=1);
namespace Drupal\webhooks\Hook;
use Drupal\Core\Entity\EntityInterface;
use Drupal\Core\Hook\Attribute\Hook;
use Drupal\Core\Routing\RouteMatchInterface;
use Drupal\Core\Session\AccountInterface;
use Drupal\user\Entity\User;
use Drupal\user\UserInterface;
use Drupal\webhooks\Webhook;
/**
* Hook implementations for webhooks module.
*/
class WebhooksHooks {
/**
* Implements hook_help().
*/
#[Hook('help')]
public function help($route_name, RouteMatchInterface $route_match): string|\Stringable|array|null {
switch ($route_name) {
case 'help.page.webhooks':
$output = '';
$output .= '<h3>' . t('Webhooks') . '</h3>';
$output .= '<p>' . t('User-defined HTTP callbacks.') . '</p>';
return $output;
}
return NULL;
}
/**
* Implements hook_entity_insert().
*/
#[Hook('entity_insert')]
public function entityInsert(EntityInterface $entity): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'create']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_entity_update().
*/
#[Hook('entity_update')]
public function entityUpdate(EntityInterface $entity): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'update']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_entity_delete().
*/
#[Hook('entity_delete')]
public function entityDelete(EntityInterface $entity): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'delete']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_cron().
*/
#[Hook('cron')]
public function cron(): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
$event = implode(':', ['system', 'cron']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_file_download().
*/
#[Hook('file_download')]
public function fileDownload($uri): array|int|null {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'file_download']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'uri' => $serializer->normalize($uri),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
return NULL;
}
/**
* Implements hook_modules_installed().
*/
#[Hook('modules_installed')]
public function modulesInstalled($modules, $is_syncing): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'modules_installed']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'modules' => $serializer->normalize($modules),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_cancel().
*/
#[Hook('user_cancel')]
public function userCancel($edit, UserInterface $account, $method): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_cancel']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_login().
*/
#[Hook('user_login')]
public function userLogin(UserInterface $account): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_login']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_logout().
*/
#[Hook('user_logout')]
public function userLogout(AccountInterface $account): void {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_logout']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_cache_flush().
*/
#[Hook('cache_flush')]
public function cacheFlush() {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
$event = implode(':', ['system', 'cache_flush']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
}
webhooks.module deleted 100644 → 0
+ 0
− 301
View file @ de6fa578
<?php
/**
* @file
* Contains webhooks.module.
*/
use Drupal\Core\Entity\EntityInterface;
use Drupal\Core\Routing\RouteMatchInterface;
use Drupal\Core\Session\AccountInterface;
use Drupal\user\Entity\User;
use Drupal\user\UserInterface;
use Drupal\webhooks\Webhook;
/**
* Implements hook_help().
*/
function webhooks_help($route_name, RouteMatchInterface $route_match) {
switch ($route_name) {
case 'help.page.webhooks':
$output = '';
$output .= '<h3>' . t('Webhooks') . '</h3>';
$output .= '<p>' . t('User-defined HTTP callbacks.') . '</p>';
return $output;
default:
}
}
/**
* Implements hook_entity_insert().
*/
function webhooks_entity_insert(EntityInterface $entity) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'create']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_entity_update().
*/
function webhooks_entity_update(EntityInterface $entity) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'update']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_entity_delete().
*/
function webhooks_entity_delete(EntityInterface $entity) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['entity', $entity->getEntityType()->id(), 'delete']);
$user = User::load(\Drupal::currentUser()->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
'entity' => $serializer->normalize($entity),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_cron().
*/
function webhooks_cron() {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
$event = implode(':', ['system', 'cron']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_file_download().
*/
function webhooks_file_download($uri) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'file_download']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'uri' => $serializer->normalize($uri),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_modules_installed().
*/
function webhooks_modules_installed($modules, $is_syncing) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'modules_installed']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'modules' => $serializer->normalize($modules),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_cancel().
*/
function webhooks_user_cancel($edit, UserInterface $account, $method) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_cancel']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_login().
*/
function webhooks_user_login(UserInterface $account) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_login']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_user_logout().
*/
function webhooks_user_logout(AccountInterface $account) {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
/** @var \Symfony\Component\Serializer\Serializer $serializer */
$serializer = \Drupal::service('serializer');
$event = implode(':', ['system', 'user_logout']);
$user = User::load($account->id());
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
'user' => $serializer->normalize($user),
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
/**
* Implements hook_cache_flush().
*/
function webhooks_cache_flush() {
/** @var \Drupal\webhooks\WebhooksService $webhooks_service */
$webhooks_service = \Drupal::service('webhooks.service');
$event = implode(':', ['system', 'cache_flush']);
$webhook_configs = $webhooks_service->loadMultipleByEvent($event);
/** @var \Drupal\webhooks\Entity\WebhookConfig $webhook_config */
foreach ($webhook_configs as $webhook_config) {
$webhook = new Webhook(
[
'event' => $event,
],
[],
$event,
$webhook_config->getContentType()
);
$webhooks_service->send($webhook_config, $webhook);
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment