Project and brodcast ApplicationInstanceMoved

trento-project · Jun 26, 2023 · 2f3bbc8 · 2f3bbc8
1 parent 10983a5
commit 2f3bbc8
Show file tree

Hide file tree

Showing 3 changed files with 154 additions and 55 deletions.
diff --git a/lib/trento/application/projectors/sap_system_projector.ex b/lib/trento/application/projectors/sap_system_projector.ex
@@ -11,6 +11,7 @@ defmodule Trento.SapSystemProjector do
   alias Trento.Domain.Events.{
     ApplicationInstanceDeregistered,
     ApplicationInstanceHealthChanged,
+    ApplicationInstanceMoved,
     ApplicationInstanceRegistered,
     SapSystemDeregistered,
     SapSystemHealthChanged,
@@ -96,6 +97,26 @@ defmodule Trento.SapSystemProjector do
     end
   )
 
+  project(
+    %ApplicationInstanceMoved{
+      sap_system_id: sap_system_id,
+      instance_number: instance_number,
+      old_host_id: old_host_id,
+      new_host_id: new_host_id
+    },
+    fn multi ->
+      instance =
+        Repo.get_by(ApplicationInstanceReadModel,
+          sap_system_id: sap_system_id,
+          instance_number: instance_number,
+          host_id: old_host_id
+        )
+
+      changeset = ApplicationInstanceReadModel.changeset(instance, %{host_id: new_host_id})
+      Ecto.Multi.update(multi, :application_instance, changeset)
+    end
+  )
+
   project(
     %ApplicationInstanceHealthChanged{
       sap_system_id: sap_system_id,
@@ -213,6 +234,31 @@ defmodule Trento.SapSystemProjector do
     )
   end
 
+  @impl true
+  def after_update(
+        %ApplicationInstanceMoved{
+          sap_system_id: sap_system_id,
+          instance_number: instance_number,
+          old_host_id: old_host_id,
+          new_host_id: new_host_id
+        },
+        _,
+        _
+      ) do
+    TrentoWeb.Endpoint.broadcast(
+      @sap_systems_topic,
+      "application_instance_moved",
+      SapSystemView.render("application_instance_moved.json",
+        instance_moved: %{
+          sap_system_id: sap_system_id,
+          instance_number: instance_number,
+          old_host_id: old_host_id,
+          new_host_id: new_host_id
+        }
+      )
+    )
+  end
+
   @impl true
   def after_update(
         %ApplicationInstanceHealthChanged{},

diff --git a/lib/trento_web/views/v1/sap_system_view.ex b/lib/trento_web/views/v1/sap_system_view.ex
@@ -79,6 +79,9 @@ defmodule TrentoWeb.V1.SapSystemView do
     |> Map.delete(:host)
   end
 
+  def render("application_instance_moved.json", %{instance_moved: instance_moved}),
+    do: instance_moved
+
   def render("application_instance_health_changed.json", %{health: health}), do: health
 
   def render("sap_systems.json", %{sap_systems: sap_systems}) do

diff --git a/test/trento/application/projectors/sap_system_projector_test.exs b/test/trento/application/projectors/sap_system_projector_test.exs
@@ -18,6 +18,7 @@ defmodule Trento.SapSystemProjectorTest do
   alias Trento.Domain.Events.{
     ApplicationInstanceDeregistered,
     ApplicationInstanceHealthChanged,
+    ApplicationInstanceMoved,
     SapSystemDeregistered,
     SapSystemHealthChanged,
     SapSystemUpdated
@@ -59,16 +60,18 @@ defmodule Trento.SapSystemProjectorTest do
     assert event.health == projection.health
     assert event.ensa_version == projection.ensa_version
 
-    assert_broadcast "sap_system_registered",
-                     %{
-                       db_host: ^db_host,
-                       health: ^health,
-                       id: ^id,
-                       sid: ^sid,
-                       tenant: ^tenant,
-                       ensa_version: ^ensa_version
-                     },
-                     1000
+    assert_broadcast(
+      "sap_system_registered",
+      %{
+        db_host: ^db_host,
+        health: ^health,
+        id: ^id,
+        sid: ^sid,
+        tenant: ^tenant,
+        ensa_version: ^ensa_version
+      },
+      1000
+    )
   end
 
   test "should update the health of a SAP System when a SapSystemHealthChanged event is received" do
@@ -80,12 +83,14 @@ defmodule Trento.SapSystemProjectorTest do
 
     assert event.health == projection.health
 
-    assert_broadcast "sap_system_health_changed",
-                     %{
-                       id: ^sap_system_id,
-                       health: ^health
-                     },
-                     1000
+    assert_broadcast(
+      "sap_system_health_changed",
+      %{
+        id: ^sap_system_id,
+        health: ^health
+      },
+      1000
+    )
   end
 
   test "should project a new application instance when ApplicationInstanceRegistered event is received" do
@@ -116,20 +121,57 @@ defmodule Trento.SapSystemProjectorTest do
     assert event.host_id == projection.host_id
     assert event.health == projection.health
 
-    assert_broadcast "application_instance_registered",
-                     %{
-                       features: ^features,
-                       health: ^health,
-                       host_id: ^host_id,
-                       http_port: 8080,
-                       https_port: 8443,
-                       instance_hostname: ^instance_hostname,
-                       instance_number: ^instance_number,
-                       sap_system_id: ^sap_system_id,
-                       sid: ^sid,
-                       start_priority: ^start_priority
-                     },
-                     1000
+    assert_broadcast(
+      "application_instance_registered",
+      %{
+        features: ^features,
+        health: ^health,
+        host_id: ^host_id,
+        http_port: 8080,
+        https_port: 8443,
+        instance_hostname: ^instance_hostname,
+        instance_number: ^instance_number,
+        sap_system_id: ^sap_system_id,
+        sid: ^sid,
+        start_priority: ^start_priority
+      },
+      1000
+    )
+  end
+
+  test "should move the application instance when an ApplicationInstanceMoved is received" do
+    insert(:sap_system, id: sap_system_id = Faker.UUID.v4())
+
+    %{host_id: old_host_id, instance_number: instance_number} =
+      insert(:application_instance, sap_system_id: sap_system_id)
+
+    event = %ApplicationInstanceMoved{
+      sap_system_id: sap_system_id,
+      instance_number: instance_number,
+      old_host_id: old_host_id,
+      new_host_id: new_host_id = Faker.UUID.v4()
+    }
+
+    ProjectorTestHelper.project(SapSystemProjector, event, "sap_system_projector")
+
+    application_instance =
+      Repo.get_by!(ApplicationInstanceReadModel,
+        sap_system_id: event.sap_system_id,
+        instance_number: event.instance_number
+      )
+
+    assert application_instance.host_id == event.new_host_id
+
+    assert_broadcast(
+      "application_instance_moved",
+      %{
+        sap_system_id: ^sap_system_id,
+        instance_number: ^instance_number,
+        old_host_id: ^old_host_id,
+        new_host_id: ^new_host_id
+      },
+      1000
+    )
   end
 
   test "should broadcast application_instance_health_changed when ApplicationInstanceHealthChanged event is received" do
@@ -157,14 +199,16 @@ defmodule Trento.SapSystemProjectorTest do
 
     ProjectorTestHelper.project(SapSystemProjector, health_event, "sap_system_projector")
 
-    assert_broadcast "application_instance_health_changed",
-                     %{
-                       health: :critical,
-                       host_id: ^host_id,
-                       instance_number: ^instance_number,
-                       sap_system_id: ^sap_system_id
-                     },
-                     1000
+    assert_broadcast(
+      "application_instance_health_changed",
+      %{
+        health: :critical,
+        host_id: ^host_id,
+        instance_number: ^instance_number,
+        sap_system_id: ^sap_system_id
+      },
+      1000
+    )
   end
 
   test "should update read model after deregistration" do
@@ -181,9 +225,11 @@ defmodule Trento.SapSystemProjectorTest do
 
     projection = Repo.get(SapSystemReadModel, sap_system_id)
 
-    assert_broadcast "sap_system_deregistered",
-                     %{id: ^sap_system_id, sid: ^sid},
-                     1000
+    assert_broadcast(
+      "sap_system_deregistered",
+      %{id: ^sap_system_id, sid: ^sid},
+      1000
+    )
 
     assert deregistered_at == projection.deregistered_at
   end
@@ -219,14 +265,16 @@ defmodule Trento.SapSystemProjectorTest do
              |> Repo.all()
              |> Enum.count()
 
-    assert_broadcast "application_instance_deregistered",
-                     %{
-                       sap_system_id: ^sap_system_id,
-                       instance_number: ^instance_number,
-                       host_id: ^host_id,
-                       sid: ^sid
-                     },
-                     1000
+    assert_broadcast(
+      "application_instance_deregistered",
+      %{
+        sap_system_id: ^sap_system_id,
+        instance_number: ^instance_number,
+        host_id: ^host_id,
+        sid: ^sid
+      },
+      1000
+    )
   end
 
   test "should update an already existing SAP System when a SapSystemUpdated event is received" do
@@ -246,11 +294,13 @@ defmodule Trento.SapSystemProjectorTest do
 
     assert event.ensa_version == ensa_version
 
-    assert_broadcast "sap_system_updated",
-                     %{
-                       id: ^id,
-                       ensa_version: ^ensa_version
-                     },
-                     1000
+    assert_broadcast(
+      "sap_system_updated",
+      %{
+        id: ^id,
+        ensa_version: ^ensa_version
+      },
+      1000
+    )
   end
 end