SendgridRestTransport::sendApiCall() - Code Metrics - Inspection of "update sendgrid api" - bytic/mail - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 03a8f7...7b2ab5 )

by Gabriel
created 2022-03-16 22:46 UTC
SendgridRestTransport::sendApiCall() A

↳ Parent: SendgridRestTransport
Complexity

Conditions	3
Paths	3
Size

Total Lines	18
Code Lines	13
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	3
eloc	13
c	1
b	0
f	0
nc	3
nop	1
dl	0
loc	18
rs	9.8333
<?php
declare(strict_types=1);

namespace Nip\Mail\Transport;

use Exception;
use Nip\Mail\Message;
use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\Log\LoggerInterface;
use SendGrid;
use SendGrid\Mail\Attachment;
use SendGrid\Mail\Content;
use SendGrid\Mail\Mail;
use SendGrid\Mail\Personalization;
use SendGrid\Mail\To;
use Symfony\Component\Mailer\Exception\TransportException;
use Symfony\Component\Mailer\SentMessage;
use Symfony\Component\Mailer\Transport\AbstractTransport;
use Symfony\Component\Mime\Part\DataPart;

/**
 * Class SendgridTransport
 * @package Nip\Mail\Transport
 */
class SendgridRestTransport extends AbstractTransport
{
    /** @var string|null */
    protected ?string $apiKey;

    public function __construct(EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
    {
        parent::__construct($dispatcher, $logger);
    }

    /**
     * @return null|string
     */
    public function getApiKey(): ?string
    {
        return $this->apiKey;
    }

    /**
     * @throws SendGrid\Mail\TypeException
     */
    protected function doSend(SentMessage $message): void
    {
        $mail = new Mail();

        $message = $message->getOriginalMessage();

        /** @var Message $message */
        $this->populateSenders($message, $mail);
        $this->populatePersonalization($message, $mail);
        $this->populateContent($message, $mail);
        $this->populateCustomArg($message, $mail);

        $this->sendApiCall($mail);
    }


    /**
     * @param \Symfony\Component\Mime\Message $message
     * @param Mail $mail
     * @throws SendGrid\Mail\TypeException
     */
    protected function populateSenders(\Symfony\Component\Mime\Message $message, Mail $mail)
    {
        $addresses = $message->getFrom();
        $addresses = $message->getFrom();
        foreach ($addresses as $address) {
            $mail->setFrom($address->getAddress(), $address->getName());
            $mail->setReplyTo($address->getAddress(), $address->getName());
        }
        $reply = $message->getReplyTo();
        $reply = $message->getReplyTo();
        foreach ($reply as $address) {
            $mail->setReplyTo($address->getAddress(), $address->getName());
        }
    }

    /**
     * @param Message $message
     * @param Mail $mail
     * @throws SendGrid\Mail\TypeException
     */
    protected function populatePersonalization(Message $message, Mail $mail)
    {
        $emailsTos = $message->getTo();
        $personalizationIndex = 0;
        foreach ($emailsTos as $emailTo => $nameTo) {
            $personalization = $this->generatePersonalization($emailTo, $nameTo, $message, $personalizationIndex);
            $mail->addPersonalization($personalization);
            $personalizationIndex++;
        }
    }

    /**
     * @param $emailTo
     * @param $nameTo
     * @param Message $message
     * @param integer $i
     * @return Personalization
     * @throws SendGrid\Mail\TypeException
     */
    protected function generatePersonalization($emailTo, $nameTo, Message $message, $i): Personalization
    {
        $personalization = new Personalization();

        $email = new To($emailTo, $nameTo);
        $personalization->addTo($email);

        $personalization->setSubject($message->getSubject());

        $mergeTags = $message->getMergeTags();
        foreach ($mergeTags as $varKey => $value) {
            if (is_array($value)) {
                $value = $value[$i];
            }
            $value = (string)$value;
            $personalization->addSubstitution('{{' . $varKey . '}}', $value);
        }

        return $personalization;
    }

    /**
     * @param Message $message
     * @param Mail $mail
     * @throws SendGrid\Mail\TypeException
     */
    protected function populateContent(Message $message, Mail $mail)
    {
        foreach ($message->getAttachments() as $attachment) {
            $this->addAttachment($attachment, $mail);
        }

        $content = new Content("text/plain", $message->getTextBody());
        $content = new Content("text/plain", /** @scrutinizer ignore-type */ $message->getTextBody());
        $mail->addContent($content);

        $content = new Content("text/html", $message->getHtmlBody());
        $mail->addContent($content);
    }

    /**
     * @param DataPart $attachment
     * @param Mail $mail
     * @throws SendGrid\Mail\TypeException
     */
    protected function addAttachment(DataPart $attachment, $mail)
    {
        $headers = $attachment->getPreparedHeaders();
        $filename = $headers->getHeaderParameter('Content-Disposition', 'filename');
        $disposition = $headers->getHeaderBody('Content-Disposition');

        $sgAttachment = new Attachment();
        $sgAttachment->setContent(str_replace("\r\n", '', $attachment->bodyToString()));
        $sgAttachment->setType($headers->get('Content-Type')->getBody());
        $sgAttachment->setFilename($filename);
        $sgAttachment->setDisposition($disposition);

        if ('inline' === $disposition) {
            $sgAttachment->setContentID($filename);
        }

        $mail->addAttachment($sgAttachment);
    }

    /**
     * @param Message $message
     * @param $mail
     */
    protected function populateCustomArg(Message $message, $mail)
    {
        $args = $message->getCustomArgs();
        foreach ($args as $key => $value) {
            if ($key == 'category') {
                $mail->addCategory($value);
            } else {
                $mail->addCustomArg($key, (string)$value);
            }
        }
    }

    /**
     * @return bool
     * @throws TransportException
     */
    protected function sendApiCall($mail): bool
    {
        $sendGrid = $this->createApi();
        try {
            $response = $sendGrid->send($mail);
        } catch (Exception $exception) {
            throw new TransportException(
                'Error sending email Code [' . $exception->getMessage() . ']'
            );
        }

        if ($response->statusCode() == '202') {
            return true;
        } else {
            throw new TransportException(
                'Error sending email Code [' . $response->statusCode() . ']. '
                . 'HEADERS [' . print_r($response->headers())
                . 'HEADERS [' . /** @scrutinizer ignore-type */ print_r($response->headers())
                . $response->body()
            );
        }
    }

    /**
     * @return SendGrid
     * @throws TransportException
     */
    protected function createApi(): SendGrid
    {
        if ($this->getApiKey() === null) {
            throw new TransportException('Cannot create instance of \SendGrid while API key is NULL');
        }

        return new SendGrid($this->getApiKey());
    }

    /**
     * @param string $apiKey
     * @return $this
     */
    public function setApiKey($apiKey): self
    {
        $this->apiKey = $apiKey;

        return $this;
    }

    public function __toString(): string
    {
        return 'sendgrid';
    }
}

bytic / mail

Push — master ( 03a8f7...7b2ab5 )

SendgridRestTransport::sendApiCall() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
