defmodule Mobilizon.Web.Email.Activity do @moduledoc """ Handles emails sent about activity notifications. """ use Phoenix.Swoosh, view: Mobilizon.Web.EmailView import Mobilizon.Web.Gettext alias Mobilizon.Activities.Activity alias Mobilizon.Actors.Actor alias Mobilizon.Config alias Mobilizon.Web.Email require Logger @spec direct_activity(String.t(), list(), Keyword.t()) :: Swoosh.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) [to: email, subject: subject] |> Email.base_email() |> render_body(:email_direct_activity, %{ locale: locale, subject: subject, activities: chunked_activities, total_number_activities: length(activities), single_activity: single_activity, recap: recap }) end @spec anonymous_activity(String.t(), Activity.t(), Keyword.t()) :: Swoosh.Email.t() def anonymous_activity( email, %Activity{subject_params: subject_params, type: :conversation} = activity, options ) do locale = Keyword.get(options, :locale, "en") Gettext.put_locale(locale) subject = dgettext( "activity", "Informations about your event %{event}", event: subject_params["conversation_event_title"] ) Logger.debug("Going to send anonymous activity of type #{activity.type} to #{email}") [to: email, subject: subject] |> Email.base_email() |> render_body(:email_anonymous_activity, %{ subject: subject, activity: activity, locale: locale }) end def anonymous_activity(email, %Activity{subject_params: subject_params} = activity, options) do locale = Keyword.get(options, :locale, "en") Gettext.put_locale(locale) subject = dgettext( "activity", "Announcement for your event %{event}", event: subject_params["event_title"] ) Logger.debug("Going to send anonymous activity of type #{activity.type} to #{email}") [to: email, subject: subject] |> Email.base_email() |> render_body(:email_anonymous_activity, %{ subject: subject, activity: activity, locale: locale }) 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