148 lines
4.1 KiB
Elixir
148 lines
4.1 KiB
Elixir
defmodule Mobilizon.Web.Email.Activity do
|
|
@moduledoc """
|
|
Handles emails sent about activity notifications.
|
|
"""
|
|
use Bamboo.Phoenix, view: Mobilizon.Web.EmailView
|
|
|
|
import Bamboo.Phoenix
|
|
import Mobilizon.Web.Gettext
|
|
|
|
alias Mobilizon.Activities.Activity
|
|
alias Mobilizon.Actors.Actor
|
|
alias Mobilizon.Config
|
|
alias Mobilizon.Web.Email
|
|
|
|
@spec direct_activity(String.t(), list(), Keyword.t()) ::
|
|
Bamboo.Email.t()
|
|
def direct_activity(
|
|
email,
|
|
activities,
|
|
options \\ []
|
|
) do
|
|
locale = Keyword.get(options, :locale, "en")
|
|
single_activity = Keyword.get(options, :single_activity, false)
|
|
recap = Keyword.get(options, :recap, false)
|
|
Gettext.put_locale(locale)
|
|
|
|
subject = get_subject(recap)
|
|
|
|
chunked_activities = chunk_activities(activities)
|
|
|
|
Email.base_email(to: email, subject: subject)
|
|
|> assign(:locale, locale)
|
|
|> assign(:subject, subject)
|
|
|> assign(:activities, chunked_activities)
|
|
|> assign(:total_number_activities, length(activities))
|
|
|> assign(:single_activity, single_activity)
|
|
|> assign(:recap, recap)
|
|
|> render(:email_direct_activity)
|
|
end
|
|
|
|
@spec anonymous_activity(String.t(), Activity.t(), Keyword.t()) :: Bamboo.Email.t()
|
|
def anonymous_activity(email, %Activity{subject_params: subject_params} = activity, options) do
|
|
locale = Keyword.get(options, :locale, "en")
|
|
|
|
subject =
|
|
dgettext(
|
|
"activity",
|
|
"Announcement for your event %{event}",
|
|
event: subject_params["event_title"]
|
|
)
|
|
|
|
Email.base_email(to: email, subject: subject)
|
|
|> assign(:subject, subject)
|
|
|> assign(:activity, activity)
|
|
|> assign(:locale, locale)
|
|
|> render(:email_anonymous_activity)
|
|
end
|
|
|
|
@spec chunk_activities(list()) :: map()
|
|
defp chunk_activities(activities) do
|
|
activities
|
|
|> Enum.reduce(%{}, fn activity, acc ->
|
|
case activity do
|
|
%Activity{group: %Actor{id: group_id}} ->
|
|
Map.update(acc, group_id, [activity], fn activities -> activities ++ [activity] end)
|
|
|
|
# Not a group activity
|
|
%Activity{} ->
|
|
Map.update(acc, nil, [activity], fn activities -> activities ++ [activity] end)
|
|
end
|
|
end)
|
|
|> Enum.map(fn {key, value} ->
|
|
{key, Enum.sort(value, &(&1.inserted_at <= &2.inserted_at))}
|
|
end)
|
|
|> Enum.map(fn {key, value} -> {key, filter_duplicates(value)} end)
|
|
|> Enum.into(%{})
|
|
end
|
|
|
|
# We filter duplicates when subject_params are being the same
|
|
# so it will probably not catch much things
|
|
@spec filter_duplicates(list()) :: list()
|
|
defp filter_duplicates(activities) do
|
|
Enum.uniq_by(activities, fn activity ->
|
|
case activity do
|
|
%Activity{
|
|
author: %Actor{id: author_id},
|
|
group: %Actor{id: group_id},
|
|
type: type,
|
|
subject: subject,
|
|
subject_params: subject_params
|
|
} ->
|
|
%{
|
|
author_id: author_id,
|
|
group_id: group_id,
|
|
type: type,
|
|
subject: subject,
|
|
subject_params: subject_params
|
|
}
|
|
|
|
%Activity{
|
|
type: type,
|
|
subject: subject,
|
|
subject_params: subject_params
|
|
} ->
|
|
%{
|
|
type: type,
|
|
subject: subject,
|
|
subject_params: subject_params
|
|
}
|
|
end
|
|
end)
|
|
end
|
|
|
|
@spec get_subject(atom() | false) :: String.t()
|
|
defp get_subject(recap) do
|
|
if recap do
|
|
case recap do
|
|
:one_hour ->
|
|
dgettext(
|
|
"activity",
|
|
"Activity notification for %{instance}",
|
|
instance: Config.instance_name()
|
|
)
|
|
|
|
:one_day ->
|
|
dgettext(
|
|
"activity",
|
|
"Daily activity recap for %{instance}",
|
|
instance: Config.instance_name()
|
|
)
|
|
|
|
:one_week ->
|
|
dgettext(
|
|
"activity",
|
|
"Weekly activity recap for %{instance}",
|
|
instance: Config.instance_name()
|
|
)
|
|
end
|
|
else
|
|
dgettext(
|
|
"activity",
|
|
"Activity notification for %{instance}",
|
|
instance: Config.instance_name()
|
|
)
|
|
end
|
|
end
|
|
end
|