kafe

% @hidden
-module(kafe_protocol_leave_group).

-include("../include/kafe.hrl").
-define(MAX_VERSION, 0).

-export([
         run/2,
         request/3,
         response/2
        ]).

run(GroupId, MemberId) ->
  kafe_protocol:run(
    ?LEAVE_GROUP_REQUEST,
    ?MAX_VERSION,
    {fun ?MODULE:request/3, [GroupId, MemberId]},
    fun ?MODULE:response/2,
    #{broker => {coordinator, GroupId}}).

% LeaveGroup Request (Version: 0) => group_id member_id
%   group_id => STRING
%   member_id => STRING
request(GroupId, MemberId, State) ->
  kafe_protocol:request(
    <<(kafe_protocol:encode_string(GroupId))/binary,
      (kafe_protocol:encode_string(MemberId))/binary>>,
    State).

% LeaveGroup Response (Version: 0) => error_code
%   error_code => INT16
response(<<ErrorCode:16/signed>>,
         _State) ->
  {ok, #{error_code => kafe_error:code(ErrorCode)}}.