backend: more serialize object integration tests

redpanda-data · Aug 31, 2023 · 7f58284 · 7f58284
1 parent dde5877
commit 7f58284
Show file tree

Hide file tree

Showing 3 changed files with 777 additions and 189 deletions.
diff --git a/backend/pkg/serde/record.go b/backend/pkg/serde/record.go
@@ -107,6 +107,7 @@ type TroubleshootingReport struct {
 }
 
 type SerializeInput struct {
+	Topic string
 	Key   RecordPayloadInput
 	Value RecordPayloadInput
 }

diff --git a/backend/pkg/serde/service.go b/backend/pkg/serde/service.go
@@ -173,6 +173,10 @@ func (s *Service) SerializeRecord(input SerializeInput) (*SerializeOutput, error
 	sr := SerializeOutput{}
 
 	// key
+	if input.Topic != "" {
+		input.Key.Options = append(input.Key.Options, WithTopic(input.Topic))
+	}
+
 	keyTS := make([]TroubleshootingReport, 0)
 	found := false
 	for _, serde := range s.SerDes {
@@ -188,11 +192,12 @@ func (s *Service) SerializeRecord(input SerializeInput) (*SerializeOutput, error
 			} else {
 				keySerResult.Encoding = serde.Name()
 				keySerResult.Payload = bytes
-				keySerResult.Troubleshooting = keyTS
 			}
 		}
 	}
 
+	keySerResult.Troubleshooting = keyTS
+
 	sr.Key = &keySerResult
 
 	if !found {
@@ -203,6 +208,11 @@ func (s *Service) SerializeRecord(input SerializeInput) (*SerializeOutput, error
 		return &sr, err
 	}
 
+	// value
+	if input.Topic != "" {
+		input.Value.Options = append(input.Value.Options, WithTopic(input.Topic))
+	}
+
 	valueTS := make([]TroubleshootingReport, 0)
 	found = false
 	for _, serde := range s.SerDes {
@@ -218,11 +228,12 @@ func (s *Service) SerializeRecord(input SerializeInput) (*SerializeOutput, error
 			} else {
 				valueSerResult.Encoding = serde.Name()
 				valueSerResult.Payload = bytes
-				valueSerResult.Troubleshooting = valueTS
 			}
 		}
 	}
 
+	valueSerResult.Troubleshooting = valueTS
+
 	sr.Value = &valueSerResult
 
 	if !found {