defmodule Pleroma.Activity do use Ecto.Schema alias Pleroma.{Repo, Activity, Notification, Object} import Ecto.{Query, Changeset} 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 def change(struct, params \\ %{}) do struct |> cast(params, [:data]) |> validate_required([:data]) |> unique_constraint(:ap_id, name: :activities_unique_apid_index) 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: normalize(obj["id"]) def normalize(ap_id) when is_binary(ap_id), do: get_by_ap_id(ap_id) def normalize(_), do: nil defp get_in_reply_to_activity_from_object(%Object{data: %{"inReplyTo" => ap_id}}) do get_create_activity_by_object_ap_id(ap_id) end defp get_in_reply_to_activity_from_object(_), do: nil def get_in_reply_to_activity(%Activity{data: %{"object" => object}}) do get_in_reply_to_activity_from_object(Object.normalize(object)) end end