refactor(log_assertion): use serializer for encoding record batches

Author: ryan-gang

internal/assertions/log_assertion.go

@@ -9,16 +9,17 @@ import (
 	kafkaapi "github.com/codecrafters-io/kafka-tester/protocol/api"
 	"github.com/codecrafters-io/kafka-tester/protocol/common"
 	"github.com/codecrafters-io/kafka-tester/protocol/decoder"
+	"github.com/codecrafters-io/kafka-tester/protocol/serializer"
 	"github.com/codecrafters-io/tester-utils/logger"
 )
 
 type TopicPartitionLogAssertion struct {
 	topic         string
 	partition     int32
-	RecordBatches []kafkaapi.RecordBatch
+	RecordBatches kafkaapi.RecordBatches
 }
 
-func NewTopicPartitionLogAssertion(topic string, partition int32, recordBatches []kafkaapi.RecordBatch) TopicPartitionLogAssertion {
+func NewTopicPartitionLogAssertion(topic string, partition int32, recordBatches kafkaapi.RecordBatches) TopicPartitionLogAssertion {
 	return TopicPartitionLogAssertion{
 		topic:         topic,
 		partition:     partition,
@@ -35,7 +36,7 @@ func (a TopicPartitionLogAssertion) Run(logger *logger.Logger) error {
 		return fmt.Errorf("Failed to read log file %s: %w", logFilePath, err)
 	}
 
-	expectedEncodedRecordBatches := encodeRecordBatches(a.RecordBatches)
+	expectedEncodedRecordBatches := serializer.GetEncodedBytes(a.RecordBatches)
 	if len(expectedEncodedRecordBatches) == 0 {
 		panic("Codecrafters Internal Error: RecordBatches are empty")
 	}