aboutsummaryrefslogtreecommitdiff
path: root/lib/pleroma/activity/queries.ex
diff options
context:
space:
mode:
authorIvan Tashkinov <ivantashkinov@gmail.com>2020-01-22 21:10:17 +0300
committerIvan Tashkinov <ivantashkinov@gmail.com>2020-01-22 21:10:17 +0300
commitcf96c4005743c61d44e17c9d37c6427eaf69c152 (patch)
treea3da096727b94385c6a735a363f19aa2844883fb /lib/pleroma/activity/queries.ex
parent6e6f1ead31ba26bc42b14226e3c0876042f0596a (diff)
downloadpleroma-cf96c4005743c61d44e17c9d37c6427eaf69c152.tar.gz
[#1505] Added Mastodon-compatible `replies` collection to Note federated representation.
Diffstat (limited to 'lib/pleroma/activity/queries.ex')
-rw-r--r--lib/pleroma/activity/queries.ex18
1 files changed, 17 insertions, 1 deletions
diff --git a/lib/pleroma/activity/queries.ex b/lib/pleroma/activity/queries.ex
index 79f305201..c17affec9 100644
--- a/lib/pleroma/activity/queries.ex
+++ b/lib/pleroma/activity/queries.ex
@@ -7,7 +7,7 @@ defmodule Pleroma.Activity.Queries do
Contains queries for Activity.
"""
- import Ecto.Query, only: [from: 2]
+ import Ecto.Query, only: [from: 2, where: 3]
@type query :: Ecto.Queryable.t() | Activity.t()
@@ -63,6 +63,22 @@ defmodule Pleroma.Activity.Queries do
)
end
+ @spec by_object_id(query, String.t()) :: query
+ def by_object_in_reply_to_id(query, in_reply_to_id, opts \\ []) do
+ query =
+ if opts[:skip_preloading] do
+ Activity.with_joined_object(query)
+ else
+ Activity.with_preloaded_object(query)
+ end
+
+ where(
+ query,
+ [activity, object: o],
+ fragment("(?)->>'inReplyTo' = ?", o.data, ^to_string(in_reply_to_id))
+ )
+ end
+
@spec by_type(query, String.t()) :: query
def by_type(query \\ Activity, activity_type) do
from(