X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fobject.ex;h=558e151b093bac8a48f972cf2c81e2e9fa3404a3;hb=1f32ba052c52ad974d17d8b65fb2c66b61eceffe;hp=30ba7b57a88f615557ea38884a9f40835e223784;hpb=30e9b22f96f2bf1cd895e993190f40afba159bb6;p=akkoma diff --git a/lib/pleroma/object.ex b/lib/pleroma/object.ex index 30ba7b57a..558e151b0 100644 --- a/lib/pleroma/object.ex +++ b/lib/pleroma/object.ex @@ -4,14 +4,14 @@ 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 @@ -22,24 +22,30 @@ defmodule Pleroma.Object do 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