Minor refactor

lib/cdc/event.go

@@ -28,14 +28,9 @@ type Event interface {
 	GetColumns(ctx context.Context) *columns.Columns
 }
 
-// FieldLabelKind is used when the schema is turned on. Each schema object will be labelled.
+// FieldLabelKind is used when the schema is turned on.
 type FieldLabelKind string
 
 const (
-	Before      FieldLabelKind = "before"
-	After       FieldLabelKind = "after"
-	Source      FieldLabelKind = "source"
-	Op          FieldLabelKind = "op"
-	TsMs        FieldLabelKind = "ts_ms"
-	Transaction FieldLabelKind = "transaction"
+	After FieldLabelKind = "after"
 )

lib/cdc/mongo/debezium_test.go

@@ -4,7 +4,6 @@ import (
 	"encoding/json"
 	"time"
 
-	"github.com/artie-labs/transfer/lib/cdc"
 	"github.com/artie-labs/transfer/lib/config/constants"
 	"github.com/artie-labs/transfer/lib/debezium"
 
@@ -442,12 +441,6 @@ func (p *MongoTestSuite) TestMongoDBEventWithSchema() {
 	schemaEvt, isOk := evt.(*SchemaEventPayload)
 	assert.True(p.T(), isOk)
 	assert.Equal(p.T(), schemaEvt.Schema.SchemaType, "struct")
-	assert.Equal(p.T(), schemaEvt.Schema.GetSchemaFromLabel(cdc.Source).Fields[0], debezium.Field{
-		Optional:     false,
-		FieldName:    "version",
-		DebeziumType: "",
-		Type:         "string",
-	})
 	assert.False(p.T(), evt.DeletePayload())
 	cols := schemaEvt.GetColumns(p.ctx)
 	assert.NotNil(p.T(), cols)

lib/cdc/util/parse.go

@@ -11,6 +11,11 @@ import (
 
 // ParseField returns a `parsedValue` as type interface{}
 func parseField(ctx context.Context, field debezium.Field, value interface{}) interface{} {
+	if value == nil {
+		// Early exit.
+		return nil
+	}
+
 	// Check if the field is an integer and requires us to cast it as such.
 	if field.IsInteger() {
 		valFloat, isOk := value.(float64)

lib/cdc/util/parse_test.go

@@ -17,6 +17,11 @@ func (u *UtilTestSuite) TestParseField() {
 	}
 
 	testCases := []_testCase{
+		{
+			name:          "nil",
+			value:         nil,
+			expectedValue: nil,
+		},
 		{
 			name:          "string",
 			value:         "robin",

lib/stringutil/strings.go

@@ -9,10 +9,6 @@ import (
 
 // Override - pass in a list of vals, the right most value that is not empty will override.
 func Override(vals ...string) string {
-	if len(vals) == 0 {
-		return ""
-	}
-
 	var retVal string
 	for _, val := range vals {
 		if val != "" {