X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Factivity.ex;h=f226c4c5f351d797a9eac90bc835645c230c10bd;hb=5dc278b1a68a244ad09853ef3e9a100851a51420;hp=40e14005b07d4d50ed64ea112c041924058af4a4;hpb=9cf38d679671181cf539883981f92e6777beb951;p=akkoma diff --git a/lib/pleroma/activity.ex b/lib/pleroma/activity.ex index 40e14005b..f226c4c5f 100644 --- a/lib/pleroma/activity.ex +++ b/lib/pleroma/activity.ex @@ -15,9 +15,19 @@ defmodule Pleroma.Activity do where: fragment("(?)->>'id' = ?", activity.data, ^to_string(ap_id))) end + # Wrong name, only returns create activities + def all_by_object_ap_id_q(ap_id) do + from activity in Activity, + where: fragment("(?)->'object'->>'id' = ?", activity.data, ^to_string(ap_id)) + end + + def all_non_create_by_object_ap_id_q(ap_id) do + from activity in Activity, + where: fragment("(?)->>'object' = ?", activity.data, ^to_string(ap_id)) + end + def all_by_object_ap_id(ap_id) do - Repo.all(from activity in Activity, - where: fragment("(?)->'object'->>'id' = ?", activity.data, ^to_string(ap_id))) + Repo.all(all_by_object_ap_id_q(ap_id)) end def get_create_activity_by_object_ap_id(ap_id) do