SparkPostCourier::getContentHeaders() - Code Metrics - Inspection of "Send custom headers from Email object (#17)" - quartzy/courier - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( d32337...505a31 )

by Chris

created 2018-02-25 22:43 UTC

SparkPostCourier::getContentHeaders() A

↳ Parent: SparkPostCourier

Complexity

Conditions	3
Paths	4

Size

Total Lines	13
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	13
ccs	7
cts	7
cp	1
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	6
nc	4
nop	1
crap	3

<?php

declare(strict_types=1);

namespace Courier;

use Courier\Exceptions\TransmissionException;
use Courier\Exceptions\UnsupportedContentException;
use Courier\Exceptions\ValidationException;
use PhpEmail\Address;
use PhpEmail\Attachment;
use PhpEmail\Content;
use PhpEmail\Email;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use SparkPost\SparkPost;
use SparkPost\SparkPostException;
use SparkPost\SparkPostResponse;

/**
 * A courier implementation using SparkPost as the third-party provider. This library uses the web API and the
 * php-sparkpost library to send transmissions.
 *
 * An important note is that while the SparkPost API does not support sending attachments on templated transmissions,
 * this API simulates the feature by creating an inline template based on the defined template using the API. In this
 * case, all template variables will be sent as expected, but tracking/reporting may not work as expected within
 * SparkPost.
 */
class SparkPostCourier implements ConfirmingCourier
{
    use SavesReceipts;

    const RECIPIENTS        = 'recipients';
    const CC                = 'cc';
    const BCC               = 'bcc';
    const REPLY_TO          = 'reply_to';
    const SUBSTITUTION_DATA = 'substitution_data';

    const CONTENT     = 'content';
    const FROM        = 'from';
    const SUBJECT     = 'subject';
    const HTML        = 'html';
    const TEXT        = 'text';
    const ATTACHMENTS = 'attachments';
    const TEMPLATE_ID = 'template_id';

    const HEADERS   = 'headers';
    const CC_HEADER = 'CC';

    const ADDRESS       = 'address';
    const CONTACT_NAME  = 'name';
    const CONTACT_EMAIL = 'email';
    const HEADER_TO     = 'header_to';

    const ATTACHMENT_NAME = 'name';
    const ATTACHMENT_TYPE = 'type';
    const ATTACHMENT_DATA = 'data';

    /**
     * @var SparkPost
     */
    private $sparkPost;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @param SparkPost       $sparkPost
     * @param LoggerInterface $logger
     */
    public function __construct(SparkPost $sparkPost, LoggerInterface $logger = null)
    {
        $this->sparkPost = $sparkPost;
        $this->logger    = $logger ?: new NullLogger();
    }

    public function deliver(Email $email): void
    {
        if (!$this->supportsContent($email->getContent())) {
            throw new UnsupportedContentException($email->getContent());
        }

        $mail = $this->prepareEmail($email);
        $mail = $this->prepareContent($email, $mail);

        $response = $this->send($mail);

        $this->saveReceipt($email, $response->getBody()['results']['id']);
    }

    /**
     * @param array $mail
     *
     * @return SparkPostResponse
     */
    protected function send(array $mail): SparkPostResponse
    {
        $promise = $this->sparkPost->transmissions->post($mail);

        try {
            return $promise->wait();
        } catch (SparkPostException $e) {
            $this->logger->error(
                'Received status {code} from SparkPost with body: {body}',
                [
                    'code' => $e->getCode(),
                    'body' => $e->getBody(),
                ]
            );

            throw new TransmissionException($e->getCode(), $e);
        }
    }

    /**
     * @return array
     */
    protected function supportedContent(): array
    {
        return [
            Content\EmptyContent::class,
            Content\Contracts\SimpleContent::class,
            Content\Contracts\TemplatedContent::class,
        ];
    }

    /**
     * Determine if the content is supported by this courier.
     *
     * @param Content $content
     *
     * @return bool
     */
    protected function supportsContent(Content $content): bool
    {
        foreach ($this->supportedContent() as $contentType) {
            if ($content instanceof $contentType) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param Email $email
     *
     * @return array
     */
    protected function prepareEmail(Email $email): array
    {
        $message  = [];
        $headerTo = $this->buildHeaderTo($email);

        $message[self::RECIPIENTS] = [];

        foreach ($email->getToRecipients() as $recipient) {
            $message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
        }

        foreach ($email->getCcRecipients() as $recipient) {
            $message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
        }

        foreach ($email->getBccRecipients() as $recipient) {
            $message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
        }

        return $message;
    }

    /**
     * @param Email $email
     * @param array $message
     *
     * @return array
     */
    protected function prepareContent(Email $email, array $message): array
    {
        switch (true) {
            case $email->getContent() instanceof Content\Contracts\TemplatedContent:
                $message[self::CONTENT]           = $this->buildTemplateContent($email);
                $message[self::SUBSTITUTION_DATA] = $this->buildTemplateData($email);

                break;

            case $email->getContent() instanceof Content\EmptyContent:
                $email->setContent(new Content\SimpleContent(
                    new Content\SimpleContent\Message(''),
                    new Content\SimpleContent\Message('')
                ));

                $message[self::CONTENT] = $this->buildSimpleContent($email);

                break;

            case $email->getContent() instanceof Content\SimpleContent:
                $message[self::CONTENT] = $this->buildSimpleContent($email);
        }

        return $message;
    }

    /**
     * Attempt to create template data using the from, subject and reply to, which SparkPost considers to be
     * part of the templates substitutable content.
     *
     * @param Email $email
     *
     * @return array
     */
    protected function buildTemplateData(Email $email): array
    {
        /** @var Content\TemplatedContent $emailContent */
        $emailContent = $email->getContent();
        $templateData = $emailContent->getTemplateData();

        if ($email->getReplyTos()) {
            $replyTos = $email->getReplyTos();
            $first    = reset($replyTos);

            if (!array_key_exists('replyTo', $templateData)) {
                $templateData['replyTo'] = $first->toRfc2822();
            }
        }

        if (!array_key_exists('fromName', $templateData)) {
            $templateData['fromName'] = $email->getFrom()->getName();
        }

        if (!array_key_exists('fromEmail', $templateData)) {
            $templateData['fromEmail'] = explode('@', $email->getFrom()->getEmail())[0];
        }

        if (!array_key_exists('fromDomain', $templateData)) {
            $templateData['fromDomain'] = explode('@', $email->getFrom()->getEmail())[1];
        }

        if (!array_key_exists('subject', $templateData)) {
            $templateData['subject'] = $email->getSubject();
        }

        // @TODO Remove this variable once SparkPost CC headers work properly for templates
        if (!array_key_exists('ccHeader', $templateData)) {
            if ($header = $this->buildCcHeader($email)) {
                $templateData['ccHeader'] = $header;
            }
        }

        return $templateData;
    }

    /**
     * @param Email $email
     *
     * @return array
     */
    protected function buildTemplateContent(Email $email): array
    {
        $content = [
            self::TEMPLATE_ID => $email->getContent()->getTemplateId(),
        ];

        $content[self::HEADERS] = $this->getContentHeaders($email);

        if ($email->getAttachments()) {
            /*
             * SparkPost does not currently support sending attachments with templated emails. For this reason,
             * we will instead get the template from SparkPost and create a new inline template using the information
             * from it instead.
             */
            $template    = $this->getTemplate($email);
            $inlineEmail = clone $email;

            $inlineEmail
                ->setSubject($template[self::SUBJECT])
                ->setContent($this->getInlineContent($template));

            // If the from contains a templated from, it should be actively replaced now to avoid validation errors.
            if (strpos($template[self::FROM][self::CONTACT_EMAIL], '{{') !== false) {
                $inlineEmail->setFrom($email->getFrom());
            } else {
                $inlineEmail->setFrom(
                    new Address(
                        $template[self::FROM][self::CONTACT_EMAIL],
                        $template[self::FROM][self::CONTACT_NAME]
                    )
                );
            }

            // If the form contains a templated replyTo, it should be actively replaced now to avoid validation errors.
            if (array_key_exists(self::REPLY_TO, $template)) {
                if (strpos($template[self::REPLY_TO], '{{') !== false) {
                    if (empty($email->getReplyTos())) {
                        throw new ValidationException('Reply to is templated but no value was given');
                    }

                    $inlineEmail->setReplyTos($email->getReplyTos()[0]);
                } else {
                    $inlineEmail->setReplyTos(Address::fromString($template[self::REPLY_TO]));
                }
            }

            $content = $this->buildSimpleContent($inlineEmail);

            // If the template AND content include headers, merge them
            // if only the template includes headers, then just use that
            if (array_key_exists(self::HEADERS, $template) && array_key_exists(self::HEADERS, $content)) {
                $content[self::HEADERS] = array_merge($template[self::HEADERS], $content[self::HEADERS]);
            } elseif (array_key_exists(self::HEADERS, $template)) {
                $content[self::HEADERS] = $template[self::HEADERS];
            }
        }

        return $content;
    }

    /**
     * @param Email $email
     *
     * @return array
     */
    protected function buildSimpleContent(Email $email): array
    {
        $attachments = [];

        foreach ($email->getAttachments() as $attachment) {
            $attachments[] = $this->buildAttachment($attachment);
        }

        $replyTo = null;
        if (!empty($email->getReplyTos())) {
            // SparkPost only supports a single reply-to
            $replyTos = $email->getReplyTos();
            $first    = reset($replyTos);

            $replyTo = $first->toRfc2822();
        }

        /** @var Content\Contracts\SimpleContent $emailContent */
        $emailContent = $email->getContent();

        $content = [
            self::FROM => [
                self::CONTACT_NAME  => $email->getFrom()->getName(),
                self::CONTACT_EMAIL => $email->getFrom()->getEmail(),
            ],
            self::SUBJECT     => $email->getSubject(),
            self::HTML        => $emailContent->getHtml() !== null ? $emailContent->getHtml()->getBody() : null,
            self::TEXT        => $emailContent->getText() !== null ? $emailContent->getText()->getBody() : null,
            self::ATTACHMENTS => $attachments,
            self::REPLY_TO    => $replyTo,
        ];

        $content[self::HEADERS] = $this->getContentHeaders($email);

        return $content;
    }

    protected function getContentHeaders(Email $email): array
    {
        $headers = [];

        if ($ccHeader = $this->buildCcHeader($email)) {
            $headers[self::CC_HEADER] = $ccHeader;
        }

        foreach ($email->getHeaders() as $header) {
            $headers[$header->getField()] = $header->getValue();
        }

        return $headers;
    }

    /**
     * Create the SimpleContent based on the SparkPost template data.
     *
     * @param array $template
     *
     * @return Content\SimpleContent
     */
    protected function getInlineContent(array $template): Content\SimpleContent
    {
        $htmlContent = null;
        if (array_key_exists(self::HTML, $template)) {
            $htmlContent = new Content\SimpleContent\Message($template[self::HTML]);
        }

        $textContent = null;
        if (array_key_exists(self::TEXT, $template)) {
            $textContent = new Content\SimpleContent\Message($template[self::TEXT]);
        }

        return new Content\SimpleContent($htmlContent, $textContent);
    }

    /**
     * Get the template content from SparkPost.
     *
     * @param Email $email
     *
     * @throws TransmissionException
     *
     * @return array
     */
    private function getTemplate(Email $email): array
    {
        try {
            $response = $this->sparkPost->syncRequest('GET', "templates/{$email->getContent()->getTemplateId()}");

            return $response->getBody()['results'][self::CONTENT];
        } catch (SparkPostException $e) {
            $this->logger->error(
                'Received status {code} from SparkPost while retrieving template with body: {body}',
                [
                    'code' => $e->getCode(),
                    'body' => $e->getBody(),
                ]
            );

            throw new TransmissionException($e->getCode(), $e);
        }
    }

    /**
     * @param Attachment $attachment
     *
     * @return array
     */
    private function buildAttachment(Attachment $attachment): array
    {
        return [
            self::ATTACHMENT_NAME => $attachment->getName(),
            self::ATTACHMENT_TYPE => $attachment->getContentType(),
            self::ATTACHMENT_DATA => $attachment->getBase64Content(),
        ];
    }

    /**
     * @param Address $address
     * @param string  $headerTo
     *
     * @return array
     */
    private function createAddress(Address $address, string $headerTo): array
    {
        return [
            self::ADDRESS => [
                self::CONTACT_EMAIL => $address->getEmail(),
                self::HEADER_TO     => $headerTo,
            ],
        ];
    }

    /**
     * Build a string representing the header_to field of this email.
     *
     * @param Email $email
     *
     * @return string
     */
    private function buildHeaderTo(Email $email): string
    {
        return implode(',', array_map(function (Address $address) {
            return $address->toRfc2822();
        }, $email->getToRecipients()));
    }

    /**
     * Build a string representing the CC header for this email.
     *
     * @param Email $email
     *
     * @return string
     */
    private function buildCcHeader(Email $email): string
    {
        return implode(',', array_map(function (Address $address) {
            return $address->toRfc2822();
        }, $email->getCcRecipients()));
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Courier;
6
7		use Courier\Exceptions\TransmissionException;
8		use Courier\Exceptions\UnsupportedContentException;
9		use Courier\Exceptions\ValidationException;
10		use PhpEmail\Address;
11		use PhpEmail\Attachment;
12		use PhpEmail\Content;
13		use PhpEmail\Email;
14		use Psr\Log\LoggerInterface;
15		use Psr\Log\NullLogger;
16		use SparkPost\SparkPost;
17		use SparkPost\SparkPostException;
18		use SparkPost\SparkPostResponse;
19
20		/**
21		* A courier implementation using SparkPost as the third-party provider. This library uses the web API and the
22		* php-sparkpost library to send transmissions.
23		*
24		* An important note is that while the SparkPost API does not support sending attachments on templated transmissions,
25		* this API simulates the feature by creating an inline template based on the defined template using the API. In this
26		* case, all template variables will be sent as expected, but tracking/reporting may not work as expected within
27		* SparkPost.
28		*/
29		class SparkPostCourier implements ConfirmingCourier
30		{
31		use SavesReceipts;
32
33		const RECIPIENTS = 'recipients';
34		const CC = 'cc';
35		const BCC = 'bcc';
36		const REPLY_TO = 'reply_to';
37		const SUBSTITUTION_DATA = 'substitution_data';
38
39		const CONTENT = 'content';
40		const FROM = 'from';
41		const SUBJECT = 'subject';
42		const HTML = 'html';
43		const TEXT = 'text';
44		const ATTACHMENTS = 'attachments';
45		const TEMPLATE_ID = 'template_id';
46
47		const HEADERS = 'headers';
48		const CC_HEADER = 'CC';
49
50		const ADDRESS = 'address';
51		const CONTACT_NAME = 'name';
52		const CONTACT_EMAIL = 'email';
53		const HEADER_TO = 'header_to';
54
55		const ATTACHMENT_NAME = 'name';
56		const ATTACHMENT_TYPE = 'type';
57		const ATTACHMENT_DATA = 'data';
58
59		/**
60		* @var SparkPost
61		*/
62		private $sparkPost;
63
64		/**
65		* @var LoggerInterface
66		*/
67		private $logger;
68
69		/**
70		* @param SparkPost $sparkPost
71		* @param LoggerInterface $logger
72		*/
73	12	public function __construct(SparkPost $sparkPost, LoggerInterface $logger = null)
74		{
75	12	$this->sparkPost = $sparkPost;
76	12	$this->logger = $logger ?: new NullLogger();
77		}
78
79	12	public function deliver(Email $email): void
80		{
81	12	if (!$this->supportsContent($email->getContent())) {
82	1	throw new UnsupportedContentException($email->getContent());
83		}
84
85	11	$mail = $this->prepareEmail($email);
86	11	$mail = $this->prepareContent($email, $mail);
87
88	9	$response = $this->send($mail);
89
90	8	$this->saveReceipt($email, $response->getBody()['results']['id']);
91		}
92
93		/**
94		* @param array $mail
95		*
96		* @return SparkPostResponse
97		*/
98	9	protected function send(array $mail): SparkPostResponse
99		{
100	9	$promise = $this->sparkPost->transmissions->post($mail);
101
102		try {
103	9	return $promise->wait();
104	1	} catch (SparkPostException $e) {
105	1	$this->logger->error(
106	1	'Received status {code} from SparkPost with body: {body}',
107		[
108	1	'code' => $e->getCode(),
109	1	'body' => $e->getBody(),
110		]
111		);
112
113	1	throw new TransmissionException($e->getCode(), $e);
114		}
115		}
116
117		/**
118		* @return array
119		*/
120	12	protected function supportedContent(): array
121		{
122		return [
123	12	Content\EmptyContent::class,
124		Content\Contracts\SimpleContent::class,
125		Content\Contracts\TemplatedContent::class,
126		];
127		}
128
129		/**
130		* Determine if the content is supported by this courier.
131		*
132		* @param Content $content
133		*
134		* @return bool
135		*/
136	12	protected function supportsContent(Content $content): bool
137		{
138	12	foreach ($this->supportedContent() as $contentType) {
139	12	if ($content instanceof $contentType) {
140	12	return true;
141		}
142		}
143
144	1	return false;
145		}
146
147		/**
148		* @param Email $email
149		*
150		* @return array
151		*/
152	11	protected function prepareEmail(Email $email): array
153		{
154	11	$message = [];
155	11	$headerTo = $this->buildHeaderTo($email);
156
157	11	$message[self::RECIPIENTS] = [];
158
159	11	foreach ($email->getToRecipients() as $recipient) {
160	11	$message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
161		}
162
163	11	foreach ($email->getCcRecipients() as $recipient) {
164	3	$message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
165		}
166
167	11	foreach ($email->getBccRecipients() as $recipient) {
168	1	$message[self::RECIPIENTS][] = $this->createAddress($recipient, $headerTo);
169		}
170
171	11	return $message;
172		}
173
174		/**
175		* @param Email $email
176		* @param array $message
177		*
178		* @return array
179		*/
180	11	protected function prepareContent(Email $email, array $message): array
181		{
182		switch (true) {
183	11	case $email->getContent() instanceof Content\Contracts\TemplatedContent:
184	7	$message[self::CONTENT] = $this->buildTemplateContent($email);
185	5	$message[self::SUBSTITUTION_DATA] = $this->buildTemplateData($email);
186
187	5	break;
188
189	4	case $email->getContent() instanceof Content\EmptyContent:
190	2	$email->setContent(new Content\SimpleContent(
191	2	new Content\SimpleContent\Message(''),
192	2	new Content\SimpleContent\Message('')
193		));
194
195	2	$message[self::CONTENT] = $this->buildSimpleContent($email);
196
197	2	break;
198
199	2	case $email->getContent() instanceof Content\SimpleContent:
200	2	$message[self::CONTENT] = $this->buildSimpleContent($email);
201		}
202
203	9	return $message;
204		}
205
206		/**
207		* Attempt to create template data using the from, subject and reply to, which SparkPost considers to be
208		* part of the templates substitutable content.
209		*
210		* @param Email $email
211		*
212		* @return array
213		*/
214	5	protected function buildTemplateData(Email $email): array
215		{
216		/** @var Content\TemplatedContent $emailContent */
217	5	$emailContent = $email->getContent();
218	5	$templateData = $emailContent->getTemplateData();
219
220	5	if ($email->getReplyTos()) {
221	3	$replyTos = $email->getReplyTos();
222	3	$first = reset($replyTos);
223
224	3	if (!array_key_exists('replyTo', $templateData)) {
225	3	$templateData['replyTo'] = $first->toRfc2822();
226		}
227		}
228
229	5	if (!array_key_exists('fromName', $templateData)) {
230	5	$templateData['fromName'] = $email->getFrom()->getName();
231		}
232
233	5	if (!array_key_exists('fromEmail', $templateData)) {
234	5	$templateData['fromEmail'] = explode('@', $email->getFrom()->getEmail())[0];
235		}
236
237	5	if (!array_key_exists('fromDomain', $templateData)) {
238	5	$templateData['fromDomain'] = explode('@', $email->getFrom()->getEmail())[1];
239		}
240
241	5	if (!array_key_exists('subject', $templateData)) {
242	5	$templateData['subject'] = $email->getSubject();
243		}
244
245		// @TODO Remove this variable once SparkPost CC headers work properly for templates
246	5	if (!array_key_exists('ccHeader', $templateData)) {
247	5	if ($header = $this->buildCcHeader($email)) {
248	2	$templateData['ccHeader'] = $header;
249		}
250		}
251
252	5	return $templateData;
253		}
254
255		/**
256		* @param Email $email
257		*
258		* @return array
259		*/
260	7	protected function buildTemplateContent(Email $email): array
261		{
262		$content = [
263	7	self::TEMPLATE_ID => $email->getContent()->getTemplateId(),
264		];
265
266	7	$content[self::HEADERS] = $this->getContentHeaders($email);
267
268	7	if ($email->getAttachments()) {
269		/*
270		* SparkPost does not currently support sending attachments with templated emails. For this reason,
271		* we will instead get the template from SparkPost and create a new inline template using the information
272		* from it instead.
273		*/
274	5	$template = $this->getTemplate($email);
275	4	$inlineEmail = clone $email;
276
277		$inlineEmail
278	4	->setSubject($template[self::SUBJECT])
279	4	->setContent($this->getInlineContent($template));
280
281		// If the from contains a templated from, it should be actively replaced now to avoid validation errors.
282	4	if (strpos($template[self::FROM][self::CONTACT_EMAIL], '{{') !== false) {
283	2	$inlineEmail->setFrom($email->getFrom());
284		} else {
285	2	$inlineEmail->setFrom(
286	2	new Address(
287	2	$template[self::FROM][self::CONTACT_EMAIL],
288	2	$template[self::FROM][self::CONTACT_NAME]
289		)
290		);
291		}
292
293		// If the form contains a templated replyTo, it should be actively replaced now to avoid validation errors.
294	4	if (array_key_exists(self::REPLY_TO, $template)) {
295	4	if (strpos($template[self::REPLY_TO], '{{') !== false) {
296	2	if (empty($email->getReplyTos())) {
297	1	throw new ValidationException('Reply to is templated but no value was given');
298		}
299
300	1	$inlineEmail->setReplyTos($email->getReplyTos()[0]);
301		} else {
302	2	$inlineEmail->setReplyTos(Address::fromString($template[self::REPLY_TO]));
303		}
304		}
305
306	3	$content = $this->buildSimpleContent($inlineEmail);
307
308		// If the template AND content include headers, merge them
309		// if only the template includes headers, then just use that
310	3	if (array_key_exists(self::HEADERS, $template) && array_key_exists(self::HEADERS, $content)) {
311	3	$content[self::HEADERS] = array_merge($template[self::HEADERS], $content[self::HEADERS]);
312		} elseif (array_key_exists(self::HEADERS, $template)) {
313		$content[self::HEADERS] = $template[self::HEADERS];
314		}
315		}
316
317	5	return $content;
318		}
319
320		/**
321		* @param Email $email
322		*
323		* @return array
324		*/
325	7	protected function buildSimpleContent(Email $email): array
326		{
327	7	$attachments = [];
328
329	7	foreach ($email->getAttachments() as $attachment) {
330	4	$attachments[] = $this->buildAttachment($attachment);
331		}
332
333	7	$replyTo = null;
334	7	if (!empty($email->getReplyTos())) {
335		// SparkPost only supports a single reply-to
336	4	$replyTos = $email->getReplyTos();
337	4	$first = reset($replyTos);
338
339	4	$replyTo = $first->toRfc2822();
340		}
341
342		/** @var Content\Contracts\SimpleContent $emailContent */
343	7	$emailContent = $email->getContent();
344
345		$content = [
346	7	self::FROM => [
347	7	self::CONTACT_NAME => $email->getFrom()->getName(),
348	7	self::CONTACT_EMAIL => $email->getFrom()->getEmail(),
349		],
350	7	self::SUBJECT => $email->getSubject(),
351	7	self::HTML => $emailContent->getHtml() !== null ? $emailContent->getHtml()->getBody() : null,
352	7	self::TEXT => $emailContent->getText() !== null ? $emailContent->getText()->getBody() : null,
353	7	self::ATTACHMENTS => $attachments,
354	7	self::REPLY_TO => $replyTo,
355		];
356
357	7	$content[self::HEADERS] = $this->getContentHeaders($email);
358
359	7	return $content;
360		}
361
362	11	protected function getContentHeaders(Email $email): array
363		{
364	11	$headers = [];
365
366	11	if ($ccHeader = $this->buildCcHeader($email)) {
367	3	$headers[self::CC_HEADER] = $ccHeader;
368		}
369
370	11	foreach ($email->getHeaders() as $header) {
371	1	$headers[$header->getField()] = $header->getValue();
372		}
373
374	11	return $headers;
375		}
376
377		/**
378		* Create the SimpleContent based on the SparkPost template data.
379		*
380		* @param array $template
381		*
382		* @return Content\SimpleContent
383		*/
384	4	protected function getInlineContent(array $template): Content\SimpleContent
385		{
386	4	$htmlContent = null;
387	4	if (array_key_exists(self::HTML, $template)) {
388	4	$htmlContent = new Content\SimpleContent\Message($template[self::HTML]);
389		}
390
391	4	$textContent = null;
392	4	if (array_key_exists(self::TEXT, $template)) {
393		$textContent = new Content\SimpleContent\Message($template[self::TEXT]);
394		}
395
396	4	return new Content\SimpleContent($htmlContent, $textContent);
397		}
398
399		/**
400		* Get the template content from SparkPost.
401		*
402		* @param Email $email
403		*
404		* @throws TransmissionException
405		*
406		* @return array
407		*/
408	5	private function getTemplate(Email $email): array
409		{
410		try {
411	5	$response = $this->sparkPost->syncRequest('GET', "templates/{$email->getContent()->getTemplateId()}");
412
413	4	return $response->getBody()['results'][self::CONTENT];
414	1	} catch (SparkPostException $e) {
415	1	$this->logger->error(
416	1	'Received status {code} from SparkPost while retrieving template with body: {body}',
417		[
418	1	'code' => $e->getCode(),
419	1	'body' => $e->getBody(),
420		]
421		);
422
423	1	throw new TransmissionException($e->getCode(), $e);
424		}
425		}
426
427		/**
428		* @param Attachment $attachment
429		*
430		* @return array
431		*/
432	4	private function buildAttachment(Attachment $attachment): array
433		{
434		return [
435	4	self::ATTACHMENT_NAME => $attachment->getName(),
436	4	self::ATTACHMENT_TYPE => $attachment->getContentType(),
437	4	self::ATTACHMENT_DATA => $attachment->getBase64Content(),
438		];
439		}
440
441		/**
442		* @param Address $address
443		* @param string $headerTo
444		*
445		* @return array
446		*/
447	11	private function createAddress(Address $address, string $headerTo): array
448		{
449		return [
450	11	self::ADDRESS => [
451	11	self::CONTACT_EMAIL => $address->getEmail(),
452	11	self::HEADER_TO => $headerTo,
453		],
454		];
455		}
456
457		/**
458		* Build a string representing the header_to field of this email.
459		*
460		* @param Email $email
461		*
462		* @return string
463		*/
464		private function buildHeaderTo(Email $email): string
465		{
466	11	return implode(',', array_map(function (Address $address) {
467	11	return $address->toRfc2822();
468	11	}, $email->getToRecipients()));
469		}
470
471		/**
472		* Build a string representing the CC header for this email.
473		*
474		* @param Email $email
475		*
476		* @return string
477		*/
478		private function buildCcHeader(Email $email): string
479		{
480	11	return implode(',', array_map(function (Address $address) {
481	3	return $address->toRfc2822();
482	11	}, $email->getCcRecipients()));
483		}
484		}
485

quartzy / courier

Push — master ( d32337...505a31 )

SparkPostCourier::getContentHeaders() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like