fix

FGasper · FGasper · commit 3b1884553039 · 2024-10-30T11:32:46.000-04:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -85,7 +85,7 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 		}
 
 		err := verifier.persistChangeStreamResumeToken(ctx, cs)
-		if err != nil {
+		if err == nil {
 			lastPersistedTime = time.Now()
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,7 @@ func (verifier Verifier) iterateChangeStream(ctx context.Context, cs mongo.Cha`
`85`	`85`	`}`
`86`	`86`
`87`	`87`	`err := verifier.persistChangeStreamResumeToken(ctx, cs)`
`88`		`- if err != nil {`
	`88`	`+ if err == nil {`
`89`	`89`	`lastPersistedTime = time.Now()`
`90`	`90`	`}`
`91`	`91`