Packages
arke
0.1.2
1.1.33
retired
0.6.3
0.6.2
0.6.1
0.6.0
0.5.0
0.4.5
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.4.0-bulk.1
0.4.0-bulk.0
0.3.17
0.3.16
0.3.15
0.3.14
0.3.13
0.3.12
0.3.11
0.3.10
0.3.9
0.3.8
0.3.7
0.3.6
0.3.5
0.3.4
0.3.3
0.3.2
0.3.1
0.3.0
0.1.38
0.1.37
0.1.36
0.1.35
0.1.34
0.1.33
0.1.32
0.1.31
0.1.30
0.1.29
0.1.28
0.1.27
0.1.26
0.1.25
0.1.24
0.1.23
0.1.22
0.1.21
0.1.20
0.1.19
0.1.18
0.1.17
0.1.16
0.1.15
0.1.14
0.1.13
0.1.12
0.1.11
0.1.10
0.1.9
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
Arke low code framework Core
Current section
Files
Jump to
Current section
Files
lib/arke/link_manager.ex
defmodule Arke.LinkManager do
@moduledoc false
@record_fields [:id, :data, :configuration, :inserted_at, :updated_at]
import Ecto.Query
alias Arke.Boundary.ArkeManager
alias Arke.QueryManager
def add_node(project, parent, child, type \\ "link", metadata \\ %{}) do
arke_link = ArkeManager.get(:arke_link, :arke_system)
parent_id = get_node_id(parent)
child_id = get_node_id(child)
QueryManager.create(project, arke_link,
parent_id: parent_id,
child_id: child_id,
type: type,
metadata: metadata
)
end
def delete_node(project, parent, child, type, metadata \\ %{}) do
arke_link = ArkeManager.get(:arke_link, :arke_system)
parent_id = get_node_id(parent)
child_id = get_node_id(child)
# TODO: handle custom exception
with %Arke.Core.Unit{} = link <-
Arke.QueryManager.query(project: project, arke: arke_link)
|> Arke.QueryManager.filter(:parent_id, :eq, parent, false)
|> Arke.QueryManager.filter(:child_id, :eq, child, false)
|> Arke.QueryManager.filter(:type, :eq, type, false)
|> Arke.QueryManager.filter(:configuration, :eq, metadata, false)
|> Arke.QueryManager.one() do
Arke.QueryManager.delete(project, link)
{:ok, nil}
else
_ -> raise "link not found"
end
end
# TODO: unit id to_string()
defp get_node_id(id) when is_binary(id), do: id
defp get_node_id(id) when is_atom(id), do: Atom.to_string(id)
defp get_node_id(%{id: id} = _unit), do: id
end