149 lines
3.6 KiB
Elixir
149 lines
3.6 KiB
Elixir
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.Gettext, as: GettextBackend
|
|
|
|
@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
|
|
GettextBackend.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
|
|
|
|
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
|
|
|
|
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
|
|
|
|
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
|