Function TestPartialExecuteCodec_Decode

codecs/partial_codecs_test.go:153–180

(t *testing.T)

}

func TestPartialExecuteCodec_Decode(t *testing.T) {
	localSerialConsistency := primitive.ConsistencyLevelLocalSerial
	codec := &partialExecuteCodec{}

	msg := &message.Execute{
		QueryId:          []byte{0x0a, 0x0b, 0x0c},
		ResultMetadataId: []byte{0x0d, 0x0e, 0x0f},
		Options: &message.QueryOptions{
			Consistency:       primitive.ConsistencyLevelOne,
			SerialConsistency: &localSerialConsistency,
		},
	}

	var buf bytes.Buffer
	err := builtinExecuteCodec.Encode(msg, &buf, primitive.ProtocolVersion4)
	require.NoError(t, err)

	execute, err := codec.Decode(NewFrameBodyReader(buf.Bytes()), primitive.ProtocolVersion4)
	require.NoError(t, err)

	assert.False(t, execute.IsResponse())
	assert.Equal(t, primitive.OpCodeExecute, execute.GetOpCode())
	assert.Equal(t, "EXECUTE 0a0b0c", execute.(*PartialExecute).String())

	assert.Equal(t, []byte{0x0a, 0x0b, 0x0c}, execute.(*PartialExecute).QueryId)
	assert.Equal(t, primitive.ConsistencyLevelOne, execute.(*PartialExecute).Consistency)
	assert.Equal(t, []byte{0x10, 0x00, 0x9}, execute.(*PartialExecute).Parameters)
}

func TestPartialExecuteCodec_Decode_Invalid(t *testing.T) {
	tests := []struct {