sarama/acl_create_request_test.go

package sarama

import "testing"

var (
	aclCreateRequest = []byte{
		0, 0, 0, 1,
		3, // resource type = group
		0, 5, 'g', 'r', 'o', 'u', 'p',
		0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
		0, 4, 'h', 'o', 's', 't',
		2, // all
		2, // deny
	}
	aclCreateRequestv1 = []byte{
		0, 0, 0, 1,
		3, // resource type = group
		0, 5, 'g', 'r', 'o', 'u', 'p',
		3, // resource pattten type = literal
		0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
		0, 4, 'h', 'o', 's', 't',
		2, // all
		2, // deny
	}
)

func TestCreateAclsRequestv0(t *testing.T) {
	req := &CreateAclsRequest{
		Version: 0,
		AclCreations: []*AclCreation{{
			Resource: Resource{
				ResourceType: AclResourceGroup,
				ResourceName: "group",
			},
			Acl: Acl{
				Principal:      "principal",
				Host:           "host",
				Operation:      AclOperationAll,
				PermissionType: AclPermissionDeny,
			}},
		},
	}

	testRequest(t, "create request", req, aclCreateRequest)
}

func TestCreateAclsRequestv1(t *testing.T) {
	req := &CreateAclsRequest{
		Version: 1,
		AclCreations: []*AclCreation{{
			Resource: Resource{
				ResourceType:        AclResourceGroup,
				ResourceName:        "group",
				ResourcePatternType: AclPatternLiteral,
			},
			Acl: Acl{
				Principal:      "principal",
				Host:           "host",
				Operation:      AclOperationAll,
				PermissionType: AclPermissionDeny,
			}},
		},
	}

	testRequest(t, "create request v1", req, aclCreateRequestv1)
}