Upcast version of the changed events

trento-project · Sep 6, 2022 · ea9ddb9 · ea9ddb9
1 parent 085a403
commit ea9ddb9
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/lib/trento/domain/host/events/host_details_updated.ex b/lib/trento/domain/host/events/host_details_updated.ex
@@ -5,7 +5,7 @@ defmodule Trento.Domain.Events.HostDetailsUpdated do
 
   use Trento.Event
 
-  defevent do
+  defevent version: 2 do
     field :host_id, Ecto.UUID
     field :hostname, :string
     field :ip_addresses, {:array, :string}
@@ -20,4 +20,6 @@ defmodule Trento.Domain.Events.HostDetailsUpdated do
       values: [:community, :suse, :unknown],
       default: :unknown
   end
+
+  def upcast(params, _, 2), do: Map.put(params, "installation_source", :unknown)
 end
diff --git a/lib/trento/domain/host/events/host_registered.ex b/lib/trento/domain/host/events/host_registered.ex
@@ -5,7 +5,7 @@ defmodule Trento.Domain.Events.HostRegistered do
 
   use Trento.Event
 
-  defevent do
+  defevent version: 2 do
     field :host_id, Ecto.UUID
     field :hostname, :string
     field :ip_addresses, {:array, :string}
@@ -22,4 +22,6 @@ defmodule Trento.Domain.Events.HostRegistered do
 
     field :heartbeat, Ecto.Enum, values: [:unknown]
   end
+
+  def upcast(params, _, 2), do: Map.put(params, "installation_source", :unknown)
 end