diff options
author | lain <lain@soykaf.club> | 2018-04-28 16:10:24 +0200 |
---|---|---|
committer | lain <lain@soykaf.club> | 2018-04-28 16:10:24 +0200 |
commit | 4d55d7c95e8409f5018f3321d7e653b6349b9ba6 (patch) | |
tree | 6f562f413ce2299591092f19d421bf60a6fd3dfb /lib | |
parent | a7a40bb8f1eaf30f0f0d581089ff3ef45de4087c (diff) | |
download | pleroma-4d55d7c95e8409f5018f3321d7e653b6349b9ba6.tar.gz |
Insert object after being rewritten.
Diffstat (limited to 'lib')
-rw-r--r-- | lib/pleroma/web/activity_pub/activity_pub.ex | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/pleroma/web/activity_pub/activity_pub.ex b/lib/pleroma/web/activity_pub/activity_pub.ex index 984d1162d..3ddc009a1 100644 --- a/lib/pleroma/web/activity_pub/activity_pub.ex +++ b/lib/pleroma/web/activity_pub/activity_pub.ex @@ -20,8 +20,8 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do def insert(map, local \\ true) when is_map(map) do with nil <- Activity.get_by_ap_id(map["id"]), map <- lazy_put_activity_defaults(map), - :ok <- insert_full_object(map), - {:ok, map} <- @rewrite_policy.filter(map) do + {:ok, map} <- @rewrite_policy.filter(map), + :ok <- insert_full_object(map) do {:ok, activity} = Repo.insert(%Activity{ data: map, @@ -313,7 +313,9 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do defp restrict_blocked(query, %{"blocking_user" => %User{info: info}}) do blocks = info["blocks"] || [] - from(activity in query, + + from( + activity in query, where: fragment("not (? = ANY(?))", activity.actor, ^blocks), where: fragment("not (?->'to' \\?| ?)", activity.data, ^blocks) ) |