1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Emails.Mailer do
7 Defines the Pleroma mailer.
9 The module contains functions to delivery email using Swoosh.Mailer.
13 alias Pleroma.Workers.Mailer, as: MailerWorker
14 alias Swoosh.DeliveryError
17 @mailer_config [otp: :pleroma]
19 @spec enabled?() :: boolean()
20 def enabled?, do: Pleroma.Config.get([__MODULE__, :enabled])
22 defdelegate worker_args(queue), to: Pleroma.Workers.Helper
24 @doc "add email to queue"
25 def deliver_async(email, config \\ []) do
28 |> :erlang.term_to_binary()
31 %{"op" => "email", "encoded_email" => encoded_email, "config" => config}
32 |> MailerWorker.new(worker_args(:mailer))
36 @doc "callback to perform send email from queue"
37 def perform(:deliver_async, email, config), do: deliver(email, config)
39 @spec deliver(Swoosh.Email.t(), Keyword.t()) :: {:ok, term} | {:error, term}
40 def deliver(email, config \\ [])
42 def deliver(email, config) do
44 true -> Swoosh.Mailer.deliver(email, parse_config(config))
45 false -> {:error, :deliveries_disabled}
49 @spec deliver!(Swoosh.Email.t(), Keyword.t()) :: term | no_return
50 def deliver!(email, config \\ [])
52 def deliver!(email, config) do
53 case deliver(email, config) do
54 {:ok, result} -> result
55 {:error, reason} -> raise DeliveryError, reason: reason
59 @on_load :validate_dependency
62 def validate_dependency do
64 |> Keyword.get(:adapter)
65 |> Swoosh.Mailer.validate_dependency()
68 defp parse_config(config) do
69 Swoosh.Mailer.parse_config(@otp_app, __MODULE__, @mailer_config, config)