Stfalcon\Bundle\EventBundle\Command\StfalconMailerCommand

Complexity

Total Complexity

19

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	7	1
D	execute()	0	90	18

<?php

namespace Stfalcon\Bundle\EventBundle\Command;

use Application\Bundle\DefaultBundle\Service\MyMailer;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Stfalcon\Bundle\EventBundle\Entity\Mail;

/**
 * Class StfalconMailerCommand.
 */
class StfalconMailerCommand extends ContainerAwareCommand
{
    /**
     * Set options.
     */
    protected function configure()
    {
        $this
            ->setName('stfalcon:mailer')
            ->setDescription('Send message from queue')
            ->addOption('amount', null, InputOption::VALUE_OPTIONAL, 'Amount of mails which will send per operation. Default 10.')
            ->addOption('host', null, InputOption::VALUE_OPTIONAL, 'Site host. Default fwdays.com.');
    }

    /**
     * @param InputInterface  $input
     * @param OutputInterface $output
     *
     * @return int|null|void
     *
     * @throws \Doctrine\ORM\OptimisticLockException
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        /** @var \Symfony\Component\Routing\RequestContext $context */
        $context = $this->getContainer()->get('router')->getContext();
        $context->setHost('fwdays.com');
        $context->setScheme('http');

        $limit = 10;

        if ($input->getOption('amount')) {
            $limit = (int) $input->getOption('amount');
        }

        if ($input->getOption('host')) {
            $context->setHost($input->getOption('host'));

It seems like $input->getOption('host') can also be of type string[]; however, parameter $host of Symfony\Component\Routing\RequestContext::setHost() does only seem to accept string, maybe add an additional type check?

        }

        /** @var $em \Doctrine\ORM\EntityManager */
        $em = $this->getContainer()->get('doctrine.orm.entity_manager');
        /** @var $mailer MyMailer */
        $mailer = $this->getContainer()->get('app.my_mailer.service');
        /** @var $mailerHelper \Stfalcon\Bundle\EventBundle\Helper\StfalconMailerHelper */
        $mailerHelper = $this->getContainer()->get('stfalcon_event.mailer_helper');
        /** @var $queueRepository \Stfalcon\Bundle\EventBundle\Repository\MailQueueRepository */
        $queueRepository = $em->getRepository('StfalconEventBundle:MailQueue');

        $mailsQueue = $queueRepository->getMessages($limit);
        $logger = $this->getContainer()->get('logger');
        /* @var $mail Mail */
        foreach ($mailsQueue as $item) {
            $user = $item->getUser();
            $mail = $item->getMail();

            if (!(
                $user &&
                $mail &&
                $user->isEnabled() &&
                $user->isSubscribe() &&
                $user->isEmailExists() &&
                filter_var($user->getEmail(), FILTER_VALIDATE_EMAIL)
            )) {
                $mail->decTotalMessages();
                $em->remove($item);
                $em->flush();
                continue;
            }

            try {
                $message = $mailerHelper->formatMessage($user, $mail);
            } catch (\Exception $e) {
                $logger->addError('Mailer:'.$e->getMessage(), ['email' => $user->getEmail()]);

                $mail->decTotalMessages();
                $em->remove($item);
                $em->flush();
                continue;
            }

            $headers = $message->getHeaders();
            $http = $this->getContainer()->get('router')->generate(
                'unsubscribe',
                [
                    'hash' => $user->getSalt(),
                    'userId' => $user->getId(),
                    'mailId' => $mail->getId(),
                ],
                true
            );

            $headers->removeAll('List-Unsubscribe');
            $headers->addTextHeader('List-Unsubscribe', '<'.$http.'>');
            $failed = [];
            if ($mailer->send($message, $failed)) {
                $mail->incSentMessage();
                $item->setIsSent(true);
                $em->flush();
            } else {
                $logger->addError('Mailer send exception', [
                    'mail_id' => $mail->getId(),
                    'user_id' => $user->getId(),
                    'error_swift_message' => isset($failed['error_swift_message']) ? $failed['error_swift_message'] : '',
                    'error_swift_code' => isset($failed['error_swift_code']) ? $failed['error_swift_code'] : '',
                    'error_swift_trace' => isset($failed['error_swift_trace']) ? $failed['error_swift_trace'] : '',
                    'error_exception_message' => isset($failed['error_exception_message']) ? $failed['error_exception_message'] : '',
                    'error_exception_code' => isset($failed['error_exception_code']) ? $failed['error_exception_code'] : '',
                    'error_exception_trace' => isset($failed['error_exception_trace']) ? $failed['error_exception_trace'] : '',
                ]);
            }
        }
        $em->flush();
    }
}