Add AccountClose process

Author: Marcelo Amancio de Lima Santos

lib/event/dispatcher.ex

@@ -315,6 +315,10 @@ defmodule Helix.Event.Dispatcher do
     BankHandler.Bank.Account,
     :account_create_processed
 
+  event BankEvent.AccountClose.Processed,
+    BankHandler.Bank.Account,
+    :account_close_processed
+
   event BankEvent.Bank.Account.Password.Revealed,
     EntityHandler.Database,
     :bank_password_revealed

lib/universe/bank/action/flow/bank_account.ex

@@ -13,6 +13,8 @@ defmodule Helix.Universe.Bank.Action.Flow.BankAccount do
   alias Helix.Universe.Bank.Model.BankToken
   alias Helix.Universe.Bank.Query.Bank, as: BankQuery
 
+  alias Helix.Universe.Bank.Process.Bank.Account.AccountCreate,
+    as: BankAccountCreateProcess
   alias Helix.Universe.Bank.Process.Bank.Account.RevealPassword,
     as: BankAccountRevealPasswordProcess
   alias Helix.Universe.Bank.Process.Bank.Account.ChangePassword,
@@ -55,9 +57,9 @@ defmodule Helix.Universe.Bank.Action.Flow.BankAccount do
 
   @spec open(Server.t, Account.id, Server.t, relay) ::
   {:ok, Process.t}
-  | BankAccountAccountChangeProcess.executable_error
+  | BankAccountChangeProcess.executable_error
   @doc """
-  Opens a new BankAccount to given Account.id
+  Starts the `bank_account_create` process.
   """
   def open(gateway, account_id, atm, relay) do
     entity_id = Entity.ID.cast!(to_string(account_id.id))
@@ -67,23 +69,22 @@ defmodule Helix.Universe.Bank.Action.Flow.BankAccount do
       source_entity_id: entity_id
     }
 
-    BankAccountAccountCreateProcess.execute(gateway, atm, %{}, meta, relay)
+    BankAccountCreateProcess.execute(gateway, atm, %{}, meta, relay)
   end
 
   @spec close(BankAccount.t) ::
-  :ok
-  | {:error, {:bank_account, :not_found}}
-  | {:error, {:bank_account, :not_empty}}
-  def close(bank_account) do
-    flowing do
-      with \
-        true <- not is_nil(bank_account),
-        {:ok, events} <- BankAction.close_account(bank_account),
-        on_success(fn -> Event.emit(events) end)
-      do
-        :ok
-      end
-    end
+  {:ok, Process.t}
+  | BankAccountCloseProcess.executable_error
+  @doc """
+  Starts the `bank_account_close` process.
+  """
+  def close(gateway, bank_account, atm, relay) do
+    meta = %{
+      src_atm_id: bank_account.server_id,
+      src_account_number: bank_account.account_number
+    }
+
+    BankAccountCloseProcess.execute(gateway, atm, %{}, meta, relay)
   end
 
   @spec change_password(BankAccount.t, Server.t, Server.t, relay) ::

lib/universe/bank/event/account_close.ex

@@ -0,0 +1,36 @@
+defmodule Helix.Universe.Bank.Event.AccountClose do
+
+  import Helix.Event
+
+  event Processed do
+
+    alias Helix.Process.Model.Process
+    alias Helix.Universe.Bank.Model.ATM
+    alias Helix.Universe.Bank.Model.BankAccount
+    alias Helix.Universe.Bank.Process.Bank.Account.AccountClose,
+      as: AccountCloseProcess
+
+    @type t :: %__MODULE__{
+      atm_id: ATM.id,
+      account_number: BankAccount.account
+    }
+
+    event_struct [:atm_id, :account_number]
+
+    @spec new(ATM.id, BankAccount.account) :: t
+
+    def new(atm_id, account_number) do
+      %__MODULE__{
+        atm_id: atm_id,
+        account_number: account_number
+      }
+    end
+
+    @spec new(Process.t, AccountCloseProcess.t) :: t
+    def new(process = %Process{}, data = %AccountCloseProcess{}) do
+      %__MODULE__{
+        atm_id: process.src_atm_id,
+        account_number: process.src_acc_number
+      }
+    end
+  end

lib/universe/bank/event/handler/bank/account.ex

@@ -32,6 +32,19 @@ defmodule Helix.Universe.Bank.Event.Handler.Bank.Account do
     end
   end
 
+ def account_close_processed(event = %AccountCloseProcessedEvent{}) do
+    flowing
+      with \
+        bank_account = BankQuery.fetch_account(event.atm_id, event.account_number)
+        true <- not is_nil(bank_account),
+        {:ok, events} <- BankAction.close_account(bank_account),
+        on_success(fn -> Event.emit(events) end)
+      do
+        :ok
+      end
+    end
+  end
+
   @doc """
   Handles the conclusion of a `PasswordRevealProcess`, described at
   `BankAccountFlow`. Note that actually *displaying* the password to the user

lib/universe/bank/process/bank/account/close_account.ex

@@ -0,0 +1,82 @@
+import Helix.Process
+
+process Helix.Universe.Bank.Process.Bank.Account.AccountClose do
+
+  alias Helix.Universe.Bank.Model.ATM
+  alias Helix.Universe.Bank.Model.BankAccount
+
+  process_struct [:account]
+
+  @process_type :bank_close_account
+
+  @type t :: %__MODULE__{}
+
+  @type creation_params :: %{}
+
+  @type objective :: %{cpu: resource_usage}
+
+  @type resource :: %{
+    objective: objective,
+    static: map,
+    l_dynamic: [:cpu],
+    r_dynamic: []
+  }
+
+  @type resources_params :: %{}
+
+  @spec new(creation_params) :: t
+  def new(%{}) do
+    %__MODULE__{}
+  end
+
+  @spec resources(resources_params) :: resources
+  def resources(params = %{})
+    do: get_resources params
+
+  processable do
+
+    alias Helix.Universe.Bank.Event.AccountClose.Processed,
+      as: AccountCloseProcessedEvent
+
+    on_completion(process, data) do
+      event = AccountCloseProcessedEvent.new(process, data)
+
+      {:delete, [event]}
+    end
+
+    resourceable do
+      alias Heli.Universe.Bank.Process.Bank.Account.AccountClose,
+        as: AccountCloseProcess
+
+      @type params :: AccountCloseProcess.resources_params
+      @type factors :: term
+
+      # TODO proper balance
+      get_factors(%{}) do end
+
+      cpu(_) do
+
+      end
+
+      dynamic do
+        [:cpu]
+      end
+    end
+
+    executable do
+
+      alias Helix.Universe.Bank.Process.Bank.Account.AccountClose,
+        as: AccountCloseProcess
+
+      @type params :: AccountCloseProcess.creation_params
+
+      @type meta ::
+        %{
+          optional(atom) => term
+        }
+
+      resources(_, _, %{}, _) do
+        %{}
+      end
+    end
+  end

lib/universe/bank/websocket/channel/requests/close_account.ex

@@ -7,6 +7,7 @@ request Helix.Universe.Bank.Websocket.Requests.CloseAccount do
 
   It Returs :ok or :error
   """
+  alias Helix.Server.Query.Server, as: ServerQuery
   alias Helix.Universe.Bank.Henforcer.Bank, as: BankHenforcer
   alias Helix.Universe.Bank.Public.Bank, as: BankPublic
   alias Helix.Universe.Bank.Query.Bank, as: BankQuery
@@ -36,11 +37,13 @@ request Helix.Universe.Bank.Websocket.Requests.CloseAccount do
     atm_id = socket.assigns.atm_id
     account_number = socket.assigns.account_number
     bank_account = BankQuery.fetch_account(atm_id, account_number)
-    close_account = BankPublic.close_account(bank_account)
+    atm = ServerQuery.fetch(atm_id)
+    relay = request.relay
+    process = BankPublic.close_account(gateway, bank_account, atm, relay)
 
-    case close_account do
-      :ok ->
-        reply_ok(request)
+    case process do
+      {:ok, process} ->
+        update_meta(request, %{process: process}, reply: true)
       {:error, reason} ->
         reply_error(request, reason)
     end