Function TestPartialExecuteCodec_Encode

codecs/partial_codecs_test.go:217–299

(t *testing.T)

}

func TestPartialExecuteCodec_Encode(t *testing.T) {
	tests := []struct {
		name string
		msg  *message.Execute
	}{
		{
			name: "simple",
			msg: &message.Execute{
				QueryId:          []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8},
				ResultMetadataId: []byte{0xa, 0xb, 0xc, 0xd, 0xe, 0xf, 0xa, 0xb},
			},
		},
		{
			name: "consistency",
			msg: &message.Execute{
				QueryId:          []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8},
				ResultMetadataId: []byte{0xa, 0xb, 0xc, 0xd, 0xe, 0xf, 0xa, 0xb},
				Options: &message.QueryOptions{
					Consistency: primitive.ConsistencyLevelEachQuorum,
				},
			},
		},
		{
			name: "parameters",
			msg: &message.Execute{
				QueryId:          []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8},
				ResultMetadataId: []byte{0xa, 0xb, 0xc, 0xd, 0xe, 0xf, 0xa, 0xb},
				Options: &message.QueryOptions{
					Consistency: primitive.ConsistencyLevelEachQuorum,
					PositionalValues: []*primitive.Value{
						{
							Type:     primitive.ValueTypeRegular,
							Contents: []byte{0x1, 0x2, 0x3},
						},
						{
							Type:     primitive.ValueTypeRegular,
							Contents: []byte{0x4, 0x5, 0x6},
						},
					},
					SkipMetadata:    true,
					PageSize:        123,
					PageSizeInBytes: false,
					PagingState:     []byte{0xa, 0xb, 0xc},
					Keyspace:        "keyspace1",
				},
			},
		},
	}

	codec := &partialExecuteCodec{}
	version := primitive.ProtocolVersion4

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			expectedLen, err := builtinExecuteCodec.EncodedLength(tt.msg, version)
			assert.NoError(t, err, "unexpected error calculating encoded length with built-in execute codec")

			var expectedBytes bytes.Buffer