aboutsummaryrefslogtreecommitdiff
path: root/lib/pleroma/repo.ex
diff options
context:
space:
mode:
authorMaksim <parallel588@gmail.com>2019-05-06 17:51:03 +0000
committerlambda <lain@soykaf.club>2019-05-06 17:51:03 +0000
commit1040caf096347b638b9fda5b23fcccde87b32ede (patch)
treedb56c5118b7e853f27d5bd0d0782ab72f532d821 /lib/pleroma/repo.ex
parentaacac9da0beddcf797958acca330747b8f2d1f06 (diff)
downloadpleroma-1040caf096347b638b9fda5b23fcccde87b32ede.tar.gz
fix format
Modified-by: Maksim Pechnikov <parallel588@gmail.com>
Diffstat (limited to 'lib/pleroma/repo.ex')
-rw-r--r--lib/pleroma/repo.ex28
1 files changed, 28 insertions, 0 deletions
diff --git a/lib/pleroma/repo.ex b/lib/pleroma/repo.ex
index aa5d427ae..f57e088bc 100644
--- a/lib/pleroma/repo.ex
+++ b/lib/pleroma/repo.ex
@@ -19,4 +19,32 @@ defmodule Pleroma.Repo do
def init(_, opts) do
{:ok, Keyword.put(opts, :url, System.get_env("DATABASE_URL"))}
end
+
+ @doc "find resource based on prepared query"
+ @spec find_resource(Ecto.Query.t()) :: {:ok, struct()} | {:error, :not_found}
+ def find_resource(%Ecto.Query{} = query) do
+ case __MODULE__.one(query) do
+ nil -> {:error, :not_found}
+ resource -> {:ok, resource}
+ end
+ end
+
+ def find_resource(_query), do: {:error, :not_found}
+
+ @doc """
+ Gets association from cache or loads if need
+
+ ## Examples
+
+ iex> Repo.get_assoc(token, :user)
+ %User{}
+
+ """
+ @spec get_assoc(struct(), atom()) :: {:ok, struct()} | {:error, :not_found}
+ def get_assoc(resource, association) do
+ case __MODULE__.preload(resource, association) do
+ %{^association => assoc} when not is_nil(assoc) -> {:ok, assoc}
+ _ -> {:error, :not_found}
+ end
+ end
end