Current section

Files

Jump to
commanded test event event_handler_error_handling_test.exs
Raw

test/event/event_handler_error_handling_test.exs

defmodule Commanded.Event.EventHandlerErrorHandlingTest do
use Commanded.StorageCase
defmodule ErrorEventHandler do
use Commanded.Event.Handler, name: "ErrorEventHandler"
alias Commanded.ExampleDomain.BankAccount.Events.BankAccountOpened
def handle(%BankAccountOpened{}, _metadata), do: {:error, :failed}
end
alias Commanded.ExampleDomain.BankAccount.Commands.OpenAccount
alias Commanded.ExampleDomain.BankAccount.Events.BankAccountOpened
alias Commanded.ExampleDomain.BankRouter
alias Commanded.Helpers.CommandAuditMiddleware
setup do
CommandAuditMiddleware.start_link()
:ok
end
test "should stop event handler on error" do
account_number = UUID.uuid4()
{:ok, handler} = ErrorEventHandler.start_link()
Process.unlink(handler)
ref = Process.monitor(handler)
:ok = BankRouter.dispatch(%OpenAccount{account_number: account_number, initial_balance: 1_000})
assert_receive {:DOWN, ^ref, _, _, _}
refute Process.alive?(handler)
end
end