PROCERGS\LoginCidadao\PhoneVerificationBundle\Event\UpdateSentVerificationSubscriber

Complexity

Total Complexity

10

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Test Coverage

Coverage

87.5%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
B	onStatusRequested()	0	30	5
A	__construct()	0	6	1
A	protectedGetStatus()	0	12	1
A	log()	0	4	2
A	getSubscribedEvents()	0	4	1

<?php
/**
 * This file is part of the login-cidadao project or it's bundles.
 *
 * (c) Guilherme Donato <guilhermednt on github>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace PROCERGS\LoginCidadao\PhoneVerificationBundle\Event;

use Eljam\CircuitBreaker\Breaker;
use LoginCidadao\PhoneVerificationBundle\Event\UpdateStatusEvent;
use LoginCidadao\PhoneVerificationBundle\Exception\InvalidSentVerificationStatusException;
use LoginCidadao\PhoneVerificationBundle\PhoneVerificationEvents;
use PROCERGS\Sms\Exception\InvalidStatusException;
use PROCERGS\Sms\Exception\SmsExceptionInterface;
use PROCERGS\Sms\Exception\TransactionNotFoundException;
use PROCERGS\Sms\Protocols\SmsInterface;
use PROCERGS\Sms\Protocols\SmsStatusInterface;
use PROCERGS\Sms\SmsService;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\LoggerTrait;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class UpdateSentVerificationSubscriber implements EventSubscriberInterface, LoggerAwareInterface
{
    use LoggerAwareTrait, LoggerTrait;

    /** @var SmsService */
    private $smsService;

    /** @var Breaker */
    private $breaker;

    /**
     * PhoneVerificationSubscriber constructor.
     *
     * @param SmsService $smsService
     * @param Breaker $breaker
     */
    public function __construct(
        SmsService $smsService,
        Breaker $breaker
    ) {
        $this->smsService = $smsService;
        $this->breaker = $breaker;
    }

    /**
     * Logs with an arbitrary level.
     *
     * @param mixed $level
     * @param string $message
     * @param array $context
     *
     * @return void
     */
    protected function log($level, $message, array $context = array())
    {
        if ($this->logger) {
            $this->logger->log($level, $message, $context);
        }
    }

    /**
     * Returns an array of event names this subscriber wants to listen to.
     *
     * The array keys are event names and the value can be:
     *
     *  * The method name to call (priority defaults to 0)
     *  * An array composed of the method name to call and the priority
     *  * An array of arrays composed of the method names to call and respective
     *    priorities, or 0 if unset
     *
     * For instance:
     *
     *  * array('eventName' => 'methodName')
     *  * array('eventName' => array('methodName', $priority))
     *  * array('eventName' => array(array('methodName1', $priority), array('methodName2')))
     *
     * @return array The event names to listen to
     */
    public static function getSubscribedEvents()
    {
        return [
            PhoneVerificationEvents::PHONE_VERIFICATION_GET_SENT_VERIFICATION_STATUS => 'onStatusRequested',
        ];
    }

    /**
     * @param UpdateStatusEvent $event
     * @throws \Exception
     */
    public function onStatusRequested(UpdateStatusEvent $event)
    {
        $transactionId = $event->getTransactionId();

        try {
            $sms = $this->protectedGetStatus($this->smsService, $transactionId);
            $status = $sms->getStatus();
            if (!$status instanceof SmsStatusInterface) {
                throw new InvalidSentVerificationStatusException(
                    "No status available for transaction {$transactionId}"
                );
            }
        } catch (TransactionNotFoundException $e) {
            return;
        } catch (SmsExceptionInterface $e) {
            throw new InvalidSentVerificationStatusException(
                "Error for transaction id {$transactionId}: {$e->getMessage()}",
                $e->getCode(),
                $e
            );
        } catch (InvalidSentVerificationStatusException $e) {
            throw new InvalidSentVerificationStatusException(
                "Error for transaction id {$transactionId}: {$e->getMessage()}",
                $e->getCode(),
                $e
            );
        }

        $event->setDeliveryStatus($status);

$status of type PROCERGS\Sms\Protocols\SmsStatusInterface is incompatible with the type LoginCidadao\PhoneVerificationBundle\Model\SmsStatusInterface expected by parameter $deliveryStatus of LoginCidadao\PhoneVerificationBundle\Event\UpdateStatusEvent::setDeliveryStatus().

        unset($sms);
    }

    /**
     * @param SmsService $smsService
     * @param $transactionId
     * @return SmsInterface
     * @throws \Exception|TransactionNotFoundException
     */
    private function protectedGetStatus(SmsService $smsService, $transactionId)
    {
        return $this->breaker->protect(
            function () use ($smsService, $transactionId) {

The import $smsService is not used and could be removed.

                $statuses = $this->smsService->getStatus($transactionId);

                $this->info(
                    'Updating status for transaction ID: {transaction_id}',
                    ['transaction_id' => $transactionId]
                );

                return $statuses;
            }
        );
    }
}