deep clone

FGasper · FGasper · commit fc8bee168eea · 2024-11-22T01:34:53.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -170,7 +170,10 @@ func (verifier *Verifier) readAndHandleOneChangeEventBatch(
 			changeEventBatch = make([]bson.Raw, cs.RemainingBatchLength()+1)
 		}
 
-		copy(changeEventBatch[eventsRead], cs.Current)
+		// NB: Decode() achieves a deep-clone of cs.Current.
+		if err := cs.Decode(&changeEventBatch[eventsRead]); err != nil {
+			return errors.Wrap(err, "failed to decode change event")
+		}
 
 		eventsRead++
 	}

Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,10 @@ func (verifier *Verifier) readAndHandleOneChangeEventBatch(`
`170`	`170`	`changeEventBatch = make([]bson.Raw, cs.RemainingBatchLength()+1)`
`171`	`171`	`}`
`172`	`172`
`173`		`- copy(changeEventBatch[eventsRead], cs.Current)`
	`173`	`+ // NB: Decode() achieves a deep-clone of cs.Current.`
	`174`	`+ if err := cs.Decode(&changeEventBatch[eventsRead]); err != nil {`
	`175`	`+ return errors.Wrap(err, "failed to decode change event")`
	`176`	`+ }`
`174`	`177`
`175`	`178`	`eventsRead++`
`176`	`179`	`}`