mirror of
https://github.com/appwrite/appwrite
synced 2026-05-09 10:10:51 +00:00
836ce852ed
Update the mails worker to only be responsible for building the final email using the base (layout) template and the user, team, project, and redirect variables. It is the responsibility of the controller to perform localization and determine whether a custom or default email template should be used. If the default one is used, it has to be rendered using the hello, footer, thanks, and signature variables so that it matches the custom template. Then, it can be sent to the worker.
129 lines
3.4 KiB
PHP
129 lines
3.4 KiB
PHP
<?php
|
|
|
|
namespace Appwrite\Platform\Workers;
|
|
|
|
use Appwrite\Template\Template;
|
|
use Exception;
|
|
use PHPMailer\PHPMailer\PHPMailer;
|
|
use Swoole\Runtime;
|
|
use Utopia\App;
|
|
use Utopia\CLI\Console;
|
|
use Utopia\Platform\Action;
|
|
use Utopia\Queue\Message;
|
|
use Utopia\Registry\Registry;
|
|
|
|
class Mails extends Action
|
|
{
|
|
public static function getName(): string
|
|
{
|
|
return 'mails';
|
|
}
|
|
|
|
/**
|
|
* @throws Exception
|
|
*/
|
|
public function __construct()
|
|
{
|
|
$this
|
|
->desc('Mails worker')
|
|
->inject('message')
|
|
->inject('register')
|
|
->callback(fn($message, $register) => $this->action($message, $register));
|
|
}
|
|
|
|
/**
|
|
* @param Message $message
|
|
* @param Registry $register
|
|
* @throws \PHPMailer\PHPMailer\Exception
|
|
* @return void
|
|
* @throws Exception
|
|
*/
|
|
public function action(Message $message, Registry $register): void
|
|
{
|
|
Runtime::setHookFlags(SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_TCP);
|
|
$payload = $message->getPayload() ?? [];
|
|
|
|
if (empty($payload)) {
|
|
throw new Exception('Missing payload');
|
|
}
|
|
|
|
$smtp = $payload['smtp'];
|
|
|
|
if (empty($smtp) && empty(App::getEnv('_APP_SMTP_HOST'))) {
|
|
Console::info('Skipped mail processing. No SMTP configuration has been set.');
|
|
return;
|
|
}
|
|
|
|
$recipient = $payload['recipient'];
|
|
$subject = $payload['subject'];
|
|
$variables = $payload['variables'];
|
|
$name = $payload['name'];
|
|
$body = $payload['body'];
|
|
|
|
$bodyTemplate = Template::fromFile(__DIR__ . '/../../../../app/config/locale/templates/email-base.tpl');
|
|
$bodyTemplate->setParam('{{body}}', $body);
|
|
|
|
foreach ($variables as $key => $value) {
|
|
$bodyTemplate->setParam('{{' . $key . '}}', $value);
|
|
}
|
|
|
|
$body = $bodyTemplate->render();
|
|
|
|
/** @var PHPMailer $mail */
|
|
$mail = empty($smtp)
|
|
? $register->get('smtp')
|
|
: $this->getMailer($smtp);
|
|
|
|
$mail->clearAddresses();
|
|
$mail->clearAllRecipients();
|
|
$mail->clearReplyTos();
|
|
$mail->clearAttachments();
|
|
$mail->clearBCCs();
|
|
$mail->clearCCs();
|
|
$mail->addAddress($recipient, $name);
|
|
$mail->Subject = $subject;
|
|
$mail->Body = $body;
|
|
$mail->AltBody = \strip_tags($body);
|
|
|
|
try {
|
|
$mail->send();
|
|
} catch (\Exception $error) {
|
|
throw new Exception('Error sending mail: ' . $error->getMessage(), 500);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param array $smtp
|
|
* @return PHPMailer
|
|
* @throws \PHPMailer\PHPMailer\Exception
|
|
*/
|
|
protected function getMailer(array $smtp): PHPMailer
|
|
{
|
|
$mail = new PHPMailer(true);
|
|
|
|
$mail->isSMTP();
|
|
|
|
$username = $smtp['username'];
|
|
$password = $smtp['password'];
|
|
|
|
$mail->XMailer = 'Appwrite Mailer';
|
|
$mail->Host = $smtp['host'];
|
|
$mail->Port = $smtp['port'];
|
|
$mail->SMTPAuth = (!empty($username) && !empty($password));
|
|
$mail->Username = $username;
|
|
$mail->Password = $password;
|
|
$mail->SMTPSecure = $smtp['secure'];
|
|
$mail->SMTPAutoTLS = false;
|
|
$mail->CharSet = 'UTF-8';
|
|
|
|
$mail->setFrom($smtp['senderEmail'], $smtp['senderName']);
|
|
|
|
if (!empty($smtp['replyTo'])) {
|
|
$mail->addReplyTo($smtp['replyTo'], $smtp['senderName']);
|
|
}
|
|
|
|
$mail->isHTML();
|
|
|
|
return $mail;
|
|
}
|
|
}
|