git.squeep.com Git - akkoma/blob - lib/pleroma/web/activity_pub/mrf/simple_policy.ex

   1 defmodule Pleroma.Web.ActivityPub.MRF.SimplePolicy do
   2   alias Pleroma.User
   3   @behaviour Pleroma.Web.ActivityPub.MRF
   4
   5   @mrf_policy Application.get_env(:pleroma, :mrf_simple)
   6
   7   @reject Keyword.get(@mrf_policy, :reject)
   8   defp check_reject(actor_info, object) do
   9     if actor_info.host in @reject do
  10       {:reject, nil}
  11     else
  12       {:ok, object}
  13     end
  14   end
  15
  16   @media_removal Keyword.get(@mrf_policy, :media_removal)
  17   defp check_media_removal(actor_info, object) do
  18     if actor_info.host in @media_removal do
  19       child_object = Map.delete(object["object"], "attachment")
  20       object = Map.put(object, "object", child_object)
  21       {:ok, object}
  22     else
  23       {:ok, object}
  24     end
  25   end
  26
  27   @media_nsfw Keyword.get(@mrf_policy, :media_nsfw)
  28   defp check_media_nsfw(actor_info, object) do
  29     child_object = object["object"]
  30
  31     if actor_info.host in @media_nsfw and child_object["attachment"] != nil and
  32          length(child_object["attachment"]) > 0 do
  33       tags = (child_object["tag"] || []) ++ ["nsfw"]
  34       child_object = Map.put(child_object, "tags", tags)
  35       child_object = Map.put(child_object, "sensitive", true)
  36       object = Map.put(object, "object", child_object)
  37       {:ok, object}
  38     else
  39       {:ok, object}
  40     end
  41   end
  42
  43   @ftl_removal Keyword.get(@mrf_policy, :federated_timeline_removal)
  44   defp check_ftl_removal(actor_info, object) do
  45     if actor_info.host in @ftl_removal do
  46       user = User.get_by_ap_id(object["actor"])
  47
  48       # flip to/cc relationship to make the post unlisted
  49       object =
  50         if "https://www.w3.org/ns/activitystreams#Public" in object["to"] and
  51              user.follower_address in object["cc"] do
  52           to =
  53             List.delete(object["to"], "https://www.w3.org/ns/activitystreams#Public") ++
  54               [user.follower_address]
  55
  56           cc =
  57             List.delete(object["cc"], user.follower_address) ++
  58               ["https://www.w3.org/ns/activitystreams#Public"]
  59
  60           object
  61           |> Map.put("to", to)
  62           |> Map.put("cc", cc)
  63         else
  64           object
  65         end
  66
  67       {:ok, object}
  68     else
  69       {:ok, object}
  70     end
  71   end
  72
  73   @impl true
  74   def filter(object) do
  75     actor_info = URI.parse(object["actor"])
  76
  77     with {:ok, object} <- check_reject(actor_info, object),
  78          {:ok, object} <- check_media_removal(actor_info, object),
  79          {:ok, object} <- check_media_nsfw(actor_info, object),
  80          {:ok, object} <- check_ftl_removal(actor_info, object) do
  81       {:ok, object}
  82     else
  83       _e -> {:reject, nil}
  84     end
  85   end
  86 end