Add Host Check Selection Domain logic

Co-authored-by: Eugen Maksymenko <eugen.maksymenko@suse.com>

lib/trento/domain/host/commands/select_host_checks.ex

@@ -0,0 +1,14 @@
+defmodule Trento.Domain.Commands.SelectHostChecks do
+  @moduledoc """
+  Select the checks to be executed on a host.
+  """
+
+  @required_fields :all
+
+  use Trento.Command
+
+  defcommand do
+    field :host_id, Ecto.UUID
+    field :checks, {:array, :string}
+  end
+end

lib/trento/domain/host/events/host_checks_selected.ex

@@ -0,0 +1,12 @@
+defmodule Trento.Domain.Events.HostChecksSelected do
+  @moduledoc """
+  Event of the checks selected for a host.
+  """
+
+  use Trento.Event
+
+  defevent do
+    field :host_id, Ecto.UUID
+    field :checks, {:array, :string}
+  end
+end

lib/trento/domain/host/host.ex

@@ -31,6 +31,7 @@ defmodule Trento.Domain.Host do
   alias Trento.Domain.Commands.{
     RegisterHost,
     RollUpHost,
+    SelectHostChecks,
     UpdateHeartbeat,
     UpdateProvider,
     UpdateSlesSubscriptions
@@ -39,6 +40,7 @@ defmodule Trento.Domain.Host do
   alias Trento.Domain.Events.{
     HeartbeatFailed,
     HeartbeatSucceded,
+    HostChecksSelected,
     HostDetailsUpdated,
     HostRegistered,
     HostRolledUp,
@@ -66,6 +68,7 @@ defmodule Trento.Domain.Host do
     field :installation_source, Ecto.Enum, values: [:community, :suse, :unknown]
     field :heartbeat, Ecto.Enum, values: [:passing, :critical, :unknown]
     field :rolling_up, :boolean, default: false
+    field :selected_checks, {:array, :string}, default: []
 
     embeds_many :subscriptions, SlesSubscription
 
@@ -267,6 +270,20 @@ defmodule Trento.Domain.Host do
     }
   end
 
+  def execute(
+        %Host{
+          host_id: host_id
+        },
+        %SelectHostChecks{
+          checks: selected_checks
+        }
+      ) do
+    %HostChecksSelected{
+      host_id: host_id,
+      checks: selected_checks
+    }
+  end
+
   def apply(
         %Host{} = host,
         %HostRegistered{
@@ -373,4 +390,16 @@ defmodule Trento.Domain.Host do
       }) do
     snapshot
   end
+
+  def apply(
+        %Host{} = host,
+        %HostChecksSelected{
+          checks: selected_checks
+        }
+      ) do
+    %Host{
+      host
+      | selected_checks: selected_checks
+    }
+  end
 end

lib/trento/infrastructure/router.ex

@@ -19,6 +19,7 @@ defmodule Trento.Router do
     RollUpHost,
     RollUpSapSystem,
     SelectChecks,
+    SelectHostChecks,
     UpdateHeartbeat,
     UpdateProvider,
     UpdateSlesSubscriptions
@@ -33,7 +34,8 @@ defmodule Trento.Router do
              UpdateHeartbeat,
              UpdateProvider,
              UpdateSlesSubscriptions,
-             RollUpHost
+             RollUpHost,
+             SelectHostChecks
            ],
            to: Host,
            lifespan: Host.Lifespan