Page Menu
Home
Phorge
Search
Configure Global Search
Log In
Files
F21841529
mailer.ex
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Award Token
Flag For Later
Size
1 KB
Referenced Files
None
Subscribers
None
mailer.ex
View Options
# Pleroma: A lightweight social networking server
# Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only
defmodule
Pleroma.Emails.Mailer
do
@moduledoc
"""
Defines the Pleroma mailer.
The module contains functions to delivery email using Swoosh.Mailer.
"""
alias
Pleroma.Workers.MailerWorker
alias
Swoosh.DeliveryError
@otp_app
:pleroma
@mailer_config
[
otp
:
:pleroma
]
@spec
enabled?
()
::
boolean
()
def
enabled?
,
do
:
Pleroma.Config
.
get
([
__MODULE__
,
:enabled
])
@doc
"add email to queue"
def
deliver_async
(
email
,
config
\\
[])
do
encoded_email
=
email
|>
:erlang
.
term_to_binary
()
|>
Base
.
encode64
()
MailerWorker
.
enqueue
(
"email"
,
%{
"encoded_email"
=>
encoded_email
,
"config"
=>
config
})
end
@doc
"callback to perform send email from queue"
def
perform
(
:deliver_async
,
email
,
config
),
do
:
deliver
(
email
,
config
)
@spec
deliver
(
Swoosh.Email
.
t
(),
Keyword
.
t
())
::
{
:ok
,
term
}
|
{
:error
,
term
}
def
deliver
(
email
,
config
\\
[])
def
deliver
(
email
,
config
)
do
# temporary hackney fix until hackney max_connections bug is fixed
# https://git.pleroma.social/pleroma/pleroma/-/issues/2101
email
=
Swoosh.Email
.
put_private
(
email
,
:hackney_options
,
ssl_options
:
[
versions
:
[
:"tlsv1.2"
]])
case
enabled?
()
do
true
->
Swoosh.Mailer
.
deliver
(
email
,
parse_config
(
config
))
false
->
{
:error
,
:deliveries_disabled
}
end
end
@spec
deliver!
(
Swoosh.Email
.
t
(),
Keyword
.
t
())
::
term
|
no_return
def
deliver!
(
email
,
config
\\
[])
def
deliver!
(
email
,
config
)
do
case
deliver
(
email
,
config
)
do
{
:ok
,
result
}
->
result
{
:error
,
reason
}
->
raise
DeliveryError
,
reason
:
reason
end
end
@on_load
:validate_dependency
@doc
false
def
validate_dependency
do
parse_config
([])
|>
Keyword
.
get
(
:adapter
)
|>
Swoosh.Mailer
.
validate_dependency
()
end
defp
parse_config
(
config
)
do
Swoosh.Mailer
.
parse_config
(
@otp_app
,
__MODULE__
,
@mailer_config
,
config
)
end
end
File Metadata
Details
Attached
Mime Type
text/x-ruby
Expires
Sat, Dec 27, 11:50 PM (1 d, 22 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
799113
Default Alt Text
mailer.ex (1 KB)
Attached To
Mode
rPUBE pleroma-upstream
Attached
Detach File
Event Timeline
Log In to Comment