X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fweb%2Factivity_pub%2Fside_effects.ex;h=0460289b77c63152dbd9f6bd16ff14ae5a4274c3;hb=12a171844b139cd6ea61e24ff9bc7f1b5e41ec51;hp=39d37fbcb8210e982d43021b02c7325d6f5bdc5a;hpb=e25af3f2d8ee5459d20b67049da8d2e99f5d72a7;p=akkoma diff --git a/lib/pleroma/web/activity_pub/side_effects.ex b/lib/pleroma/web/activity_pub/side_effects.ex index 39d37fbcb..0460289b7 100644 --- a/lib/pleroma/web/activity_pub/side_effects.ex +++ b/lib/pleroma/web/activity_pub/side_effects.ex @@ -538,6 +538,18 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do end @impl true + def handle_after_transaction(%Pleroma.Activity{data: %{"type" => "Create"}} = activity) do + Pleroma.Elasticsearch.put_by_id(:activity, activity.id) + end + + def handle_after_transaction(%Pleroma.Activity{}) do + :ok + end + + def handle_after_transaction(%Pleroma.Object{}) do + :ok + end + def handle_after_transaction(meta) do meta |> send_notifications()