SentryExceptionCatcherProcessor for Swarrot

SentryExceptionCatcherProcessor.php

<?php

namespace Hexanet\Si\AppBundle\Processor\Swarrot;

use Swarrot\Broker\Message;
use Swarrot\Processor\ProcessorInterface;

class SentryExceptionCatcherProcessor implements ProcessorInterface
{
    /**
     * @var ProcessorInterface
     */
    private $processor;

    /**
     * @var \Raven_Client|null
     */
    private $client;

    /**
     * @param ProcessorInterface $processor
     * @param \Raven_Client|null $client
     */
    public function __construct(ProcessorInterface $processor, \Raven_Client $client = null)
    {
        $this->processor = $processor;
        $this->client = $client;
    }

    /**
     * {@inheritdoc}
     */
    public function process(Message $message, array $options)
    {
        try {
            return $this->processor->process($message, $options);
        } catch (\Throwable $e) {
            $this->handleException($e, $message, $options);
        } catch (\Exception $e) {
            $this->handleException($e, $message, $options);
        }
    }

    /**
     * @param \Throwable|\Exception  $exception
     * @param Message                $message
     * @param array                  $options
     *
     * @throws \Throwable|\Exception
     */
    private function handleException($exception, Message $message, array $options)
    {
        $properties = $message->getProperties();

        $data = [
            'tags' => [
                'routing_key' => $properties['routing_key'] ?? '',
                'queue' => $options['queue'] ?? '',
            ],
            'extra' => [
                'message' => $message->getBody(),
            ]
        ];

        $this->client and $this->client->captureException($exception, $data);
        throw $exception;
    }
}