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 alias Mobilizon.Web.JsonLD.ObjectView @important_changes [:title, :begins_on, :ends_on, :status, :physical_address] @spec event_updated( Participant.t(), String.t(), Actor.t(), Event.t(), Event.t(), MapSet.t(), String.t() ) :: Bamboo.Email.t() def event_updated( email, %Participant{} = participant, %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 ) json_ld = "participation.json" |> ObjectView.render(%{participant: %Participant{participant | event: event, actor: actor}}) |> Jason.encode!() 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) |> assign(:jsonLDMetadata, json_ld) |> 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( 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( participant, email, actor, old_event, event, diff, "Etc/UTC", locale ) end defp send_notification_for_event_update_to_participant( {%Participant{metadata: %{email: email} = participant_metadata} = 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( participant, email, actor, old_event, event, diff, Map.get(participant_metadata, :timezone, "Etc/UTC"), locale ) end @spec do_send_notification_for_event_update_to_participant( Participant.t(), 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( participant, email, actor, old_event, event, diff, timezone, locale ) do email |> Email.Event.event_updated(participant, actor, old_event, event, diff, timezone, locale) |> Email.Mailer.send_email_later() end end