erin/akkoma
1
0
Fork 0
forked from mirrors/akkoma
Code Activity

pipeline it

Browse source
This commit is contained in:
FloatingGhost 2021-12-12 19:39:07 +00:00
parent f341e68622
commit 7502da993b
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/pleroma/web/activity_pub/pipeline.ex
View file

@ -27,7 +27,8 @@ defp config, do: Config.get([:pipeline, :config], Config)
def common_pipeline(object, meta) do def common_pipeline(object, meta) do
case Repo.transaction(fn -> do_common_pipeline(object, meta) end, Utils.query_timeout()) do case Repo.transaction(fn -> do_common_pipeline(object, meta) end, Utils.query_timeout()) do
{:ok, {:ok, activity, meta}} -> {:ok, {:ok, activity, meta}} ->
side_effects().handle_after_transaction(activity, meta) side_effects().handle_after_transaction(meta)
side_effects().handle_after_transaction(activity)
{:ok, activity, meta} {:ok, activity, meta}
{:ok, value} -> {:ok, value} ->

9
lib/pleroma/web/activity_pub/side_effects.ex
View file

@ -537,11 +537,16 @@ defp add_notifications(meta, notifications) do
end end
@impl true @impl true
def handle_after_transaction(activity, meta) do @impl true
Pleroma.Elasticsearch.put_by_id(activity.id) def handle_after_transaction(%{data: %{"type" => "Create"}} = activity) do
Elasticsearch.put_by_id(activity.id)
end
def handle_after_transaction(meta) do
meta meta
|> send_notifications() |> send_notifications()
|> send_streamables() |> send_streamables()
end end
def handle_after_transaction(_), do: :ok
end end