ProfiledQueueWorker.php

<?php

namespace Perfbase\Drupal\Queue;

use Drupal\Core\Queue\QueueWorkerInterface;
use Perfbase\Drupal\Config\ConfigResolver;
use Perfbase\Drupal\Lifecycle\QueueItemLifecycle;
use Perfbase\Drupal\Runtime\PerfbaseFactoryInterface;
use Perfbase\Drupal\Support\ErrorHandler;

/**
 *
 */
class ProfiledQueueWorker implements QueueWorkerInterface {
  private QueueWorkerInterface $inner;

  private string $pluginId;

  private PerfbaseFactoryInterface $factory;

  private ConfigResolver $configResolver;

  private ErrorHandler $errorHandler;

  public function __construct(
    QueueWorkerInterface $inner,
    string $pluginId,
    PerfbaseFactoryInterface $factory,
    ConfigResolver $configResolver,
    ErrorHandler $errorHandler,
  ) {
    $this->inner = $inner;
    $this->pluginId = $pluginId;
    $this->factory = $factory;
    $this->configResolver = $configResolver;
    $this->errorHandler = $errorHandler;
  }

  /**
   * @param mixed $data
   */
  public function processItem($data): void {
    $lifecycle = new QueueItemLifecycle(
          $this->pluginId,
          $this->factory,
          $this->configResolver,
          $this->errorHandler
      );

    $lifecycle->startProfiling();

    try {
      $this->inner->processItem($data);
    }
    catch (\Throwable $exception) {
      $lifecycle->setException($exception->getMessage());
      throw $exception;
    } finally {
      $lifecycle->stopProfiling();
    }
  }

  /**
   *
   */
  public function getPluginId(): string {
    return (string) $this->inner->getPluginId();
  }

  /**
   * @return array<string, mixed>
   */
  public function getPluginDefinition(): array {
    $definition = $this->inner->getPluginDefinition();

    return is_array($definition) ? $definition : [];
  }

  /**
   *
   */
  public function getBaseId(): string {
    $parts = explode(':', $this->pluginId, 2);

    return $parts[0];
  }

  /**
   *
   */
  public function getDerivativeId(): ?string {
    $parts = explode(':', $this->pluginId, 2);

    return $parts[1] ?? NULL;
  }

  /**
   * @param array<int, mixed> $arguments
   * @return mixed
   */
  public function __call(string $name, array $arguments) {
    return $this->inner->{$name}(...$arguments);
  }

}