summaryrefslogtreecommitdiff
path: root/lib/pleroma/web/common_api.ex
diff options
context:
space:
mode:
Diffstat (limited to 'lib/pleroma/web/common_api.ex')
-rw-r--r--lib/pleroma/web/common_api.ex10
1 files changed, 8 insertions, 2 deletions
diff --git a/lib/pleroma/web/common_api.ex b/lib/pleroma/web/common_api.ex
index 1b95ee89c..d5a4e72fa 100644
--- a/lib/pleroma/web/common_api.ex
+++ b/lib/pleroma/web/common_api.ex
@@ -391,8 +391,14 @@ defmodule Pleroma.Web.CommonAPI do
end
def listen(user, data) do
- with {:ok, draft} <- ActivityDraft.listen(user, data) do
- ActivityPub.listen(draft.changes)
+ with {_, {:ok, %{changes: draft}}} <- {:draft, ActivityDraft.listen(user, data)},
+ {_, {:ok, activity_data, []}} <- {:builder, Builder.listen(draft, draft.additional)},
+ {_, {:ok, activity, _}} <-
+ {:pipeline, Pipeline.common_pipeline(activity_data, local: true)},
+ {_, %Activity{} = activity} <- {:norm, Activity.normalize(activity)} do
+ {:ok, activity}
+ else
+ e -> {:error, e}
end
end