defmodule Pleroma.Activity do use Ecto.Schema alias Pleroma.{Repo, Activity, Notification} import Ecto.{Query, Changeset} # https://github.com/tootsuite/mastodon/blob/master/app/models/notification.rb#L19 @mastodon_notification_types %{ "Create" => "mention", "Follow" => "follow", "Announce" => "reblog", "Like" => "favourite" } schema "activities" do field(:data, :map) field(:local, :boolean, default: true) field(:actor, :string) field(:recipients, {:array, :string}) has_many(:notifications, Notification, on_delete: :delete_all) timestamps() end def get_by_ap_id(ap_id) do Repo.one( from( activity in Activity, where: fragment("(?)->>'id' = ?", activity.data, ^to_string(ap_id)) ) ) end # TODO: # Go through these and fix them everywhere. # Wrong name, only returns create activities def all_by_object_ap_id_q(ap_id) do from( activity in Activity, where: fragment( "coalesce((?)->'object'->>'id', (?)->>'object') = ?", activity.data, activity.data, ^to_string(ap_id) ), where: fragment("(?)->>'type' = 'Create'", activity.data) ) end # Wrong name, returns all. def all_non_create_by_object_ap_id_q(ap_id) do from( activity in Activity, where: fragment( "coalesce((?)->'object'->>'id', (?)->>'object') = ?", activity.data, activity.data, ^to_string(ap_id) ) ) end # Wrong name plz fix thx def all_by_object_ap_id(ap_id) do Repo.all(all_by_object_ap_id_q(ap_id)) end def create_activity_by_object_id_query(ap_ids) do from( activity in Activity, where: fragment( "coalesce((?)->'object'->>'id', (?)->>'object') = ANY(?)", activity.data, activity.data, ^ap_ids ), where: fragment("(?)->>'type' = 'Create'", activity.data) ) end def get_create_activity_by_object_ap_id(ap_id) when is_binary(ap_id) do create_activity_by_object_id_query([ap_id]) |> Repo.one() end def get_create_activity_by_object_ap_id(_), do: nil def normalize(obj) when is_map(obj), do: Activity.get_by_ap_id(obj["id"]) def normalize(ap_id) when is_binary(ap_id), do: Activity.get_by_ap_id(ap_id) def normalize(_), do: nil def get_in_reply_to_activity(%Activity{data: %{"object" => %{"inReplyTo" => ap_id}}}) do get_create_activity_by_object_ap_id(ap_id) end def get_in_reply_to_activity(_), do: nil for {ap_type, type} <- @mastodon_notification_types do def mastodon_notification_type(%Activity{data: %{"type" => unquote(ap_type)}}), do: unquote(type) end def mastodon_notification_type(%Activity{}), do: nil def get_tombstone(%Activity{data: data}, deleted \\ DateTime.utc_now()) do %{ id: data["id"], context: data["context"], type: "tombstone", published: data["published"], deleted: deleted } end def swap_data_with_tombstone(activity) do tombstone = get_tombstone(activity) activity |> change(%{data: tombstone}) |> Repo.update() end end