end
end
+ def react_with_emoji(user, object, emoji, options \\ []) do
+ with local <- Keyword.get(options, :local, true),
+ activity_id <- Keyword.get(options, :activity_id, nil),
+ Pleroma.Emoji.is_unicode_emoji?(emoji),
+ reaction_data <- make_emoji_reaction_data(user, object, emoji, activity_id),
+ {:ok, activity} <- insert(reaction_data, local),
+ {:ok, object} <- add_emoji_reaction_to_object(activity, object),
+ :ok <- maybe_federate(activity) do
+ {:ok, activity, object}
+ end
+ end
+
+ def unreact_with_emoji(user, reaction_id, options \\ []) do
+ with local <- Keyword.get(options, :local, true),
+ activity_id <- Keyword.get(options, :activity_id, nil),
+ user_ap_id <- user.ap_id,
+ %Activity{actor: ^user_ap_id} = reaction_activity <- Activity.get_by_ap_id(reaction_id),
+ object <- Object.normalize(reaction_activity),
+ unreact_data <- make_undo_data(user, reaction_activity, activity_id),
+ {:ok, activity} <- insert(unreact_data, local),
+ {:ok, object} <- remove_emoji_reaction_from_object(reaction_activity, object),
+ :ok <- maybe_federate(activity) do
+ {:ok, activity, object}
+ end
+ end
+
# TODO: This is weird, maybe we shouldn't check here if we can make the activity.
def like(
%User{ap_id: ap_id} = user,
|> maybe_update_cc(list_memberships, opts["user"])
end
+ @doc """
+ Fetch favorites activities of user with order by sort adds to favorites
+ """
+ @spec fetch_favourites(list(String.t()), User.t(), map(), atom()) :: list(Activity.t())
+ def fetch_favourites(recipients, user, params \\ %{}, pagination \\ :keyset) do
+ opts =
+ %{
+ "type" => "Create",
+ "favorited_by" => user.ap_id,
+ "blocking_user" => user
+ }
+ |> Map.merge(params)
+
+ recipients
+ |> fetch_activities_query(opts)
+ |> order_by_favourites(user)
+ |> Pagination.fetch_paginated(opts, pagination)
+ end
+
+ # sorts by adds to favorites
+ #
+ @spec order_by_favourites(Ecto.Query.t(), User.t()) :: Ecto.Query.t()
+ defp order_by_favourites(query, user) do
+ join(query, :inner, [activity, object], a1 in Activity,
+ on:
+ fragment(
+ "(?->>'id') = COALESCE(?->'object'->>'id', ?->>'object') AND (?->>'type' = 'Like') AND (?.actor = ?)",
+ object.data,
+ a1.data,
+ a1.data,
+ a1.data,
+ a1,
+ ^user.ap_id
+ ),
+ as: :like_activity
+ )
+ |> order_by([_, _, like_activity], desc: like_activity.updated_at)
+ end
+
defp maybe_update_cc(activities, list_memberships, %User{ap_id: user_ap_id})
when is_list(list_memberships) and length(list_memberships) > 0 do
Enum.map(activities, fn