Skip to content

Commit

Permalink
Merge pull request #1481 from agapoff/improved-mock-list-acls-response
Browse files Browse the repository at this point in the history
Improve NewMockListAclsResponse
  • Loading branch information
bai authored Sep 6, 2019
2 parents 6cdd596 + b03ef8d commit 5534ffc
Showing 1 changed file with 22 additions and 4 deletions.
26 changes: 22 additions & 4 deletions mockresponses.go
Original file line number Diff line number Diff line change
Expand Up @@ -812,14 +812,32 @@ func NewMockListAclsResponse(t TestReporter) *MockListAclsResponse {
func (mr *MockListAclsResponse) For(reqBody versionedDecoder) encoder {
req := reqBody.(*DescribeAclsRequest)
res := &DescribeAclsResponse{}

res.Err = ErrNoError
acl := &ResourceAcls{}
acl.Resource.ResourceName = *req.ResourceName
if req.ResourceName != nil {
acl.Resource.ResourceName = *req.ResourceName
}
acl.Resource.ResourcePatternType = req.ResourcePatternTypeFilter
acl.Resource.ResourceType = req.ResourceType
acl.Acls = append(acl.Acls, &Acl{})
res.ResourceAcls = append(res.ResourceAcls, acl)

host := "*"
if req.Host != nil {
host = *req.Host
}

principal := "User:test"
if req.Principal != nil {
principal = *req.Principal
}

permissionType := req.PermissionType
if permissionType == AclPermissionAny {
permissionType = AclPermissionAllow
}

acl.Acls = append(acl.Acls, &Acl{Operation: req.Operation, PermissionType: permissionType, Host: host, Principal: principal})
res.ResourceAcls = append(res.ResourceAcls, acl)
res.Version = int16(req.Version)
return res
}

Expand Down

0 comments on commit 5534ffc

Please sign in to comment.