aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorWilliam Pitcock <nenolod@dereferenced.org>2019-05-12 04:17:17 +0000
committerWilliam Pitcock <nenolod@dereferenced.org>2019-05-12 05:04:16 +0000
commit2aee62a4565d36983484ead9dda187e9e8188971 (patch)
tree3454e9446c7cee7528e1610a7470dc55fcbeea1a /lib
parent69158f10652e735e3300335dba3856a0233da89f (diff)
downloadpleroma-2aee62a4565d36983484ead9dda187e9e8188971.tar.gz
federator: publisher: only attempt publishing if we know the activity is representable
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/web/federator/publisher.ex8
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/pleroma/web/federator/publisher.ex b/lib/pleroma/web/federator/publisher.ex
index 8777a3deb..67f4b7ba7 100644
--- a/lib/pleroma/web/federator/publisher.ex
+++ b/lib/pleroma/web/federator/publisher.ex
@@ -39,7 +39,7 @@ defmodule Pleroma.Web.Federator.Publisher do
{:ok, _} ->
:ok
- {:error, _} ->
+ {:error, _e} ->
RetryQueue.enqueue(params, module)
end
end
@@ -58,8 +58,10 @@ defmodule Pleroma.Web.Federator.Publisher do
def publish(%User{} = user, %Activity{} = activity) do
Config.get([:instance, :federation_publisher_modules])
|> Enum.each(fn module ->
- Logger.info("Publishing #{activity.data["id"]} using #{inspect(module)}")
- module.publish(user, activity)
+ if module.is_representable?(activity) do
+ Logger.info("Publishing #{activity.data["id"]} using #{inspect(module)}")
+ module.publish(user, activity)
+ end
end)
:ok