mobilizon/lib/service/activity/discussion.ex

defmodule Mobilizon.Service.Activity.Discussion do
  @moduledoc """
  Insert a discussion activity
  """
  alias Mobilizon.{Actors, Discussions}
  alias Mobilizon.Actors.Actor
  alias Mobilizon.Discussions.{Comment, Discussion}
  alias Mobilizon.Service.Activity
  alias Mobilizon.Service.Workers.{ActivityBuilder, LegacyNotifierBuilder}

  import Mobilizon.Service.Activity.Utils, only: [maybe_inserted_at: 0]

  @behaviour Activity

  @impl Activity
  def insert_activity(discussion, options \\ [])

  def insert_activity(
        %Discussion{creator_id: creator_id, actor_id: actor_id} = discussion,
        options
      )
      when not is_nil(creator_id) do
    creator = Actors.get_actor(creator_id)
    group = Actors.get_actor(actor_id)
    subject = Keyword.fetch!(options, :subject)
    author = Keyword.get(options, :moderator, creator)
    author_id = Keyword.get(options, :actor_id, author.id)
    old_discussion = Keyword.get(options, :old_discussion)

    send_mention_notifications(subject, discussion, discussion.last_comment, options)

    ActivityBuilder.enqueue(
      :build_activity,
      %{
        "type" => "discussion",
        "subject" => subject,
        "subject_params" => subject_params(discussion, subject, old_discussion),
        "group_id" => group.id,
        "author_id" => author_id,
        "object_type" => "discussion",
        "object_id" =>
          if(subject != "discussion_deleted", do: to_string(discussion.id), else: nil)
      }
      |> Map.merge(maybe_inserted_at())
    )
  end

  def insert_activity(_, _), do: {:ok, nil}

  @impl Activity
  def get_object(discussion_id) do
    Discussions.get_discussion(discussion_id)
  end

  @spec subject_params(Discussion.t(), String.t() | nil, Discussion.t() | nil) :: map()
  defp subject_params(%Discussion{} = discussion, "discussion_renamed", old_discussion) do
    discussion
    |> subject_params(nil, nil)
    |> Map.put(:old_discussion_title, old_discussion.title)
  end

  defp subject_params(%Discussion{} = discussion, _, _) do
    %{discussion_slug: discussion.slug, discussion_title: discussion.title}
  end

  # An actor is mentionned
  @spec send_mention_notifications(String.t(), Discussion.t(), Comment.t(), Keyword.t()) ::
          {:ok, Oban.Job.t()} | {:ok, :skipped}
  defp send_mention_notifications(
         subject,
         %Discussion{
           id: discussion_id,
           title: title,
           slug: slug,
           actor: %Actor{id: group_id, type: :Group}
         },
         %Comment{actor_id: actor_id, mentions: mentions},
         _options
       )
       when subject in ["discussion_created", "discussion_replied"] and length(mentions) > 0 do
    LegacyNotifierBuilder.enqueue(
      :legacy_notify,
      %{
        "subject" => :discussion_mention,
        "subject_params" => %{
          discussion_slug: slug,
          discussion_title: title
        },
        "type" => :discussion,
        "object_type" => :discussion,
        "author_id" => actor_id,
        "group_id" => group_id,
        "object_id" => to_string(discussion_id),
        "mentions" => Enum.map(mentions, & &1.actor_id)
      }
    )

    {:ok, :enqueued}
  end

  defp send_mention_notifications(_, _, _, _), do: {:ok, :skipped}
end