"Create" => "mention",
"Follow" => "follow",
"Announce" => "reblog",
- "Like" => "favourite"
+ "Like" => "favourite",
+ "Move" => "move",
+ "EmojiReaction" => "pleroma:emoji_reaction"
}
@mastodon_to_ap_notification_types for {k, v} <- @mastodon_notification_types,
def normalize(ap_id) when is_binary(ap_id), do: get_by_ap_id_with_object(ap_id)
def normalize(_), do: nil
- def delete_by_ap_id(id) when is_binary(id) do
+ def delete_all_by_object_ap_id(id) when is_binary(id) do
id
|> Queries.by_object_id()
+ |> Queries.exclude_type("Delete")
|> select([u], u)
|> Repo.delete_all()
|> elem(1)
|> purge_web_resp_cache()
end
- def delete_by_ap_id(_), do: nil
+ def delete_all_by_object_ap_id(_), do: nil
defp purge_web_resp_cache(%Activity{} = activity) do
%{path: path} = URI.parse(activity.data["id"])
from(u in User.Query.build(deactivated: true), select: u.ap_id)
|> Repo.all()
- from(activity in query,
- where: activity.actor not in ^deactivated_users
- )
+ Activity.Queries.exclude_authors(query, deactivated_users)
end
defdelegate search(user, query, options \\ []), to: Pleroma.Activity.Search
_ -> 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))
end