git.squeep.com Git - akkoma/blob - lib/pleroma/object.ex

   1 defmodule Pleroma.Object do
   2   use Ecto.Schema
   3   alias Pleroma.{Repo, Object}
   4   import Ecto.{Query, Changeset}
   5
   6   schema "objects" do
   7     field(:data, :map)
   8
   9     timestamps()
  10   end
  11
  12   def create(data) do
  13     Object.change(%Object{}, %{data: data})
  14     |> Repo.insert()
  15   end
  16
  17   def change(struct, params \\ %{}) do
  18     struct
  19     |> cast(params, [:data])
  20     |> validate_required([:data])
  21     |> unique_constraint(:ap_id, name: :objects_unique_apid_index)
  22   end
  23
  24   def get_by_ap_id(nil), do: nil
  25
  26   def get_by_ap_id(ap_id) do
  27     Repo.one(from(object in Object, where: fragment("(?)->>'id' = ?", object.data, ^ap_id)))
  28   end
  29
  30   def normalize(obj) when is_map(obj), do: Object.get_by_ap_id(obj["id"])
  31   def normalize(ap_id) when is_binary(ap_id), do: Object.get_by_ap_id(ap_id)
  32   def normalize(_), do: nil
  33
  34   def get_cached_by_ap_id(ap_id) do
  35     if Mix.env() == :test do
  36       get_by_ap_id(ap_id)
  37     else
  38       key = "object:#{ap_id}"
  39
  40       Cachex.fetch!(:user_cache, key, fn _ ->
  41         object = get_by_ap_id(ap_id)
  42
  43         if object do
  44           {:commit, object}
  45         else
  46           {:ignore, object}
  47         end
  48       end)
  49     end
  50   end
  51
  52   def context_mapping(context) do
  53     Object.change(%Object{}, %{data: %{"id" => context}})
  54   end
  55 end