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 alias Mobilizon.Service.Notifier use Mobilizon.Service.Workers.Helper, queue: "activity" @impl Oban.Worker def perform(%Job{args: args}) do with {"legacy_notify", args} <- Map.pop(args, "op") do activity = build_activity(args) args |> users_to_notify(author_id: args["author_id"], group_id: Map.get(args, "group_id")) |> Enum.each(&Notifier.notify(&1, activity, single_activity: true)) end 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 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() |> (fn %Event{organizer_actor: %Actor{id: actor_id}} -> [actor_id] end).() |> users_from_actor_ids(Keyword.fetch!(options, :author_id)) end defp users_to_notify(_, _), do: [] @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_settings!/1) end end