describe_user_scram_credentials_response_test.go

package sarama

import (
	"testing"
	"time"
)

var (
	emptyDescribeUserScramCredentialsResponse = []byte{
		0, 0, 11, 184, // throttle time (3000 ms)
		0, 0, // no error code
		0, // no error message
		1, // empty array
		0, // tagged fields
	}

	userDescribeUserScramCredentialsResponse = []byte{
		0, 0, 11, 184, // throttle time (3000 ms)
		0, 11, // Error Code
		6, 'e', 'r', 'r', 'o', 'r', // ErrorMessage
		2,                               // Results array length
		7, 'n', 'o', 'b', 'o', 'd', 'y', // User
		0, 13, // User ErrorCode
		11, 'e', 'r', 'r', 'o', 'r', '_', 'u', 's', 'e', 'r', // User ErrorMessage
		2,           // CredentialInfos array length
		2,           // Mechanism
		0, 0, 16, 0, // Iterations
		0, 0, 0,
	}
)

func TestDescribeUserScramCredentialsResponse(t *testing.T) {
	response := &DescribeUserScramCredentialsResponse{
		Version:      0,
		ThrottleTime: time.Second * 3,
	}
	testResponse(t, "empty", response, emptyDescribeUserScramCredentialsResponse)

	responseErrorMessage := "error"
	responseUserErrorMessage := "error_user"

	response.ErrorCode = 11
	response.ErrorMessage = &responseErrorMessage
	response.Results = append(response.Results, &DescribeUserScramCredentialsResult{
		User:         "nobody",
		ErrorCode:    13,
		ErrorMessage: &responseUserErrorMessage,
		CredentialInfos: []*UserScramCredentialsResponseInfo{
			{
				Mechanism:  SCRAM_MECHANISM_SHA_512,
				Iterations: 4096,
			},
		},
	})
	testResponse(t, "empty", response, userDescribeUserScramCredentialsResponse)
}