Webhook\Bundle\Service\WebhookProcessor

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	process()	0	8	1
A	getSubscribedCommand()	0	11	1

<?php
declare(strict_types=1);

namespace Webhook\Bundle\Service;


use Enqueue\Client\CommandSubscriberInterface;
use Interop\Queue\PsrContext;
use Interop\Queue\PsrMessage;
use Interop\Queue\PsrProcessor;

/**
 * Class WebhookProcessor
 *
 * @package Webhook\Bundle\Service
 */
final class WebhookProcessor implements PsrProcessor, CommandSubscriberInterface
{
    public const NAME = 'webhook-processor';

    /** @var WebhookConsumer */
    private $consumer;

    /**
     * RatesProcessor constructor.
     *
     * @param WebhookConsumer $consumer
     */
    public function __construct(WebhookConsumer $consumer)
    {
        $this->consumer = $consumer;
    }

    /**
     * @param PsrMessage $message
     * @param PsrContext $context
     *
     * @return string
     */
    public function process(PsrMessage $message, PsrContext $context): string
    {
        $id = $message->getBody();

        $this->consumer->consume($id);

        return self::ACK;
    }

    /**
     * @return array
     */
    public static function getSubscribedCommand(): array
    {
        return [
            'processorName' => self::NAME,

            // these are optional, setting these option we make the migration smooth and backward compatible.
            'queueName' => 'webhooks',
            'queueNameHardcoded' => true,
            'exclusive' => true,
        ];
    }
}