1 <?php

     2 

     3 /*

     4  * This file is part of the Symfony package.

     5  *

     6  * (c) Fabien Potencier <fabien@symfony.com>

     7  *

     8  * For the full copyright and license information, please view the LICENSE

     9  * file that was distributed with this source code.

    10  */

    11 

    12 namespace Symfony\Bundle\SwiftmailerBundle\Command;

    13 

    14 use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;

    15 use Symfony\Component\Console\Input\InputInterface;

    16 use Symfony\Component\Console\Output\OutputInterface;

    17 use Symfony\Component\Console\Input\InputOption;

    18 

    19 /**

    20  * Send Emails from the spool.

    21  *

    22  * @author Fabien Potencier <fabien@symfony.com>

    23  * @author Clément JOBEILI <clement.jobeili@gmail.com>

    24  */

    25 class SendEmailCommand extends ContainerAwareCommand

    26 {

    27     /**

    28      * @see Command

    29      */

    30     protected function configure()

    31     {

    32         $this

    33             ->setName('swiftmailer:spool:send')

    34             ->setDescription('Send emails from the spool')

    35             ->addOption('message-limit', 0, InputOption::VALUE_OPTIONAL, 'The maximum number of messages to send.')

    36             ->addOption('time-limit', 0, InputOption::VALUE_OPTIONAL, 'The time limit for sending messages (in seconds).')

    37             ->setHelp(<<<EOF

    38 The <info>swiftmailer:spool:send</info> command sends all emails from the spool.

    39 

    40 <info>php app/console swiftmailer:spool:send --message-limit=10 --time-limit=10</info>

    41 

    42 EOF

    43             )

    44         ;

    45     }

    46 

    47     /**

    48      * {@inheritdoc}

    49      */

    50     protected function execute(InputInterface $input, OutputInterface $output)

    51     {

    52         $mailer     = $this->getContainer()->get('mailer');

    53         $transport  = $mailer->getTransport();

    54 

    55         if ($transport instanceof \Swift_Transport_SpoolTransport) {

    56             $spool = $transport->getSpool();

    57             $spool->setMessageLimit($input->getOption('message-limit'));

    58             $spool->setTimeLimit($input->getOption('time-limit'));

    59             $sent = $spool->flushQueue($this->getContainer()->get('swiftmailer.transport.real'));

    60 

    61             $output->writeln(sprintf('sent %s emails', $sent));

    62         }

    63     }

    64 }