list_groups_response_test.go

package sarama

import (
	"errors"
	"testing"
)

var (
	listGroupsResponseEmpty = []byte{
		0, 0, // no error
		0, 0, 0, 0, // no groups
	}

	listGroupsResponseError = []byte{
		0, 31, // no error
		0, 0, 0, 0, // ErrClusterAuthorizationFailed
	}

	listGroupsResponseWithConsumer = []byte{
		0, 0, // no error
		0, 0, 0, 1, // 1 group
		0, 3, 'f', 'o', 'o', // group name
		0, 8, 'c', 'o', 'n', 's', 'u', 'm', 'e', 'r', // protocol type
	}

	listGroupResponseV4 = []byte{
		0, 0, 0, 0, // no throttle time
		0, 0, // no error
		2,                // compact array length (1)
		4, 'f', 'o', 'o', // group name (compact string)
		9, 'c', 'o', 'n', 's', 'u', 'm', 'e', 'r', // protocol type (compact string)
		6, 'E', 'm', 'p', 't', 'y', // state (compact string)
		0, // Empty tag buffer
		0, // Empty tag buffer
	}
)

func TestListGroupsResponse(t *testing.T) {
	var response *ListGroupsResponse

	response = new(ListGroupsResponse)
	testVersionDecodable(t, "no error", response, listGroupsResponseEmpty, 0)
	if !errors.Is(response.Err, ErrNoError) {
		t.Error("Expected no gerror, found:", response.Err)
	}
	if len(response.Groups) != 0 {
		t.Error("Expected no groups")
	}

	response = new(ListGroupsResponse)
	testVersionDecodable(t, "no error", response, listGroupsResponseError, 0)
	if !errors.Is(response.Err, ErrClusterAuthorizationFailed) {
		t.Error("Expected no gerror, found:", response.Err)
	}
	if len(response.Groups) != 0 {
		t.Error("Expected no groups")
	}

	response = new(ListGroupsResponse)
	testVersionDecodable(t, "no error", response, listGroupsResponseWithConsumer, 0)
	if !errors.Is(response.Err, ErrNoError) {
		t.Error("Expected no gerror, found:", response.Err)
	}
	if len(response.Groups) != 1 {
		t.Error("Expected one group")
	}
	if response.Groups["foo"] != "consumer" {
		t.Error("Expected foo group to use consumer protocol")
	}

	response = new(ListGroupsResponse)
	testVersionDecodable(t, "no error", response, listGroupResponseV4, 4)
	if !errors.Is(response.Err, ErrNoError) {
		t.Error("Expected no gerror, found:", response.Err)
	}
	if len(response.Groups) != 1 {
		t.Error("Expected one group")
	}
	if response.Groups["foo"] != "consumer" {
		t.Error("Expected foo group to use consumer protocol")
	}
	if response.GroupsData["foo"].GroupState != "Empty" {
		t.Error("Expected foo grup to have empty state")
	}
}