Function FuzzVersionedDecodeRequest

encoder_decoder_fuzz_test.go:18–78

FuzzVersionedDecodeRequest exercises every supported request decoder against arbitrary input. A decode error is a valid outcome; a panic is not.

(f *testing.F)

// FuzzVersionedDecodeRequest exercises every supported request decoder against
// arbitrary input. A decode error is a valid outcome; a panic is not.
func FuzzVersionedDecodeRequest(f *testing.F) {
	for _, seed := range []struct {
		key, version int16
		body         []byte
	}{
		{key: apiKeyProduce, version: 0, body: produceRequestEmpty},
		{key: apiKeyProduce, version: 0, body: produceRequestHeader},
		{key: apiKeyProduce, version: 0, body: produceRequestOneMessage},
		{key: apiKeyProduce, version: 3, body: produceRequestOneRecord},
		{key: apiKeyFetch, version: 0, body: fetchRequestNoBlocks},
		{key: apiKeyFetch, version: 0, body: fetchRequestWithProperties},
		{key: apiKeyFetch, version: 0, body: fetchRequestOneBlock},
		{key: apiKeyFetch, version: 4, body: fetchRequestOneBlockV4},
		{key: apiKeyFetch, version: 11, body: fetchRequestOneBlockV11},
		{key: apiKeyFetch, version: 12, body: fetchRequestOneBlockV12},
		{key: apiKeyListOffsets, version: 1, body: offsetRequestNoBlocksV1},
		{key: apiKeyMetadata, version: 0, body: metadataRequestNoTopicsV0},
		{key: apiKeyOffsetCommit, version: 0, body: offsetCommitRequestNoBlocksV0},
		{key: apiKeyOffsetFetch, version: 0, body: offsetFetchRequestNoGroupNoPartitions},
		{key: apiKeyFindCoordinator, version: 0, body: consumerMetadataRequestEmpty},
		{key: apiKeyFindCoordinator, version: 1, body: findCoordinatorRequestConsumerGroup},
		{key: apiKeyJoinGroup, version: 0, body: joinGroupRequestV0_NoProtocols},
		{key: apiKeyHeartbeat, version: 0, body: basicHeartbeatRequestV0},
		{key: apiKeyLeaveGroup, version: 0, body: basicLeaveGroupRequestV0},
		{key: apiKeySyncGroup, version: 0, body: emptySyncGroupRequest},
		{key: apiKeyDescribeGroups, version: 0, body: emptyDescribeGroupsRequest},
		{key: apiKeyApiVersions, version: 0, body: apiVersionRequest},
		{key: apiKeyCreateTopics, version: 0, body: createTopicsRequestV0},
		{key: apiKeyDeleteTopics, version: 0, body: deleteTopicsRequest},
		{key: apiKeyInitProducerId, version: 0, body: initProducerIDRequestNull},
		{key: apiKeyTxnOffsetCommit, version: 0, body: txnOffsetCommitRequest},
		{key: apiKeyDescribeAcls, version: 0, body: aclDescribeRequest},
		{key: apiKeyCreateAcls, version: 0, body: aclCreateRequest},
		{key: apiKeyDeleteAcls, version: 1, body: aclDeleteRequestNullsv1},
		{key: apiKeyDescribeConfigs, version: 0, body: emptyDescribeConfigsRequest},
		{key: apiKeyAlterConfigs, version: 0, body: emptyAlterConfigsRequest},
		{key: apiKeyDescribeLogDirs, version: 0, body: emptyDescribeLogDirsRequest},
		{key: apiKeySASLAuth, version: 0, body: saslAuthenticateRequest},
		{key: apiKeyCreatePartitions, version: 0, body: createPartitionRequestNoAssignment},
		{key: apiKeyDeleteGroups, version: 0, body: emptyDeleteGroupsRequest},
		{key: apiKeyElectLeaders, version: 1, body: electLeadersRequestOneTopicV1},
		{key: apiKeyIncrementalAlterConfigs, version: 0, body: emptyIncrementalAlterConfigsRequest},
		{key: apiKeyAlterPartitionReassignments, version: 0, body: alterPartitionReassignmentsRequestNoBlock},
		{key: apiKeyOffsetDelete, version: 0, body: emptyDeleteOffsetsRequest},
		{key: apiKeyDescribeClientQuotas, version: 0, body: describeClientQuotasRequestAll},
		{key: apiKeyAlterClientQuotas, version: 0, body: alterClientQuotasRequestSingleOp},
		{key: apiKeyDescribeUserScramCredentials, version: 0, body: emptyDescribeUserScramCredentialsRequest},
		{key: apiKeyAlterUserScramCredentials, version: 0, body: emptyAlterUserScramCredentialsRequest},
		{key: apiKeyUpdateFeatures, version: 0, body: updateFeaturesRequestV0},
	} {
		f.Add(seed.key, seed.version, seed.body)
	}
	f.Fuzz(func(t *testing.T, key, version int16, in []byte) {
		body := allocateBody(key, version)
		if body == nil {
			t.Skip()
		}
		defer fuzzPanic(t, "request", key, version, in)