Update internal/verifier/change_stream.go

FGasper · mmcclimon · web-flow · commit 59de79c0b987 · 2024-11-21T09:52:22.000-05:00
Co-authored-by: Michael McClimon &lt;michael@mcclimon.org&gt;
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -215,7 +215,7 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 					break
 				}
 
-				if curTs.Compare(finalTs) >= 0 {
+				if curTs == finalTs || curTs.After(finalTs) {
 					verifier.logger.Debug().
 						Interface("currentTimestamp", curTs).
 						Interface("finalTimestamp", finalTs).

Original file line number	Diff line number	Diff line change
`@@ -215,7 +215,7 @@ func (verifier Verifier) iterateChangeStream(ctx context.Context, cs mongo.Cha`
`215`	`215`	`break`
`216`	`216`	`}`
`217`	`217`
`218`		`- if curTs.Compare(finalTs) >= 0 {`
	`218`	`+ if curTs == finalTs \|\| curTs.After(finalTs) {`
`219`	`219`	`verifier.logger.Debug().`
`220`	`220`	`Interface("currentTimestamp", curTs).`
`221`	`221`	`Interface("finalTimestamp", finalTs).`