X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;ds=sidebyside;f=lib%2Fpleroma%2Fweb%2Factivity_pub%2Fmrf%2Freject_non_public.ex;h=4197be847c635167e95bd30af053b00f3f0aa0cf;hb=0b54c3d6432dea77542596e34057f8d3fc69ca4c;hp=9719a48d575d17de171fa28c51c620b80bb971bc;hpb=5b9e1f228ae21cc1749914d375bb3644e8048df4;p=akkoma diff --git a/lib/pleroma/web/activity_pub/mrf/reject_non_public.ex b/lib/pleroma/web/activity_pub/mrf/reject_non_public.ex index 9719a48d5..4197be847 100644 --- a/lib/pleroma/web/activity_pub/mrf/reject_non_public.ex +++ b/lib/pleroma/web/activity_pub/mrf/reject_non_public.ex @@ -1,35 +1,50 @@ +# Pleroma: A lightweight social networking server +# Copyright © 2017-2019 Pleroma Authors +# SPDX-License-Identifier: AGPL-3.0-only + defmodule Pleroma.Web.ActivityPub.MRF.RejectNonPublic do alias Pleroma.User @behaviour Pleroma.Web.ActivityPub.MRF - def filter(object) do - if object["type"] == "Create" do - user = User.get_by_ap_id(object["actor"]) - public = "https://www.w3.org/ns/activitystreams#Public" - - #Determine visibility - visibility = - cond do - #Public - public in object["to"] -> "p" - #Unlisted - public in object["cc"] -> "u" - #Followers-only - user.follower_address in object["to"] -> "f" - #Direct - true -> "d" - end + @impl true + def filter(%{"type" => "Create"} = object) do + user = User.get_cached_by_ap_id(object["actor"]) + public = "https://www.w3.org/ns/activitystreams#Public" + + # Determine visibility + visibility = + cond do + public in object["to"] -> "public" + public in object["cc"] -> "unlisted" + user.follower_address in object["to"] -> "followers" + true -> "direct" + end + + policy = Pleroma.Config.get(:mrf_rejectnonpublic) - {flag, object_out} = - case visibility do - "p" -> {:ok, object} - "u" -> {:ok, object} - _ -> {:reject, nil} + case visibility do + "public" -> + {:ok, object} + + "unlisted" -> + {:ok, object} + + "followers" -> + with true <- Keyword.get(policy, :allow_followersonly) do + {:ok, object} + else + _e -> {:reject, nil} end - {flag, object_out} - else - {:ok, object} + "direct" -> + with true <- Keyword.get(policy, :allow_direct) do + {:ok, object} + else + _e -> {:reject, nil} + end end end + + @impl true + def filter(object), do: {:ok, object} end