invoiceninja/app/Ninja/Mailers/Mailer.php

<?php

namespace App\Ninja\Mailers;

use App\Models\Invoice;
use Exception;
use Mail;
use Utils;
use Postmark\PostmarkClient;
use Postmark\Models\PostmarkException;
use Postmark\Models\PostmarkAttachment;

/**
 * Class Mailer.
 */
class Mailer
{
    /**
     * @param $toEmail
     * @param $fromEmail
     * @param $fromName
     * @param $subject
     * @param $view
     * @param array $data
     *
     * @return bool|string
     */
    public function sendTo($toEmail, $fromEmail, $fromName, $subject, $view, $data = [])
    {
        // don't send emails to dummy addresses
        if (stristr($toEmail, '@example.com')) {
            return true;
        }

        $views = [
            'emails.'.$view.'_html',
            'emails.'.$view.'_text',
        ];

        $toEmail = strtolower($toEmail);
        $replyEmail = $fromEmail;
        $fromEmail = CONTACT_EMAIL;

        if (Utils::isSelfHost() && config('app.debug')) {
            \Log::info("Sending email - To: {$toEmail} | Reply: {$replyEmail} | From: $fromEmail");
        }

        // Optionally send for alternate domain
        if (! empty($data['fromEmail'])) {
            $fromEmail = $data['fromEmail'];
        }

        if (config('services.postmark')) {
            return $this->sendPostmarkMail($toEmail, $fromEmail, $fromName, $replyEmail, $subject, $views, $data);
        } else {
            return $this->sendLaravelMail($toEmail, $fromEmail, $fromName, $replyEmail, $subject, $views, $data);
        }
    }

    private function sendLaravelMail($toEmail, $fromEmail, $fromName, $replyEmail, $subject, $views, $data = [])
    {
        if (Utils::isSelfHost()) {
            if (isset($data['account'])) {
                $account = $data['account'];
                if (env($account->id . '_MAIL_FROM_ADDRESS')) {
                    $fields = [
                        'driver',
                        'host',
                        'port',
                        'from.address',
                        'from.name',
                        'encryption',
                        'username',
                        'password',
                    ];
                    foreach ($fields as $field) {
                        $envKey = strtoupper(str_replace('.', '_', $field));
                        if ($value = env($account->id . '_MAIL_' . $envKey)) {
                            config(['mail.' . $field => $value]);
                        }
                    }

                    $fromEmail = config('mail.from.address');
                    $app = \App::getInstance();
                    $app->singleton('swift.transport', function ($app) {
                        return new \Illuminate\Mail\TransportManager($app);
                    });
                    $mailer = new \Swift_Mailer($app['swift.transport']->driver());
                    Mail::setSwiftMailer($mailer);
                }
            }
        }

        try {
            $response = Mail::send($views, $data, function ($message) use ($toEmail, $fromEmail, $fromName, $replyEmail, $subject, $data) {
                $message->to($toEmail)
                        ->from($fromEmail, $fromName)
                        ->replyTo($replyEmail, $fromName)
                        ->subject($subject);

                // Optionally BCC the email
                if (! empty($data['bccEmail'])) {
                    $message->bcc($data['bccEmail']);
                }

                // Handle invoice attachments
                if (! empty($data['pdfString']) && ! empty($data['pdfFileName'])) {
                    $message->attachData($data['pdfString'], $data['pdfFileName']);
                }
                if (! empty($data['ublString']) && ! empty($data['ublFileName'])) {
                    $message->attachData($data['ublString'], $data['ublFileName']);
                }
                if (! empty($data['documents'])) {
                    foreach ($data['documents'] as $document) {
                        $message->attachData($document['data'], $document['name']);
                    }
                }
            });

            return $this->handleSuccess($data);
        } catch (Exception $exception) {
            return $this->handleFailure($data, $exception->getMessage());
        }
    }

    private function sendPostmarkMail($toEmail, $fromEmail, $fromName, $replyEmail, $subject, $views, $data = [])
    {
        $htmlBody = view($views[0], $data)->render();
        $textBody = view($views[1], $data)->render();
        $attachments = [];

        if (isset($data['account'])) {
            $account = $data['account'];
            $logoName = $account->getLogoName();
            if (strpos($htmlBody, 'cid:' . $logoName) !== false && $account->hasLogo()) {
                $attachments[] = PostmarkAttachment::fromFile($account->getLogoPath(), $logoName, null, 'cid:' . $logoName);
            }
        }

        if (strpos($htmlBody, 'cid:invoiceninja-logo.png') !== false) {
            $attachments[] = PostmarkAttachment::fromFile(public_path('images/invoiceninja-logo.png'), 'invoiceninja-logo.png', null, 'cid:invoiceninja-logo.png');
            $attachments[] = PostmarkAttachment::fromFile(public_path('images/emails/icon-facebook.png'), 'icon-facebook.png', null, 'cid:icon-facebook.png');
            $attachments[] = PostmarkAttachment::fromFile(public_path('images/emails/icon-twitter.png'), 'icon-twitter.png', null, 'cid:icon-twitter.png');
            $attachments[] = PostmarkAttachment::fromFile(public_path('images/emails/icon-github.png'), 'icon-github.png', null, 'cid:icon-github.png');
        }

        // Handle invoice attachments
        if (! empty($data['pdfString']) && ! empty($data['pdfFileName'])) {
            $attachments[] = PostmarkAttachment::fromRawData($data['pdfString'], $data['pdfFileName']);
        }
        if (! empty($data['ublString']) && ! empty($data['ublFileName'])) {
            $attachments[] = PostmarkAttachment::fromRawData($data['ublString'], $data['ublFileName']);
        }
        if (! empty($data['documents'])) {
            foreach ($data['documents'] as $document) {
                $attachments[] = PostmarkAttachment::fromRawData($document['data'], $document['name']);
            }
        }

        try {
            $client = new PostmarkClient(config('services.postmark'));
            $message = [
                'To' => $toEmail,
                'From' => sprintf('"%s" <%s>', addslashes($fromName), $fromEmail),
                'ReplyTo' => $replyEmail,
                'Subject' => $subject,
                'TextBody' => $textBody,
                'HtmlBody' => $htmlBody,
                'Attachments' => $attachments,
            ];

            if (! empty($data['bccEmail'])) {
                $message['Bcc'] = $data['bccEmail'];
            }

            if (! empty($data['tag'])) {
                $message['Tag'] = $data['tag'];
            }

            $response = $client->sendEmailBatch([$message]);
            if ($messageId = $response[0]->messageid) {
                return $this->handleSuccess($data, $messageId);
            } else {
                return $this->handleFailure($data, $response[0]->message);
            }
        } catch (PostmarkException $exception) {
            return $this->handleFailure($data, $exception->getMessage());
        } catch (Exception $exception) {
            Utils::logError(Utils::getErrorString($exception));
            throw $exception;
        }
    }

    /**
     * @param $response
     * @param $data
     *
     * @return bool
     */
    private function handleSuccess($data, $messageId = false)
    {
        if (isset($data['invitation'])) {
            $invitation = $data['invitation'];
            $invoice = $invitation->invoice;
            $notes = isset($data['notes']) ? $data['notes'] : false;

            if (! empty($data['proposal'])) {
                $invitation->markSent($messageId);
            } else {
                $invoice->markInvitationSent($invitation, $messageId, true, $notes);
            }
        }

        return true;
    }

    /**
     * @param $exception
     *
     * @return string
     */
    private function handleFailure($data, $emailError)
    {
        if (isset($data['invitation'])) {
            $invitation = $data['invitation'];
            $invitation->email_error = $emailError;
            $invitation->save();
        } elseif (! Utils::isNinjaProd()) {
            Utils::logError($emailError);
        }

        return $emailError;
    }
}