AkkomaGang/akkoma
AkkomaGang/akkoma
13
63
Fork 84
Code Issues 162 Pull requests 12 Packages Projects 2 Releases 14 Wiki Activity

feature/elasticsearch #1

Merged
floatingghost merged 41 commits from feature/elasticsearch into develop 2021-12-12 17:37:28 +00:00
Conversation 0 Commits 41 Files changed 46 +9 -3
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit c4d2717beb - Show all commits

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

@ -27,7 +27,8 @@ defmodule Pleroma.Web.ActivityPub.Pipeline do
def common_pipeline(object, meta) do
case Repo.transaction(fn -> do_common_pipeline(object, meta) end, Utils.query_timeout()) do
{: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, value} ->

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

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