@sl1m_dogg

Отдает 500ую после отправки мейла через реббит, где может вонять?

Контроллер:
<?php

namespace MailerBundle\Controller;

use MailerBundle\Entity\EmailHandler\EmailReceiver;
use MailerBundle\Entity\EmailHandler\EmailSender;
use MailerBundle\Sender\AbstractSender;
use MailerBundle\Entity\Notification;
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\HttpFoundation\Request;

class EmailController extends Controller
{
    /**
     * @var AbstractSender
     */
    private $sender;

    /**
     * EmailController constructor.
     * @param AbstractSender $sender
     * @param ContainerInterface $container
     */
    public function __construct
    (
        AbstractSender $sender,
        ContainerInterface $container
    )
    {
        $this->sender = $sender;
        $this->container = $container;
    }

    /**
     * @return \Symfony\Component\HttpFoundation\Response
     */
    public function indexAction()
    {
        return $this->render('MailerBundle:Email:index.html.twig');
    }

    /**
     * @param Request $request
     * @return \Symfony\Component\HttpFoundation\Response
     */
    public function sendAction(Request $request)
    {
        $notification = new Notification();
        $user = $this->get('security.token_storage')->getToken()->getUser();
        $notification->setBody($request->request->get('subject'), $user);
        $notification->setSubject($request->request->get('body'));
        $notification->setTo($request->request->get('to'));

        $data = $notification->toJson($this->sender->getMail());

        try {
            $amqpSender = new EmailSender();
            $message = $amqpSender->send($data);

            $receiver = new EmailReceiver($this->sender);
            // echo "<pre>";
            // print_r($message); exit;
            $receiver->receive($message);
        } catch (\Exception $ex) {
            return $this->render('MailerBundle:Email:error.html.twig', [
                'error' => $ex->getMessage()
            ]);
        }

        return $this->render('MailerBundle:Email:success.html.twig');
    }
}


реббитовский отправщик:
<?php

namespace MailerBundle\Entity\EmailHandler;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class EmailSender extends AMQPHandler
{
    /**
     * @var AMQPStreamConnection
     */
    private $connection;

    /**
     * EmailSender constructor.
     */
    public function __construct()
    {
        $this->connection = $this->getConnection();
    }

    /**
     * @param $message
     * @return AMQPMessage
     */
    public function send($message)
    {
        $message = new AMQPMessage($message, ['delivery_mode' => 2]);
        $this->connection->basic_publish($message, '', 'email_queue');

        return $message;
    }
}


Получатель:
<?php

namespace MailerBundle\Entity\EmailHandler;

use MailerBundle\Sender\MailSender;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class EmailReceiver extends AMQPHandler
{
    /**
     * @var AMQPStreamConnection $connection
     */
    private $connection;

    /**
     * @var MailSender $sender
     */
    private $sender;

    /**
     * EmailReceiver constructor.
     * @param MailSender $sender
     */
    public function __construct(MailSender $sender)
    {
        $this->connection = $this->getConnection();
        $this->sender = $sender;
    }

    /**
     * @param AMQPMessage $message
     * @return AMQPMessage $message
     */
    public function receive(AMQPMessage $message)
    {
        $callback = function() use ($message)
        {
            $data = json_decode($message->body, true);
            $this->sender->send($data);
        };

        $this->connection->basic_qos(null, 1, null);
        $this->connection->basic_consume('email_queue', '', false, false, false, false, $callback);

        while(count($this->connection->callbacks)) {
            $this->connection->wait();
        }

        return $message;
    }
}


и класс для отправки письма:
<?php

namespace MailerBundle\Sender;

class MailSender extends AbstractSender
{
    /**
     * @var \Swift_Mailer
     */
    protected $transport;

    /**
     * @var string
     */
    private $userMail;

    /**
     * EmailSender constructor.
     * @param \Swift_Mailer $mailer
     * @param $name
     * @param $password
     */
    public function __construct(
        \Swift_Mailer $mailer,
        $name,
        $password
    )
    {
        $this->userMail = $name;
        $transport = \Swift_SmtpTransport::newInstance("smtp.gmail.com", 465, "ssl")
            ->setUsername($name)
            ->setPassword($password);

        $this->transport = $mailer::newInstance($transport);
    }

    /**
     * @return string
     */
    public function getMail()
    {
        return $this->userMail;
    }

    /**
     * @param array $notification
     * @return null
     */
    public function send($notification)
    {
        $message = \Swift_Message::newInstance($notification['subject'])
            ->setFrom([$notification['from']])
            ->setTo([$notification['to']])
            ->setBody($notification['body']);

        $this->transport->send($message);
    }
}


+ еще когда отправляю через гимейл на и.юа, не отправляется,
+ может кто писал тесты для свифтмейлера с рабочими моками, можете поделится?
  • Вопрос задан
  • 312 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы