Domain command

create_proposal_command.ex

defmodule CustomerManagement.Origination.Commands.CreateProposalCommand do
  use Ecto.Schema
  import Ecto.Changeset

  alias MyApp.Repo
  alias Ecto.Multi

  alias CustomerManagement.Origination.Proposal
  alias CustomerManagement.Origination.Events.ProposalCreatedEvent
  
  @primary_key false
  embedded_schema do
    has_one :proposal, Proposal
    field :realty_type, :string
    field :realty_value, Money.Ecto.Amount.Type
  end

  def execute(%{} = attrs) do
    Multi.new
    |> Multi.insert(:proposal, user_changeset(attrs))
    |> Multi.insert(:user_registred_event, UserRegistredEvent.new(attrs))
  end
  
  def user_changeset(%{} = attrs) do
    %User{}
    |> cast(attrs, [:email, :password])
    |> validate_required([:email, :password])
  end
end

register_user_command.ex

defmodule MyApp.Accounts.Commands.RegisterUserCommand do
  import Ecto.Changeset

  alias MyApp.Repo
  alias Ecto.Multi

  alias MyApp.Accounts.User
  alias MyApp.Accounts.Events.UserRegistredEvent

  def execute(%{} = attrs) do
    Multi.new
    |> Multi.insert(:user, user_changeset(attrs))
    |> Multi.insert(:user_registred_event, UserRegistredEvent.new(attrs))
  end
  
  def user_changeset(%{} = attrs) do
    %User{}
    |> cast(attrs, [:email, :password])
    |> validate_required([:email, :password])
  end
end