Packages
commanded
0.15.1
1.4.10
1.4.9
1.4.8
1.4.7
1.4.6
1.4.3
1.4.2
1.4.1
1.4.0
1.4.0-rc.0
1.3.1
1.3.0
1.2.0
1.1.1
1.1.0
1.0.1
1.0.0
1.0.0-rc.1
1.0.0-rc.0
0.19.1
0.19.0
0.18.1
0.18.0
0.17.5
0.17.4
0.17.3
0.17.2
0.17.1
0.17.0
0.16.0
0.16.0-rc.1
0.16.0-rc.0
0.15.1
0.15.0
0.14.0
0.14.0-rc.0
0.13.0
0.12.0
0.11.0
0.10.0
0.9.0
0.8.5
0.8.4
0.8.3
0.8.1
0.8.0
0.7.1
0.6.2
0.6.1
0.6.0
0.4.0
0.3.1
0.3.0
0.2.1
0.2.0
0.1.0
Use Commanded to build your own Elixir applications following the CQRS/ES pattern.
Current section
Files
Jump to
Current section
Files
test/process_managers/process_manager_instance_test.exs
defmodule Commanded.ProcessManagers.ProcessManagerInstanceTest do
use Commanded.StorageCase
alias Commanded.ExampleDomain.MoneyTransfer.Events.MoneyTransferRequested
alias Commanded.ExampleDomain.TransferMoneyProcessManager
alias Commanded.EventStore.RecordedEvent
alias Commanded.ProcessManagers.{ProcessManagerInstance,NullRouter}
alias Commanded.Helpers.ProcessHelper
test "process manager handles an event" do
transfer_uuid = UUID.uuid4
account1_uuid = UUID.uuid4
account2_uuid = UUID.uuid4
{:ok, process_manager} = ProcessManagerInstance.start_link(NullRouter, "TransferMoneyProcessManager", TransferMoneyProcessManager, transfer_uuid)
event = %RecordedEvent{
event_number: 1,
stream_id: "stream-id",
stream_version: 1,
data: %MoneyTransferRequested{
transfer_uuid: transfer_uuid,
debit_account: account1_uuid,
credit_account: account2_uuid,
amount: 100,
},
}
:ok = ProcessManagerInstance.process_event(process_manager, event, self())
# should send ack to process router after processing event
assert_receive({:"$gen_cast", {:ack_event, ^event}}, 1_000)
ProcessHelper.shutdown(process_manager)
end
test "should ensure a process manager name is provided" do
assert_raise RuntimeError, "UnnamedProcessManager expects `:name` to be given", fn ->
Code.eval_string """
defmodule UnnamedProcessManager do
use Commanded.ProcessManagers.ProcessManager,
router: Commanded.ExampleDomain.BankRouter
end
"""
end
end
test "should ensure a process manager router is provided" do
assert_raise RuntimeError, "NoRouterProcessManager expects `:router` to be given", fn ->
Code.eval_string """
defmodule NoRouterProcessManager do
use Commanded.ProcessManagers.ProcessManager,
name: "MyProcessManager"
end
"""
end
end
test "should allow using process manager module as name" do
Code.eval_string """
defmodule MyProcessManager do
use Commanded.ProcessManagers.ProcessManager,
name: __MODULE__,
router: Commanded.ExampleDomain.BankRouter
end
"""
end
end