134 lines
4.2 KiB
Elixir
134 lines
4.2 KiB
Elixir
defmodule Mobilizon.Service.Workers.LegacyNotifierBuilder do
|
|
@moduledoc """
|
|
Worker to push legacy notifications
|
|
"""
|
|
|
|
alias Mobilizon.Activities.Activity
|
|
alias Mobilizon.{Actors, Events, Users}
|
|
alias Mobilizon.Actors.Actor
|
|
alias Mobilizon.Events.{Event, Participant}
|
|
alias Mobilizon.Service.Notifier
|
|
require Logger
|
|
|
|
use Mobilizon.Service.Workers.Helper, queue: "activity"
|
|
|
|
@impl Oban.Worker
|
|
def perform(%Job{args: args}) do
|
|
{"legacy_notify", args} = Map.pop(args, "op")
|
|
activity = build_activity(args)
|
|
Logger.debug("Handling activity #{activity.subject} to notify in LegacyNotifierBuilder")
|
|
|
|
if args["subject"] == "participation_event_comment" do
|
|
notify_anonymous_participants(get_in(args, ["subject_params", "event_id"]), activity)
|
|
end
|
|
|
|
args
|
|
|> users_to_notify(author_id: args["author_id"], group_id: Map.get(args, "group_id"))
|
|
|> Enum.each(¬ify_user(&1, activity))
|
|
end
|
|
|
|
defp build_activity(args) do
|
|
author = Actors.get_actor(args["author_id"])
|
|
|
|
%Activity{
|
|
type: String.to_existing_atom(args["type"]),
|
|
subject: String.to_existing_atom(args["subject"]),
|
|
subject_params: args["subject_params"],
|
|
inserted_at: DateTime.utc_now(),
|
|
object_type: String.to_existing_atom(args["object_type"]),
|
|
object_id: args["object_id"],
|
|
group: nil,
|
|
author: author
|
|
}
|
|
end
|
|
|
|
@spec users_to_notify(map(), Keyword.t()) :: list(Users.t())
|
|
defp users_to_notify(
|
|
%{"subject" => "event_comment_mention", "mentions" => mentionned_actor_ids},
|
|
options
|
|
) do
|
|
users_from_actor_ids(mentionned_actor_ids, Keyword.fetch!(options, :author_id))
|
|
end
|
|
|
|
@spec users_to_notify(map(), Keyword.t()) :: list(Users.t())
|
|
defp users_to_notify(
|
|
%{"subject" => subject, "participant" => %{"actor_id" => actor_id}},
|
|
options
|
|
)
|
|
when subject in ["conversation_created", "conversation_replied"] do
|
|
users_from_actor_ids([actor_id], Keyword.fetch!(options, :author_id))
|
|
end
|
|
|
|
defp users_to_notify(
|
|
%{"subject" => "discussion_mention", "mentions" => mentionned_actor_ids},
|
|
options
|
|
) do
|
|
mentionned_actor_ids
|
|
|> Enum.filter(&Actors.is_member?(&1, Keyword.fetch!(options, :group_id)))
|
|
|> users_from_actor_ids(Keyword.fetch!(options, :author_id))
|
|
end
|
|
|
|
defp users_to_notify(
|
|
%{
|
|
"subject" => "participation_event_comment",
|
|
"subject_params" => subject_params
|
|
},
|
|
options
|
|
) do
|
|
subject_params
|
|
|> Map.get("event_id")
|
|
|> Events.list_actors_participants_for_event()
|
|
|> Enum.map(& &1.id)
|
|
|> users_from_actor_ids(Keyword.fetch!(options, :author_id))
|
|
end
|
|
|
|
defp users_to_notify(
|
|
%{"subject" => "event_new_comment", "subject_params" => %{"event_uuid" => event_uuid}},
|
|
options
|
|
) do
|
|
event_uuid
|
|
|> Events.get_event_by_uuid_with_preload()
|
|
|> organizer_actor_id()
|
|
|> users_from_actor_ids(Keyword.fetch!(options, :author_id))
|
|
end
|
|
|
|
defp users_to_notify(_, _), do: []
|
|
|
|
defp organizer_actor_id(%Event{organizer_actor: %Actor{id: actor_id}}) do
|
|
[actor_id]
|
|
end
|
|
|
|
@spec users_from_actor_ids(list(), integer() | String.t()) :: list(Users.t())
|
|
defp users_from_actor_ids(actor_ids, author_id) do
|
|
actor_ids
|
|
|> Enum.filter(&(&1 != author_id))
|
|
|> Enum.map(&Actors.get_actor/1)
|
|
|> Enum.filter(& &1)
|
|
|> Enum.map(& &1.user_id)
|
|
|> Enum.filter(& &1)
|
|
|> Enum.uniq()
|
|
|> Enum.map(&Users.get_user_with_activity_settings!/1)
|
|
end
|
|
|
|
defp notify_anonymous_participants(nil, _activity), do: :ok
|
|
|
|
defp notify_anonymous_participants(event_id, activity) do
|
|
event_id
|
|
|> Events.list_anonymous_participants_for_event()
|
|
|> Enum.filter(fn %Participant{metadata: metadata} ->
|
|
is_map(metadata) && is_binary(metadata.email)
|
|
end)
|
|
|> Enum.map(fn %Participant{metadata: metadata} -> metadata end)
|
|
|> Enum.map(fn %{email: email} = metadata ->
|
|
Notifier.Email.send_anonymous_activity(email, activity,
|
|
locale: Map.get(metadata, :locale, "en")
|
|
)
|
|
end)
|
|
end
|
|
|
|
defp notify_user(user, activity) do
|
|
Logger.debug("Notifying #{user.email} for activity #{activity.subject}")
|
|
Notifier.notify(user, activity, single_activity: true)
|
|
end
|
|
end
|