feat: permission handler

.gitignore

@@ -11,3 +11,4 @@ erl_crash.dump
 *.iml
 # Ignore package tarball (built via "mix hex.build").
 *.tar
+.idea/

lib/arke_postgres.ex

@@ -13,6 +13,7 @@
 # limitations under the License.
 
 defmodule ArkePostgres do
+  alias Arke.Boundary.GroupManager
   alias ArkePostgres.{Table, ArkeUnit}
 
   def init() do
@@ -22,12 +23,13 @@ defmodule ArkePostgres do
         try do
           projects =
             Arke.QueryManager.query(arke: :arke_project, project: :arke_system)
-            |> Arke.QueryManager.filter(:id, :eq, :arke_system, true)
+            # |> Arke.QueryManager.filter(:id, :eq, :arke_system, true)
             |> Arke.QueryManager.filter(:arke_id, :eq, "arke_project")
             |> Arke.QueryManager.all()
 
           Enum.each(projects, fn %{id: project_id} = _project ->
             start_managers(project_id)
+            get_group_modules(project_id)
           end)
 
           :ok
@@ -42,6 +44,36 @@ defmodule ArkePostgres do
     end
   end
 
+  defp get_group_modules(project) do
+    Enum.reduce(:application.loaded_applications(), [], fn {app, _, _}, group_list ->
+      {:ok, modules} = :application.get_key(app, :modules)
+      module_group_list =
+        Enum.reduce(modules, [], fn mod, mod_group_list ->
+          is_group =
+            Code.ensure_loaded?(mod) and :erlang.function_exported(mod, :is_group?, 0) and
+              mod.group_from_attr != nil and mod.is_group? == true
+
+              mod_group_list = check_group_module(project, mod, mod_group_list, is_group)
+        end)
+
+      group_list ++ module_group_list
+    end)
+  end
+
+  defp check_group_module(project, mod, group_list, true) do
+    %{id: id} = mod.group_from_attr
+    # IO.inspect("Modifica gruppo Gruppo #{id} - #{project}")
+    group = GroupManager.get(id, project)
+    update_group_manager_and_list(group, group_list, mod)
+  end
+  defp update_group_manager_and_list(group, group_list, _) when is_nil(group), do: group_list
+  defp update_group_manager_and_list(group, group_list, mod) do
+    GroupManager.update(group, Arke.Core.Unit.update(group, __module__: mod))
+    [mod | group_list]
+  end
+
+  defp check_group_module(_, _, group_list, false), do: group_list
+
   def print_missing_env(keys) when is_list(keys) do
     for k <- keys do
       IO.puts("#{IO.ANSI.red()} error:#{IO.ANSI.reset()} env key #{k} not found.")
@@ -80,8 +112,7 @@ defmodule ArkePostgres do
 
       Arke.Boundary.ArkeManager.create(unit, project_id)
     end)
-
-    Enum.each(groups, fn unit -> Arke.Boundary.GroupManager.create(unit, project_id) end)
+    Enum.each(groups, fn unit -> Arke.Boundary.GroupManager.create(Arke.Core.Unit.update(unit, __module__: Arke.System.BaseGroup), project_id) end)
   end
 
   def create(project, %{arke_id: arke_id} = unit) do

lib/arke_postgres/query.ex

@@ -74,6 +74,7 @@ defmodule ArkePostgres.Query do
       "string",
       "unit",
       "link",
+      "dynamic",
       "date",
       "datetime",
       "time"
@@ -342,6 +343,9 @@ defmodule ArkePostgres.Query do
   defp get_arke_column(%{id: id, arke_id: :link} = _parameter),
     do: dynamic([q], fragment("(? -> ? ->> 'value')::text", field(q, :data), ^Atom.to_string(id)))
 
+    defp get_arke_column(%{id: id, arke_id: :dynamic} = _parameter),
+    do: dynamic([q], fragment("(? -> ? ->> 'value')::text", field(q, :data), ^Atom.to_string(id)))
+
   defp get_value(_parameter, value) when is_nil(value), do: value
   defp get_value(_parameter, value) when is_list(value), do: value
   defp get_value(_parameter, value) when is_map(value), do: value
@@ -415,6 +419,7 @@ defmodule ArkePostgres.Query do
   defp get_value(%{id: id, arke_id: :dict} = _parameter, value), do: value
   defp get_value(%{id: id, arke_id: :list} = _parameter, value), do: value
   defp get_value(%{id: id, arke_id: :link} = _parameter, value), do: value
+  defp get_value(%{id: id, arke_id: :dynamic} = _parameter, value), do: value
   defp get_value(%{id: id}, value), do: raise("Parameter(#{id}) value not valid")
 
   defp parse_number_list(parameter, value, func) do

mix.exs

@@ -1,7 +1,7 @@
 defmodule ArkePostgres.MixProject do
   use Mix.Project
 
-  @version "0.2.4"
+  @version "0.2.5"
   @scm_url "https://github.com/arkemishub/arke-postgres"
   @site_url "https://arkehub.com"