pact_erlang

-module(pact_consumer_msg).

-export([
    interaction/2
]).

-type pact_ref() :: integer().
-type pact_interaction_ref() :: integer().
-type pact_pid() :: pid().
-type pact_interaction_details() :: map().
-type message() :: map().

-spec interaction(pact_pid(), pact_interaction_details()) ->
    message().
interaction(PactPid, Interaction) ->
    {_PactRef, InteractionRef} = init_interaction(PactPid, Interaction),
    Message = maps:get(with_contents, Interaction, #{}),
    ok = insert_contents(InteractionRef, Message),
    pactffi_nif:get_reified_message(InteractionRef).

%% Internal functions

-spec init_interaction(pact_pid(), pact_interaction_details()) ->
    {pact_ref(), pact_interaction_ref()}.
init_interaction(PactPid, Interaction) ->
    {Consumer, Producer} = pact_ref_server:get_consumer_producer(PactPid),
    PactRef = pactffi_nif:new_pact(Consumer, Producer),
    ok = pact_ref_server:set_pact_ref(PactPid, PactRef),
    InteractionDesc = maps:get(upon_receiving, Interaction, <<"">>),
    InteractionRef = pactffi_nif:new_msg_interaction(PactRef, InteractionDesc),
    case maps:get(given, Interaction, undefined) of
        undefined ->
            ok;
        GivenState when is_binary(GivenState) ->
            pactffi_nif:msg_given(InteractionRef, GivenState);
        GivenStateWithParams when is_map(GivenStateWithParams) ->
            ProviderState = maps:get(state, GivenStateWithParams, <<"">>),
            StateJson = maps:get(params, GivenStateWithParams, undefined),
            case StateJson of
                undefined ->
                    pactffi_nif:msg_given(InteractionRef, ProviderState);
                _ ->
                    maps:foreach(
                        fun(Key, Value) ->
                            pactffi_nif:msg_given_with_param(
                                InteractionRef, ProviderState, Key, Value
                            )
                        end,
                        StateJson
                    )
            end
    end,
    ok = pact_ref_server:create_interaction(PactPid, InteractionRef, Interaction),
    {PactRef, InteractionRef}.

-spec insert_contents(pact_interaction_ref(), message()) -> ok.
insert_contents(InteractionRef, Message) ->
    ResHeaders = maps:get(headers, Message, #{}),
    ContentType = get_content_type(ResHeaders),
    NewMessage = pact_consumer:encode_value(Message),
    pactffi_nif:msg_with_contents(InteractionRef, ContentType, NewMessage),
    ok.

-spec get_content_type(map()) -> binary().
get_content_type(Headers) ->
    maps:get(<<"Content-Type">>, Headers, <<"application/json">>).