Merge branch 'REP-5299-writesoff-timestamp' of github.com:FGasper/migration-verifier into REP-5299-writesoff-timestamp

Author: FGasper

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).

internal/verifier/integration_test_suite.go

@@ -98,7 +98,7 @@ func (suite *IntegrationTestSuite) SetupTest() {
 		dbNames, err := client.ListDatabaseNames(ctx, bson.D{})
 		suite.Require().NoError(err, "should list database names")
 		for _, dbName := range dbNames {
-			if strings.Index(dbName, suite.DBNameForTest()) == 0 {
+			if strings.HasPrefix(dbName, suite.DBNameForTest()) {
 				suite.T().Logf("Dropping database %#q because it seems to be left over from an earlier run of this test.", dbName)
 				suite.Require().NoError(client.Database(dbName).Drop(ctx))
 			}