MailService::send() - Code Metrics - Inspection of "Merge branch 'next-12246/exchange-swiftmailer-with..." - shopware/platform - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 72b2aa...c8dd73 )

by Christian

created 2021-02-02 07:19 UTC

MailService::send() C

↳ Parent: MailService

Complexity

Conditions	14
Paths	134

Size

Total Lines	103
Code Lines	66

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	14
eloc	66
c	1
b	0
f	0
nc	134
nop	3
dl	0
loc	103
rs	5.9833

How to fix Long Method Complexity

<?php declare(strict_types=1);

namespace Shopware\Core\Content\Mail\Service;

use Psr\Log\LoggerInterface;
use Shopware\Core\Content\MailTemplate\Exception\SalesChannelNotFoundException;
use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
use Shopware\Core\Content\MailTemplate\Service\Event\MailSentEvent;
use Shopware\Core\Content\Media\MediaCollection;
use Shopware\Core\Content\Media\Pathname\UrlGeneratorInterface;
use Shopware\Core\Framework\Adapter\Twig\StringTemplateRenderer;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
use Shopware\Core\Framework\DataAbstractionLayer\Validation\EntityExists;
use Shopware\Core\Framework\Feature;
use Shopware\Core\Framework\Feature\Exception\FeatureNotActiveException;
use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
use Shopware\Core\Framework\Validation\DataValidationDefinition;
use Shopware\Core\Framework\Validation\DataValidator;
use Shopware\Core\System\SalesChannel\SalesChannelDefinition;
use Shopware\Core\System\SalesChannel\SalesChannelEntity;
use Shopware\Core\System\SystemConfig\SystemConfigService;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\Mime\Email;
use Symfony\Component\Validator\Constraints\NotBlank;

class MailService extends AbstractMailService
{
    /**
     * @var DataValidator
     */
    private $dataValidator;

    /**
     * @var StringTemplateRenderer
     */
    private $templateRenderer;

    /**
     * @var AbstractMailFactory
     */
    private $messageFactory;

    /**
     * @var EntityRepositoryInterface
     */
    private $mediaRepository;

    /**
     * @var SalesChannelDefinition
     */
    private $salesChannelDefinition;

    /**
     * @var EntityRepositoryInterface
     */
    private $salesChannelRepository;

    /**
     * @var SystemConfigService
     */
    private $systemConfigService;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

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

    /**
     * @var UrlGeneratorInterface
     */
    private $urlGenerator;

    /**
     * @var AbstractMailSender
     */
    private $mailSender;

    public function __construct(
        DataValidator $dataValidator,
        StringTemplateRenderer $templateRenderer,
        AbstractMailFactory $messageFactory,
        AbstractMailSender $emailSender,
        EntityRepositoryInterface $mediaRepository,
        SalesChannelDefinition $salesChannelDefinition,
        EntityRepositoryInterface $salesChannelRepository,
        SystemConfigService $systemConfigService,
        EventDispatcherInterface $eventDispatcher,
        LoggerInterface $logger,
        UrlGeneratorInterface $urlGenerator
    ) {
        if (!Feature::isActive('FEATURE_NEXT_12246')) {
            throw new FeatureNotActiveException('FEATURE_NEXT_12246');
        }

        $this->dataValidator = $dataValidator;
        $this->templateRenderer = $templateRenderer;
        $this->messageFactory = $messageFactory;
        $this->mailSender = $emailSender;
        $this->mediaRepository = $mediaRepository;
        $this->salesChannelDefinition = $salesChannelDefinition;
        $this->salesChannelRepository = $salesChannelRepository;
        $this->systemConfigService = $systemConfigService;
        $this->eventDispatcher = $eventDispatcher;
        $this->logger = $logger;
        $this->urlGenerator = $urlGenerator;
    }

    public function getDecorated(): AbstractMailService
    {
        throw new DecorationPatternException(self::class);
    }

    public function send(array $data, Context $context, array $templateData = []): ?Email
    {
        $mailBeforeValidateEvent = new MailBeforeValidateEvent($data, $context, $templateData);
        $this->eventDispatcher->dispatch($mailBeforeValidateEvent);

        if ($mailBeforeValidateEvent->isPropagationStopped()) {
            return null;
        }

        $definition = $this->getValidationDefinition($context);
        $this->dataValidator->validate($data, $definition);

        $recipients = $data['recipients'];
        $salesChannelId = $data['salesChannelId'];
        $salesChannel = null;

        if ($salesChannelId !== null && !isset($templateData['salesChannel'])) {
            $criteria = $this->getSalesChannelDomainCriteria($salesChannelId, $context);

            /** @var SalesChannelEntity|null $salesChannel */
            $salesChannel = $this->salesChannelRepository->search($criteria, $context)->get($salesChannelId);

            if ($salesChannel === null) {
                throw new SalesChannelNotFoundException($salesChannelId);
            }

            $templateData['salesChannel'] = $salesChannel;
        } elseif (isset($templateData['salesChannel'])) {
            $salesChannel = $templateData['salesChannel'];
        }

        $senderEmail = $this->getSender($data, $salesChannelId);

        $contents = $this->buildContents($data, $salesChannel);
        if (isset($data['testMode']) && (bool) $data['testMode'] === true) {
            $this->templateRenderer->enableTestMode();
        }

        $template = $data['subject'];

        try {
            $data['subject'] = $this->templateRenderer->render($template, $templateData, $context);
            $template = $data['senderName'];
            $data['senderName'] = $this->templateRenderer->render($template, $templateData, $context);
            foreach ($contents as $index => $template) {
                $contents[$index] = $this->templateRenderer->render($template, $templateData, $context);
            }
        } catch (\Throwable $e) {
            $this->logger->error(
                "Could not render Mail-Template with error message:\n"
                . $e->getMessage() . "\n"
                . 'Error Code:' . $e->getCode() . "\n"
                . 'Template source:'
                . $template . "\n"
                . "Template data: \n"
                . json_encode($templateData) . "\n"
            );

            return null;
        }
        if (isset($data['testMode']) && (bool) $data['testMode'] === true) {
            $this->templateRenderer->disableTestMode();
        }

        $mediaUrls = $this->getMediaUrls($data, $context);

        $binAttachments = $data['binAttachments'] ?? null;

        $mail = $this->messageFactory->create(
            $data['subject'],
            [$senderEmail => $data['senderName']],
            $recipients,
            $contents,
            $mediaUrls,
            $data,
            $binAttachments
        );

        if ($mail->getBody()->toString() === '') {
            $this->logger->error(
                "message is null:\n"
                . 'Data:'
                . json_encode($data) . "\n"
                . "Template data: \n"
                . json_encode($templateData) . "\n"
            );

            return null;
        }

        $mailBeforeSentEvent = new MailBeforeSentEvent($data, $mail, $context);
        $this->eventDispatcher->dispatch($mailBeforeSentEvent);

        if ($mailBeforeSentEvent->isPropagationStopped()) {
            return null;
        }

        $this->mailSender->send($mail);

        $mailSentEvent = new MailSentEvent($data['subject'], $recipients, $contents, $context);
        $this->eventDispatcher->dispatch($mailSentEvent);

        return $mail;
    }

    private function getSender(array $data, ?string $salesChannelId): ?string
    {
        $senderEmail = $data['senderEmail'] ?? null;

        if ($senderEmail === null || trim($senderEmail) === '') {
            $senderEmail = $this->systemConfigService->get('core.basicInformation.email', $salesChannelId);
        }

        if ($senderEmail === null || trim($senderEmail) === '') {
            $senderEmail = $this->systemConfigService->get('core.mailerSettings.senderAddress', $salesChannelId);
        }

        if ($senderEmail === null || trim($senderEmail) === '') {
            $this->logger->error('senderMail not configured for salesChannel: ' . $salesChannelId . '. Please check system_config \'core.basicInformation.email\'');

            return null;
        }

        return $senderEmail;
    }

    /**
     * Attaches header and footer to given email bodies
     *
     * @param array $data e.g. ['contentHtml' => 'foobar', 'contentPlain' => '<h1>foobar</h1>']
     *
     * @return array e.g. ['text/plain' => '{{foobar}}', 'text/html' => '<h1>{{foobar}}</h1>']
     *
     * @internal
     */
    private function buildContents(array $data, ?SalesChannelEntity $salesChannel): array
    {
        if ($salesChannel && $mailHeaderFooter = $salesChannel->getMailHeaderFooter()) {
            return [
                'text/plain' => $mailHeaderFooter->getHeaderPlain() . $data['contentPlain'] . $mailHeaderFooter->getFooterPlain(),
                'text/html' => $mailHeaderFooter->getHeaderHtml() . $data['contentHtml'] . $mailHeaderFooter->getFooterHtml(),
            ];
        }

        return [
            'text/html' => $data['contentHtml'],
            'text/plain' => $data['contentPlain'],
        ];
    }

    private function getValidationDefinition(Context $context): DataValidationDefinition
    {
        $definition = new DataValidationDefinition('mail_service.send');

        $definition->add('recipients', new NotBlank());
        $definition->add('salesChannelId', new EntityExists(['entity' => $this->salesChannelDefinition->getEntityName(), 'context' => $context]));
        $definition->add('contentHtml', new NotBlank());
        $definition->add('contentPlain', new NotBlank());
        $definition->add('subject', new NotBlank());
        $definition->add('senderName', new NotBlank());

        return $definition;
    }

    private function getMediaUrls(array $data, Context $context): array
    {
        if (!isset($data['mediaIds']) || empty($data['mediaIds'])) {
            return [];
        }
        $criteria = new Criteria($data['mediaIds']);
        $media = null;
        $mediaRepository = $this->mediaRepository;
        $context->scope(Context::SYSTEM_SCOPE, static function (Context $context) use ($criteria, $mediaRepository, &$media): void {
            /** @var MediaCollection $media */
            $media = $mediaRepository->search($criteria, $context)->getElements();
        });

        $urls = [];
        foreach ($media ?? [] as $mediaItem) {
            $urls[] = $this->urlGenerator->getRelativeMediaUrl($mediaItem);
        }

        return $urls;
    }

    private function getSalesChannelDomainCriteria(string $salesChannelId, Context $context): Criteria
    {
        $criteria = new Criteria([$salesChannelId]);
        $criteria->addAssociation('mailHeaderFooter');
        $criteria->getAssociation('domains')
            ->addFilter(
                new EqualsFilter('languageId', $context->getLanguageId())
            );

        return $criteria;
    }
}


1			<?php declare(strict_types=1);
2
3			namespace Shopware\Core\Content\Mail\Service;
4
5			use Psr\Log\LoggerInterface;
6			use Shopware\Core\Content\MailTemplate\Exception\SalesChannelNotFoundException;
7			use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
8			use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
9			use Shopware\Core\Content\MailTemplate\Service\Event\MailSentEvent;
10			use Shopware\Core\Content\Media\MediaCollection;
11			use Shopware\Core\Content\Media\Pathname\UrlGeneratorInterface;
12			use Shopware\Core\Framework\Adapter\Twig\StringTemplateRenderer;
13			use Shopware\Core\Framework\Context;
14			use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
15			use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
16			use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
17			use Shopware\Core\Framework\DataAbstractionLayer\Validation\EntityExists;
18			use Shopware\Core\Framework\Feature;
19			use Shopware\Core\Framework\Feature\Exception\FeatureNotActiveException;
20			use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
21			use Shopware\Core\Framework\Validation\DataValidationDefinition;
22			use Shopware\Core\Framework\Validation\DataValidator;
23			use Shopware\Core\System\SalesChannel\SalesChannelDefinition;
24			use Shopware\Core\System\SalesChannel\SalesChannelEntity;
25			use Shopware\Core\System\SystemConfig\SystemConfigService;
26			use Symfony\Component\EventDispatcher\EventDispatcherInterface;
27			use Symfony\Component\Mime\Email;
28			use Symfony\Component\Validator\Constraints\NotBlank;
29
30			class MailService extends AbstractMailService
31			{
32			/**
33			* @var DataValidator
34			*/
35			private $dataValidator;
36
37			/**
38			* @var StringTemplateRenderer
39			*/
40			private $templateRenderer;
41
42			/**
43			* @var AbstractMailFactory
44			*/
45			private $messageFactory;
46
47			/**
48			* @var EntityRepositoryInterface
49			*/
50			private $mediaRepository;
51
52			/**
53			* @var SalesChannelDefinition
54			*/
55			private $salesChannelDefinition;
56
57			/**
58			* @var EntityRepositoryInterface
59			*/
60			private $salesChannelRepository;
61
62			/**
63			* @var SystemConfigService
64			*/
65			private $systemConfigService;
66
67			/**
68			* @var EventDispatcherInterface
69			*/
70			private $eventDispatcher;
71
72			/**
73			* @var LoggerInterface
74			*/
75			private $logger;
76
77			/**
78			* @var UrlGeneratorInterface
79			*/
80			private $urlGenerator;
81
82			/**
83			* @var AbstractMailSender
84			*/
85			private $mailSender;
86
87			public function __construct(
88			DataValidator $dataValidator,
89			StringTemplateRenderer $templateRenderer,
90			AbstractMailFactory $messageFactory,
91			AbstractMailSender $emailSender,
92			EntityRepositoryInterface $mediaRepository,
93			SalesChannelDefinition $salesChannelDefinition,
94			EntityRepositoryInterface $salesChannelRepository,
95			SystemConfigService $systemConfigService,
96			EventDispatcherInterface $eventDispatcher,
97			LoggerInterface $logger,
98			UrlGeneratorInterface $urlGenerator
99			) {
100			if (!Feature::isActive('FEATURE_NEXT_12246')) {
101			throw new FeatureNotActiveException('FEATURE_NEXT_12246');
102			}
103
104			$this->dataValidator = $dataValidator;
105			$this->templateRenderer = $templateRenderer;
106			$this->messageFactory = $messageFactory;
107			$this->mailSender = $emailSender;
108			$this->mediaRepository = $mediaRepository;
109			$this->salesChannelDefinition = $salesChannelDefinition;
110			$this->salesChannelRepository = $salesChannelRepository;
111			$this->systemConfigService = $systemConfigService;
112			$this->eventDispatcher = $eventDispatcher;
113			$this->logger = $logger;
114			$this->urlGenerator = $urlGenerator;
115			}
116
117			public function getDecorated(): AbstractMailService
118			{
119			throw new DecorationPatternException(self::class);
120			}
121
122			public function send(array $data, Context $context, array $templateData = []): ?Email
123			{
124			$mailBeforeValidateEvent = new MailBeforeValidateEvent($data, $context, $templateData);
125			$this->eventDispatcher->dispatch($mailBeforeValidateEvent);
126
127			if ($mailBeforeValidateEvent->isPropagationStopped()) {
128			return null;
129			}
130
131			$definition = $this->getValidationDefinition($context);
132			$this->dataValidator->validate($data, $definition);
133
134			$recipients = $data['recipients'];
135			$salesChannelId = $data['salesChannelId'];
136			$salesChannel = null;
137
138			if ($salesChannelId !== null && !isset($templateData['salesChannel'])) {
139			$criteria = $this->getSalesChannelDomainCriteria($salesChannelId, $context);
140
141			/** @var SalesChannelEntity\|null $salesChannel */
142			$salesChannel = $this->salesChannelRepository->search($criteria, $context)->get($salesChannelId);
143
144			if ($salesChannel === null) {
145			throw new SalesChannelNotFoundException($salesChannelId);
146			}
147
148			$templateData['salesChannel'] = $salesChannel;
149			} elseif (isset($templateData['salesChannel'])) {
150			$salesChannel = $templateData['salesChannel'];
151			}
152
153			$senderEmail = $this->getSender($data, $salesChannelId);
154
155			$contents = $this->buildContents($data, $salesChannel);
156			if (isset($data['testMode']) && (bool) $data['testMode'] === true) {
157			$this->templateRenderer->enableTestMode();
158			}
159
160			$template = $data['subject'];
161
162			try {
163			$data['subject'] = $this->templateRenderer->render($template, $templateData, $context);
164			$template = $data['senderName'];
165			$data['senderName'] = $this->templateRenderer->render($template, $templateData, $context);
166			foreach ($contents as $index => $template) {
167			$contents[$index] = $this->templateRenderer->render($template, $templateData, $context);
168			}
169			} catch (\Throwable $e) {
170			$this->logger->error(
171			"Could not render Mail-Template with error message:\n"
172			. $e->getMessage() . "\n"
173			. 'Error Code:' . $e->getCode() . "\n"
174			. 'Template source:'
175			. $template . "\n"
176			. "Template data: \n"
177			. json_encode($templateData) . "\n"
178			);
179
180			return null;
181			}
182			if (isset($data['testMode']) && (bool) $data['testMode'] === true) {
183			$this->templateRenderer->disableTestMode();
184			}
185
186			$mediaUrls = $this->getMediaUrls($data, $context);
187
188			$binAttachments = $data['binAttachments'] ?? null;
189
190			$mail = $this->messageFactory->create(
191			$data['subject'],
192			[$senderEmail => $data['senderName']],
193			$recipients,
194			$contents,
195			$mediaUrls,
196			$data,
197			$binAttachments
198			);
199
200			if ($mail->getBody()->toString() === '') {
201			$this->logger->error(
202			"message is null:\n"
203			. 'Data:'
204			. json_encode($data) . "\n"
205			. "Template data: \n"
206			. json_encode($templateData) . "\n"
207			);
208
209			return null;
210			}
211
212			$mailBeforeSentEvent = new MailBeforeSentEvent($data, $mail, $context);
213			$this->eventDispatcher->dispatch($mailBeforeSentEvent);
214
215			if ($mailBeforeSentEvent->isPropagationStopped()) {
216			return null;
217			}
218
219			$this->mailSender->send($mail);
220
221			$mailSentEvent = new MailSentEvent($data['subject'], $recipients, $contents, $context);
222			$this->eventDispatcher->dispatch($mailSentEvent);
223
224			return $mail;
225			}
226
227			private function getSender(array $data, ?string $salesChannelId): ?string
228			{
229			$senderEmail = $data['senderEmail'] ?? null;
230
231			if ($senderEmail === null \|\| trim($senderEmail) === '') {
232			$senderEmail = $this->systemConfigService->get('core.basicInformation.email', $salesChannelId);
233			}
234
235			if ($senderEmail === null \|\| trim($senderEmail) === '') {
236			$senderEmail = $this->systemConfigService->get('core.mailerSettings.senderAddress', $salesChannelId);
237			}
238
239			if ($senderEmail === null \|\| trim($senderEmail) === '') {
240			$this->logger->error('senderMail not configured for salesChannel: ' . $salesChannelId . '. Please check system_config \'core.basicInformation.email\'');
241
242			return null;
243			}
244
245			return $senderEmail;
246			}
247
248			/**
249			* Attaches header and footer to given email bodies
250			*
251			* @param array $data e.g. ['contentHtml' => 'foobar', 'contentPlain' => '<h1>foobar</h1>']
252			*
253			* @return array e.g. ['text/plain' => '{{foobar}}', 'text/html' => '<h1>{{foobar}}</h1>']
254			*
255			* @internal
256			*/
257			private function buildContents(array $data, ?SalesChannelEntity $salesChannel): array
258			{
259			if ($salesChannel && $mailHeaderFooter = $salesChannel->getMailHeaderFooter()) {
260			return [
261			'text/plain' => $mailHeaderFooter->getHeaderPlain() . $data['contentPlain'] . $mailHeaderFooter->getFooterPlain(),
262			'text/html' => $mailHeaderFooter->getHeaderHtml() . $data['contentHtml'] . $mailHeaderFooter->getFooterHtml(),
263			];
264			}
265
266			return [
267			'text/html' => $data['contentHtml'],
268			'text/plain' => $data['contentPlain'],
269			];
270			}
271
272			private function getValidationDefinition(Context $context): DataValidationDefinition
273			{
274			$definition = new DataValidationDefinition('mail_service.send');
275
276			$definition->add('recipients', new NotBlank());
277			$definition->add('salesChannelId', new EntityExists(['entity' => $this->salesChannelDefinition->getEntityName(), 'context' => $context]));
278			$definition->add('contentHtml', new NotBlank());
279			$definition->add('contentPlain', new NotBlank());
280			$definition->add('subject', new NotBlank());
281			$definition->add('senderName', new NotBlank());
282
283			return $definition;
284			}
285
286			private function getMediaUrls(array $data, Context $context): array
287			{
288			if (!isset($data['mediaIds']) \|\| empty($data['mediaIds'])) {
289			return [];
290			}
291			$criteria = new Criteria($data['mediaIds']);
292			$media = null;
293			$mediaRepository = $this->mediaRepository;
294			$context->scope(Context::SYSTEM_SCOPE, static function (Context $context) use ($criteria, $mediaRepository, &$media): void {
295			/** @var MediaCollection $media */
296			$media = $mediaRepository->search($criteria, $context)->getElements();
297			});
298
299			$urls = [];
300			foreach ($media ?? [] as $mediaItem) {
301			$urls[] = $this->urlGenerator->getRelativeMediaUrl($mediaItem);
302			}
303
304			return $urls;
305			}
306
307			private function getSalesChannelDomainCriteria(string $salesChannelId, Context $context): Criteria
308			{
309			$criteria = new Criteria([$salesChannelId]);
310			$criteria->addAssociation('mailHeaderFooter');
311			$criteria->getAssociation('domains')
312			->addFilter(
313			new EqualsFilter('languageId', $context->getLanguageId())
314			);
315
316			return $criteria;
317			}
318			}
319

shopware / platform

Push — master ( 72b2aa...c8dd73 )

MailService::send() C

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like