[Debezium] ItemsMetadata is optional (#1076)

artie-labs · Dec 12, 2024 · d93bf20 · d93bf20
1 parent 5b3ff02
commit d93bf20
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/lib/debezium/schema.go b/lib/debezium/schema.go
@@ -67,7 +67,7 @@ type Field struct {
 	DebeziumType SupportedDebeziumType `json:"name"`
 	Parameters   map[string]any        `json:"parameters"`
 	// [ItemsMetadata] is only populated if the literal type is an array.
-	ItemsMetadata Item `json:"items"`
+	ItemsMetadata *Item `json:"items,omitempty"`
 }
 
 func (f Field) GetScaleAndPrecision() (int32, *int32, error) {
@@ -146,7 +146,12 @@ func (f Field) ToValueConverter() (converters.ValueConverter, error) {
 
 		switch f.Type {
 		case Array:
-			return converters.NewArray(f.ItemsMetadata.DebeziumType == JSON), nil
+			var json bool
+			if f.ItemsMetadata != nil {
+				json = f.ItemsMetadata.DebeziumType == JSON
+			}
+
+			return converters.NewArray(json), nil
 		case Double, Float:
 			return converters.Float64{}, nil
 		}

diff --git a/lib/debezium/types_test.go b/lib/debezium/types_test.go
@@ -174,7 +174,7 @@ func TestField_ParseValue(t *testing.T) {
 	}
 	{
 		// Array
-		field := Field{Type: Array, ItemsMetadata: Item{DebeziumType: JSON}}
+		field := Field{Type: Array, ItemsMetadata: &Item{DebeziumType: JSON}}
 		value, err := field.ParseValue([]any{`{"foo": "bar", "foo": "bar"}`, `{"hello": "world"}`})
 		assert.NoError(t, err)
 		assert.Len(t, value.([]any), 2)