X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fobject.ex;h=558e151b093bac8a48f972cf2c81e2e9fa3404a3;hb=1f32ba052c52ad974d17d8b65fb2c66b61eceffe;hp=a5a1d6a763a94302bb163fdf90de0b2802387fcb;hpb=ec546baee915ecd9843f3c84e5cb0dbdbdcad826;p=akkoma diff --git a/lib/pleroma/object.ex b/lib/pleroma/object.ex index a5a1d6a76..558e151b0 100644 --- a/lib/pleroma/object.ex +++ b/lib/pleroma/object.ex @@ -4,42 +4,48 @@ defmodule Pleroma.Object do import Ecto.{Query, Changeset} schema "objects" do - field :data, :map + field(:data, :map) timestamps() end def create(data) do Object.change(%Object{}, %{data: data}) - |> Repo.insert + |> Repo.insert() end def change(struct, params \\ %{}) do - changeset = struct + struct |> cast(params, [:data]) |> validate_required([:data]) |> unique_constraint(:ap_id, name: :objects_unique_apid_index) end def get_by_ap_id(nil), do: nil + def get_by_ap_id(ap_id) do - Repo.one(from object in Object, - where: fragment("(?)->>'id' = ?", object.data, ^ap_id)) + Repo.one(from(object in Object, where: fragment("(?)->>'id' = ?", object.data, ^ap_id))) end def get_cached_by_ap_id(ap_id) do - if Mix.env == :test do + if Mix.env() == :test do get_by_ap_id(ap_id) else key = "object:#{ap_id}" - Cachex.get!(:user_cache, key, fallback: fn(_) -> - object = get_by_ap_id(ap_id) - if object do - {:commit, object} - else - {:ignore, object} + + Cachex.get!( + :user_cache, + key, + fallback: fn _ -> + object = get_by_ap_id(ap_id) + + if object do + {:commit, object} + else + {:ignore, object} + end end - end) + ) end end