KaufmannEx EventHandler 2

event_handler.ex

defmodule Sample.EventHandler do
  alias KaufmannEx.Schemas.Event

  def given_event(%Event{name: :"command.user.create", payload: payload} = event) do

    {:ok, user_info} = Sample.User.create(payload)

    Publisher.publish(:"event.user.create", user_info, event.meta)
  end
  
  def given_event(%Event{name: :"command.user.delete", payload: %{user_id: id}} = ev) do 
    
    UserAccounts.delete_account(id) # or something 
  end

  # handle unexpected events
  def given_event(event), do: IO.inspect(event.name)
  
end