Ingestion Pipeline: Listenfeatures/ingestion-listen

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