feat(containers): deployer state machine

The deployment of a release on a device is handled trough a state
machine, responsible for creating the cache resources and running the
ready actions once all the nested resources are available

Moving the delpoyment loginc into a `GenStateMachine`.
- States for deploying the resources named as `:deploy_{resource}`
- Uses pubsub to update the deployment status when a message with a
  relevant resource as topic is published.

Signed-off-by: Luca Zaninotto <luca.zaninotto@secomind.com>

backend/lib/edgehog/application.ex

@@ -57,6 +57,8 @@ defmodule Edgehog.Application do
       {Finch, name: EdgehogFinch},
       # Start the UpdateCampaigns supervisor
       Edgehog.UpdateCampaigns.Supervisor,
+      # Start the Deployer supervisor
+      Edgehog.Containers.Deployment.Supervisor,
       # Start the Tenant Reconciler Supervisor
       {Edgehog.Tenants.Reconciler.Supervisor, tenant_to_trigger_url_fun: tenant_to_trigger_url_fun},
       # Start the Endpoint (http/https)

backend/lib/edgehog/containers/containers.ex

@@ -109,10 +109,11 @@ defmodule Edgehog.Containers do
 
     resource Edgehog.Containers.Deployment do
       define :deploy, action: :deploy, args: [:release_id, :device_id]
-      define :send_deploy_request, action: :send_deploy_request, args: [:deployment]
+      # define :send_deploy_request, action: :send_deploy_request, args: [:deployment]
       define :fetch_deployment, action: :read, get_by: [:id]
+      define :fetch_deployment_by_identity, action: :read, get_by_identity: :release_instance
       define :delete_deployment, action: :destroy
-      define :deployment_update_resources_state, action: :update_resources_state
+      # define :deployment_update_resources_state, action: :update_resources_state
       define :deployments_with_release, action: :filter_by_release, args: [:release_id]
       define :run_ready_actions, action: :run_ready_actions
 
@@ -150,7 +151,9 @@ defmodule Edgehog.Containers do
         args: [:container_id]
     end
 
-    resource Edgehog.Containers.Network
+    resource Edgehog.Containers.Network do
+      define :fetch_network, action: :read, get_by: [:id]
+    end
 
     resource Edgehog.Containers.Network.Deployment do
       define :deploy_network, action: :deploy, args: [:network, :device]
@@ -161,7 +164,9 @@ defmodule Edgehog.Containers do
       define :mark_network_deployment_as_errored, action: :mark_as_errored, args: [:message]
     end
 
-    resource Edgehog.Containers.Volume
+    resource Edgehog.Containers.Volume do
+      define :fetch_volume, action: :read, get_by: [:id]
+    end
 
     resource Edgehog.Containers.Volume.Deployment do
       define :deploy_volume, action: :deploy, args: [:volume, :device]

backend/lib/edgehog/containers/deployment.ex

@@ -57,7 +57,7 @@ defmodule Edgehog.Containers.Deployment do
 
       change manage_relationship(:device_id, :device, type: :append)
 
-      change Changes.CreateDeploymentOnDevice
+      change Changes.StartDeployer
     end
 
     update :start do
@@ -92,15 +92,6 @@ defmodule Edgehog.Containers.Deployment do
       manual ManualActions.RunReadyActions
     end
 
-    action :send_deploy_request do
-      argument :deployment, :struct do
-        constraints instance_of: __MODULE__
-        allow_nil? false
-      end
-
-      run ManualActions.SendDeployRequest
-    end
-
     update :upgrade_release do
       argument :target, :uuid do
         allow_nil? false
@@ -149,16 +140,6 @@ defmodule Edgehog.Containers.Deployment do
       change set_attribute(:state, :deleting)
     end
 
-    update :update_resources_state do
-      change Changes.CheckImages
-      change Changes.CheckNetworks
-      change Changes.CheckVolumes
-      change Changes.CheckContainers
-      change Changes.CheckDeployment
-
-      require_atomic? false
-    end
-
     read :filter_by_release do
       argument :release_id, :uuid
 

backend/lib/edgehog/containers/deployment/changes/create_deployment_on_device.ex → backend/lib/edgehog/containers/deployment/changes/start_deployer.ex

@@ -18,16 +18,18 @@
 # SPDX-License-Identifier: Apache-2.0
 #
 
-defmodule Edgehog.Containers.Deployment.Changes.CreateDeploymentOnDevice do
+defmodule Edgehog.Containers.Deployment.Changes.StartDeployer do
   @moduledoc false
   use Ash.Resource.Change
 
-  alias Edgehog.Containers
+  alias Edgehog.Containers.Deployment.DeployerSupervisor
 
   @impl Ash.Resource.Change
   def change(changeset, _opts, _context) do
-    Ash.Changeset.after_action(changeset, fn _changeset, deployment ->
-      with :ok <- Containers.send_deploy_request(deployment, tenant: deployment.tenant_id) do
+    Ash.Changeset.after_transaction(changeset, fn _changeset, result ->
+      with {:ok, deployment} <- result do
+        _pid = DeployerSupervisor.start_deployer!(deployment)
+
         {:ok, deployment}
       end
     end)