kaufmann_ex v0.3.2-beta KaufmannEx.TestSupport.MockBus

Helper module for testing event flows.

Cannot be run Async, relies on sending messages to self()

For every given_event/2 and then_event/2.

Validates events against schemas registered with Schema registry
Injects generic Meta payload into given_event

then_event/2 asserts that the given event is emitted and verifies or returned the payload

If you have a custom metadata schema or specific metadata handling, set a module exporting event_metadata/2 in app_env :kaufmann_ex, :metadata_mod

### Example Usage

  defmodule EvenHandlerTests
    use KaufmannEx.TestSupport.MockBus

    test "event emission" do
      given_event(:"TestCommand", %{new_key: "test"})

      then_event(:"Testevent", %{new_key: "test"})

      then_no_event
    end
  end

Link to this section Summary

Functions

assert_matches_schema(event_name, payload, meta)

Assert a named event is encodable by its specified schema

encoded_event(event_name, payload, callback_id \\ nil)

given_event(event_name, payload, callback_id \\ nil)

Dispatches event to the default subscriber

produce(topic, event_name, payload, context)

then_event(event_name)

Asserts an event has been emitted, returns the payload

then_event(event_name, expected_payload)

Asserts an event will be emitted to the bus

then_no_event()

Asserts no more events will be emitted

then_no_event(message_name)

Assert an event will not be emitted

Link to this section Functions