|
|
@@ -3,20 +3,46 @@ |
|
|
|
# SPDX-License-Identifier: AGPL-3.0-only |
|
|
|
|
|
|
|
defmodule Pleroma.Web.ActivityPub.MRF.HellthreadPolicy do |
|
|
|
alias Pleroma.User |
|
|
|
@behaviour Pleroma.Web.ActivityPub.MRF |
|
|
|
|
|
|
|
defp delist_message(message) do |
|
|
|
follower_collection = User.get_cached_by_ap_id(message["actor"]).follower_address |
|
|
|
|
|
|
|
message |
|
|
|
|> Map.put("to", [follower_collection]) |
|
|
|
|> Map.put("cc", ["https://www.w3.org/ns/activitystreams#Public"]) |
|
|
|
end |
|
|
|
|
|
|
|
@impl true |
|
|
|
def filter(%{"type" => "Create"} = object) do |
|
|
|
threshold = Pleroma.Config.get([:mrf_hellthread, :threshold]) |
|
|
|
recipients = (object["to"] || []) ++ (object["cc"] || []) |
|
|
|
|
|
|
|
if length(recipients) > threshold do |
|
|
|
{:reject, nil} |
|
|
|
else |
|
|
|
{:ok, object} |
|
|
|
def filter(%{"type" => "Create"} = message) do |
|
|
|
delist_threshold = Pleroma.Config.get([:mrf_hellthread, :delist_threshold]) |
|
|
|
|
|
|
|
reject_threshold = |
|
|
|
Pleroma.Config.get( |
|
|
|
[:mrf_hellthread, :reject_threshold], |
|
|
|
Pleroma.Config.get([:mrf_hellthread, :threshold]) |
|
|
|
) |
|
|
|
|
|
|
|
recipients = (message["to"] || []) ++ (message["cc"] || []) |
|
|
|
|
|
|
|
cond do |
|
|
|
length(recipients) > reject_threshold and reject_threshold > 0 -> |
|
|
|
{:reject, nil} |
|
|
|
|
|
|
|
length(recipients) > delist_threshold and delist_threshold > 0 -> |
|
|
|
if Enum.member?(message["to"], "https://www.w3.org/ns/activitystreams#Public") or |
|
|
|
Enum.member?(message["cc"], "https://www.w3.org/ns/activitystreams#Public") do |
|
|
|
{:ok, delist_message(message)} |
|
|
|
else |
|
|
|
{:ok, message} |
|
|
|
end |
|
|
|
|
|
|
|
true -> |
|
|
|
{:ok, message} |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
@impl true |
|
|
|
def filter(object), do: {:ok, object} |
|
|
|
def filter(message), do: {:ok, message} |
|
|
|
end |