+
+ def direct_conversation_id(activity, for_user) do
+ alias Pleroma.Conversation.Participation
+
+ with %{data: %{"context" => context}} when is_binary(context) <- activity,
+ %Pleroma.Conversation{} = conversation <- Pleroma.Conversation.get_for_ap_id(context),
+ %Participation{id: participation_id} <-
+ Participation.for_user_and_conversation(for_user, conversation) do
+ participation_id
+ else
+ _ -> nil
+ end
+ end
+
+ def replies(activity, opts \\ []) do
+ object = Object.normalize(activity)
+
+ query =
+ Activity
+ |> Queries.by_type("Create")
+ |> Queries.by_object_in_reply_to_id(object.data["id"], skip_preloading: true)
+ |> order_by([activity], asc: activity.id)
+
+ if opts[:self_only] do
+ where(query, [a], a.actor == ^activity.actor)
+ else
+ query
+ end
+ end
+
+ def self_replies(activity, opts \\ []),
+ do: replies(activity, Keyword.put(opts, :self_only, true))