zf

zenflows testing
git clone https://s.sonu.ch/~srfsh/zf.git
Log | Files | Refs | Submodules | README | LICENSE

domain.ex (1945B)

      1 # Zenflows is designed to implement the Valueflows vocabulary,
      2 # written and maintained by srfsh <info@dyne.org>.
      3 # Copyright (C) 2021-2023 Dyne.org foundation <foundation@dyne.org>.
      4 #
      5 # This program is free software: you can redistribute it and/or modify
      6 # it under the terms of the GNU Affero General Public License as published by
      7 # the Free Software Foundation, either version 3 of the License, or
      8 # (at your option) any later version.
      9 #
     10 # This program is distributed in the hope that it will be useful,
     11 # but WITHOUT ANY WARRANTY; without even the implied warranty of
     12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     13 # GNU Affero General Public License for more details.
     14 #
     15 # You should have received a copy of the GNU Affero General Public License
     16 # along with this program.  If not, see <https://www.gnu.org/licenses/>.
     17 
     18 defmodule Zenflows.VF.Agent.Domain do
     19 @moduledoc "Domain logic of Agents."
     20 
     21 alias Ecto.Changeset
     22 alias Zenflows.DB.{Page, Repo, Schema}
     23 alias Zenflows.VF.{Agent, Agent.Query}
     24 
     25 @spec one(Ecto.Repo.t(), Schema.id() | map() | Keyword.t())
     26 	:: {:ok, Agent.t()} | {:error, String.t()}
     27 def one(repo \\ Repo, _)
     28 def one(repo, id) when is_binary(id), do: one(repo, id: id)
     29 def one(repo, clauses) do
     30 	case repo.get_by(Agent, clauses) do
     31 		nil -> {:error, "not found"}
     32 		found -> {:ok, found}
     33 	end
     34 end
     35 
     36 @spec one!(Ecto.Repo.t(), Schema.id() | map() | Keyword.t()) :: Agent.t()
     37 def one!(repo \\ Repo, id_or_clauses) do
     38 	{:ok, value} = one(repo, id_or_clauses)
     39 	value
     40 end
     41 
     42 @spec all(Page.t()) :: {:ok, [Agent.t()]} | {:error, Changeset.t()}
     43 def all(page \\ Page.new()) do
     44 	with {:ok, q} <- Query.all(page) do
     45 		{:ok, Page.all(q, page)}
     46 	end
     47 end
     48 
     49 @spec all!(Page.t()) :: [Agent.t()]
     50 def all!(page \\ Page.new()) do
     51 	{:ok, value} = all(page)
     52 	value
     53 end
     54 
     55 @spec preload(Agent.t(), :images | :primary_location) :: Agent.t()
     56 def preload(agent, x) when x in ~w[images primary_location]a do
     57 	Repo.preload(agent, x)
     58 end
     59 end