Fixing binlog jsonSerializer from change to use new LazyJSONDocument …

…type.
dolthub · May 1, 2024 · 7e651ef · 7e651ef
1 parent 3e885e4
commit 7e651ef
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/go/libraries/doltcore/sqle/binlogreplication/binlog_type_serialization.go b/go/libraries/doltcore/sqle/binlogreplication/binlog_type_serialization.go
@@ -752,9 +752,17 @@ func (j jsonSerializer) serialize(ctx *sql.Context, typ sql.Type, descriptor val
 		return nil, err
 	}
 	if json != nil {
-		jsonDoc, ok := json.(gmstypes.JSONDocument)
-		if !ok {
-			return nil, fmt.Errorf("supported JSON type: %T", json)
+		var jsonDoc gmstypes.JSONDocument
+		if lazyJsonDoc, ok := json.(*gmstypes.LazyJSONDocument); ok {
+			i, err := lazyJsonDoc.ToInterface()
+			if err != nil {
+				return nil, err
+			}
+			jsonDoc = gmstypes.JSONDocument{Val: i}
+		} else if _, ok := json.(gmstypes.JSONDocument); ok {
+			jsonDoc = json.(gmstypes.JSONDocument)
+		} else {
+			return nil, fmt.Errorf("unsupported JSON type: %T", json)
 		}
 
 		jsonBuffer, err := encodeJsonDoc(jsonDoc)