Add process

Author: Marcelo Amancio de Lima Santos

lib/event/dispatcher.ex

@@ -278,6 +278,7 @@ defmodule Helix.Event.Dispatcher do
   event BankEvent.Bank.Account.Token.Acquired
   event BankEvent.Bank.Transfer.Processed
   event BankEvent.Bank.Transfer.Aborted
+  event BankEvent.AccountCreate.Processed
   event BankEvent.RevealPassword.Processed
   event BankEvent.ChangePassword.Processed
 
@@ -310,6 +311,10 @@ defmodule Helix.Event.Dispatcher do
     BankHandler.Bank.Account,
     :password_change_processed
 
+  event BankEvent.AccountCreate.Processed,
+    BankHandler.Bank.Account,
+    :account_create_processed
+
   event BankEvent.Bank.Account.Password.Revealed,
     EntityHandler.Database,
     :bank_password_revealed
@@ -322,4 +327,5 @@ defmodule Helix.Event.Dispatcher do
     EntityHandler.Database,
     :bank_account_login
 
+
 end

lib/process/model/process.ex

@@ -79,6 +79,7 @@ defmodule Helix.Process.Model.Process do
     | :install_virus
     | :bank_change_password
     | :bank_reveal_password
+    | :bank_account_create
 
   @typedoc """
   List of signals a process may receive during its lifetime.

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

@@ -53,24 +53,21 @@ defmodule Helix.Universe.Bank.Action.Flow.BankAccount do
     BankAccountRevealPasswordProcess.execute(gateway, atm, params, meta, relay)
   end
 
-  @spec open(Account.id, ATM.id) ::
-  {:ok, BankAccount.t}
-  | {:error, :internal}
+  @spec open(Server.t, Account.id, Server.t, relay) ::
+  {:ok, Process.t}
+  | BankAccountAccountChangeProcess.executable_error
   @doc """
   Opens a new BankAccount to given Account.id
   """
-  def open(account_id, atm_id) do
-    flowing do
-      with \
-        {:ok, bank_acc, events} <- BankAction.open_account(account_id, atm_id),
-        on_success(fn -> Event.emit(events) end)
-      do
-        {:ok, bank_acc}
-      else
-        _ ->
-          {:error, :internal}
-      end
-    end
+  def open(gateway, account_id, atm, relay) do
+    entity_id = Entity.ID.cast!(to_string(account_id.id))
+
+    meta = %{
+      src_atm_id: atm.server_id,
+      source_entity_id: entity_id
+    }
+
+    BankAccountAccountCreateProcess.execute(gateway, atm, %{}, meta, relay)
   end
 
   @spec close(BankAccount.t) ::

lib/universe/bank/event/account_open.ex

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

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

@@ -11,13 +11,27 @@ defmodule Helix.Universe.Bank.Event.Handler.Bank.Account do
     as: BankAccountRemovedEvent
   alias Helix.Universe.Bank.Event.Bank.Account.Updated,
     as: BankAccountUpdatedEvent
+  alias Helix.Universe.Bank.Event.AccountCreate.Processed,
+    as: AccountCreateProcessedEvent
   alias Helix.Universe.Bank.Event.RevealPassword.Processed,
     as: RevealPasswordProcessedEvent
   alias Helix.Universe.Bank.Event.ChangePassword.Processed,
     as: ChangePasswordProcessedEvent
   alias Helix.Universe.Bank.Event.Bank.Account.Password.Changed,
     as: BankPasswordChangedEvent
 
+  def account_create_processed(event = %AccountCreateProcessedEvent{}) do
+    flowing do
+      with \
+        {:ok, _bank_account, events} <-
+          BankAction.open_account(event.requester, event.atm),
+        on_success(fn -> Event.emit(events, from: event) 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/create_account.ex

@@ -0,0 +1,84 @@
+import Helix.Process
+
+process Helix.Universe.Bank.Process.Bank.Account.AccountCreate do
+
+  alias Helix.Universe.Bank.Model.ATM
+  alias Helix.Universe.Bank.Model.BankAccount
+
+  process_struct [:atm_id]
+
+  @process_type :bank_create_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(resource_params) :: resources
+  def resources(params = %{}),
+    do: get_resources params
+
+  processable do
+
+    alias Helix.Universe.Bank.Event.Bank.Account.AccountCreate.Processed,
+      as: AccountCreateProcess
+
+    on_completion(process, data) do
+      event = AccountCreateProcess.new(process, data)
+
+      {:delete, [event]}
+    end
+  end
+
+  resourceable do
+
+    alias Helix.Universe.Bank.Process.Bank.Account.AccountCreate,
+      as: AccountCreateProcess
+
+    @type params :: AccountCreateProcess.resources_params
+    @type factors :: term
+
+    # TODO proper balance
+    get_factors(%{}) do end
+
+    cpu(_) do
+      1
+    end
+
+    dynamic do
+      [:cpu]
+    end
+
+    executable do
+
+      alias Helix.Universe.Bank.Process.Bank.Account.AccountCreate,
+        as: AccountCreateProcess
+
+      @type params :: AccountCreateProcess.creation_params
+
+      @type meta ::
+        ${
+          optional(atom) => term
+        }
+
+      resources(_, _, %{}) do
+        %{}
+      end
+    end
+  end
+end

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

@@ -55,11 +55,13 @@ request Helix.Universe.Bank.Websocket.Requests.CreateAccount do
   def handle_request(request, socket) do
     atm_id = request.meta.atm_id
     account_id = socket.assigns.account_id
+    gateway = ServerQuery.fetch(socket.assigns.gateway.server_id)
+    relay = request.relay
 
-    bank_account = BankPublic.open_account(account_id, atm_id)
-    case bank_account do
-      {:ok, bank_account} ->
-        update_meta(request, %{bank_account: bank_account}, reply: true)
+    process = BankPublic.open_account(gateway, account_id, atm, relay)
+    case process do
+      {:ok, process} ->
+        update_meta(request, %{process: process}, reply: true)
       {:error, reason} ->
         reply_error(request, reason)
     end