defmodule Mobilizon.Web.Email.Event do @moduledoc """ Handles emails sent about events. """ use Bamboo.Phoenix, view: Mobilizon.Web.EmailView import Bamboo.Phoenix import Mobilizon.Web.Gettext alias Mobilizon.Actors.Actor alias Mobilizon.Events alias Mobilizon.Events.{Event, Participant} alias Mobilizon.Storage.Repo alias Mobilizon.Users.{Setting, User} alias Mobilizon.Web.Email @important_changes [:title, :begins_on, :ends_on, :status, :physical_address] @spec event_updated(String.t(), Actor.t(), Event.t(), Event.t(), MapSet.t(), String.t()) :: Bamboo.Email.t() def event_updated( email, %Actor{} = actor, %Event{} = old_event, %Event{} = event, changes, timezone \\ "Etc/UTC", locale \\ "en" ) do Gettext.put_locale(locale) subject = gettext( "Event %{title} has been updated", title: old_event.title ) Email.base_email(to: {Actor.display_name(actor), email}, subject: subject) |> assign(:locale, locale) |> assign(:event, event) |> assign(:old_event, old_event) |> assign(:changes, changes) |> assign(:subject, subject) |> assign(:timezone, timezone) |> Email.add_event_attachment(event) |> render(:event_updated) end @spec calculate_event_diff_and_send_notifications(Event.t(), Event.t(), map()) :: {:ok, :ok} def calculate_event_diff_and_send_notifications( %Event{} = old_event, %Event{id: event_id} = event, changes ) do important = MapSet.new(@important_changes) diff = changes |> Map.keys() |> MapSet.new() |> MapSet.intersection(important) if MapSet.size(diff) > 0 do Repo.transaction(fn -> event_id |> Events.list_local_emails_user_participants_for_event_query() |> Repo.stream() |> Enum.to_list() |> Enum.each( &send_notification_for_event_update_to_participant(&1, old_event, event, diff) ) end) end end @spec send_notification_for_event_update_to_participant( {Participant.t(), Actor.t(), User.t() | nil, Setting.t() | nil}, Event.t(), Event.t(), MapSet.t() ) :: Bamboo.Email.t() defp send_notification_for_event_update_to_participant( {%Participant{} = _participant, %Actor{} = actor, %User{locale: locale, email: email} = _user, %Setting{timezone: timezone}}, %Event{} = old_event, %Event{} = event, diff ) do do_send_notification_for_event_update_to_participant( email, actor, old_event, event, diff, timezone, locale ) end defp send_notification_for_event_update_to_participant( {%Participant{} = _participant, %Actor{} = actor, %User{locale: locale, email: email} = _user, nil}, %Event{} = old_event, %Event{} = event, diff ) do do_send_notification_for_event_update_to_participant( email, actor, old_event, event, diff, "Etc/UTC", locale ) end defp send_notification_for_event_update_to_participant( {%Participant{metadata: %{email: email}} = _participant, %Actor{} = actor, nil, nil}, %Event{} = old_event, %Event{} = event, diff ) when not is_nil(email) do locale = Gettext.get_locale() do_send_notification_for_event_update_to_participant( email, actor, old_event, event, diff, "Etc/UTC", locale ) end @spec do_send_notification_for_event_update_to_participant( String.t(), Actor.t(), Event.t(), Event.t(), MapSet.t(), String.t(), String.t() ) :: Bamboo.Email.t() defp do_send_notification_for_event_update_to_participant( email, actor, old_event, event, diff, timezone, locale ) do email |> Email.Event.event_updated(actor, old_event, event, diff, timezone, locale) |> Email.Mailer.send_email_later() end end