sarama/acl_delete_response_test.go at main · leboncoin/sarama · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
//go:build !functional

package sarama

import (
	"testing"
	"time"
)

var (
	deleteAclsResponse = []byte{
		0, 0, 0, 100,
		0, 0, 0, 1,
		0, 0, // no error
		255, 255, // no error message
		0, 0, 0, 1, // 1 matching acl
		0, 0, // no error
		255, 255, // no error message
		2, // resource type
		0, 5, 't', 'o', 'p', 'i', 'c',
		0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
		0, 4, 'h', 'o', 's', 't',
		4,
		3,
	}
	deleteAclsResponseV1 = []byte{
		0, 0, 0, 100,
		0, 0, 0, 1,
		0, 0, // no error
		255, 255, // no error message
		0, 0, 0, 1, // 1 matching acl
		0, 0, // no error
		255, 255, // no error message
		2, // resource type
		0, 5, 't', 'o', 'p', 'i', 'c',
		1, // resource pattern type any
		0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
		0, 4, 'h', 'o', 's', 't',
		4,
		3,
	}
	deleteAclsResponseV2 = []byte{
		0, 0, 0, 100,
		2,
		0, 0, // no error
		0,    // no error message
		2,    // 1 matching acl
		0, 0, // no error
		0, // no error message
		2, // resource type
		6, 't', 'o', 'p', 'i', 'c',
		1, // resource pattern type any
		10, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l',
		5, 'h', 'o', 's', 't',
		4,
		3,
		0, // empty tagged fields
		0, // empty tagged fields
		0, // empty tagged fields
	}
)

func TestDeleteAclsResponse(t *testing.T) {
	resp := &DeleteAclsResponse{
		ThrottleTime: 100 * time.Millisecond,
		FilterResponses: []*FilterResponse{{
			MatchingAcls: []*MatchingAcl{{
				Resource: Resource{ResourceType: AclResourceTopic, ResourceName: "topic"},
				Acl:      Acl{Principal: "principal", Host: "host", Operation: AclOperationWrite, PermissionType: AclPermissionAllow},
			}},
		}},
	}

	testResponse(t, "", resp, deleteAclsResponse)
}

func TestDeleteAclsResponseV1(t *testing.T) {
	resp := &DeleteAclsResponse{
		Version:      1,
		ThrottleTime: 100 * time.Millisecond,
		FilterResponses: []*FilterResponse{{
			MatchingAcls: []*MatchingAcl{{
				Resource: Resource{ResourceType: AclResourceTopic, ResourceName: "topic", ResourcePatternType: AclPatternAny},
				Acl:      Acl{Principal: "principal", Host: "host", Operation: AclOperationWrite, PermissionType: AclPermissionAllow},
			}},
		}},
	}

	testResponse(t, "", resp, deleteAclsResponseV1)
}

func TestDeleteAclsResponseV2(t *testing.T) {
	resp := &DeleteAclsResponse{
		Version:      2,
		ThrottleTime: 100 * time.Millisecond,
		FilterResponses: []*FilterResponse{{
			MatchingAcls: []*MatchingAcl{{
				Resource: Resource{ResourceType: AclResourceTopic, ResourceName: "topic", ResourcePatternType: AclPatternAny},
				Acl:      Acl{Principal: "principal", Host: "host", Operation: AclOperationWrite, PermissionType: AclPermissionAllow},
			}},
		}},
	}

	testResponse(t, "", resp, deleteAclsResponseV2)
}