implement transtions and state machine for cluster

lib/polar/machines/cluster.ex

@@ -3,6 +3,13 @@ defmodule Polar.Machines.Cluster do
   import Ecto.Changeset
 
   alias __MODULE__.Credential
+  alias __MODULE__.Transitions
+  alias __MODULE__.Event
+
+  use Eventful.Transitable
+
+  Transitions
+  |> governs(:current_state, on: Event)
 
   @valid_attrs ~w(
     name

lib/polar/machines/cluster/event.ex

@@ -0,0 +1,12 @@
+defmodule Polar.Machines.Cluster.Event do
+  alias Polar.Machines.Cluster
+  alias Polar.Accounts.User
+
+  use Eventful,
+    parent: {:cluster, Cluster},
+    actor: {:user, User}
+
+  alias Cluster.Transitions
+
+  handle(:transitions, using: Transitions)
+end

lib/polar/machines/cluster/transit.ex

@@ -1,4 +1,6 @@
 defimpl Eventful.Transit, for: Polar.Machines.Cluster do
+  alias Polar.Machines.Cluster.Event
+
   def perform(cluster, user, event_name, options \\ []) do
     comment = Keyword.get(options, :comment)
     domain = Keyword.get(options, :domain, "transitions")

lib/polar/machines/cluster/triggers.ex

@@ -2,6 +2,7 @@ defmodule Polar.Machines.Cluster.Triggers do
   use Eventful.Trigger
 
   alias Polar.Machines.Cluster
+  alias Polar.Machines.Cluster.Connect
 
   Cluster
   |> trigger([currently: "connecting"], fn event, cluster ->

priv/repo/migrations/20240621115038_create_cluster_events.exs

@@ -0,0 +1,28 @@
+defmodule Polar.Repo.Migrations.CreateClusterEvents do
+  use Ecto.Migration
+
+  def change do
+    create table(:cluster_events) do
+      add(:name, :citext, null: false)
+      add(:domain, :citext, null: false)
+      add(:metadata, :map, default: "{}")
+
+      add(
+        :cluster_id,
+        references(:clusters, on_delete: :restrict),
+        null: false
+      )
+
+      add(
+        :user_id,
+        references(:users, on_delete: :restrict),
+        null: false
+      )
+
+      timestamps(type: :utc_datetime_usec)
+    end
+
+    create index(:cluster_events, [:cluster_id])
+    create index(:cluster_events, [:user_id])
+  end
+end