@@ -885,7 +885,7 @@ func (verifier *Verifier) doIndexSpecsMatch(ctx context.Context, srcSpec bson.Ra
885885 }
886886
887887 defer func () {
888- coll .DeleteOne (ctx , bson.M {"_id" : insert .InsertedID })
888+ _ , _ = coll .DeleteOne (ctx , bson.M {"_id" : insert .InsertedID })
889889 }()
890890
891891 cursor , err := coll .Aggregate (
@@ -936,67 +936,6 @@ func (verifier *Verifier) doIndexSpecsMatch(ctx context.Context, srcSpec bson.Ra
936936 return false , errors .Errorf ("weirdly received %d matching index docs (should be 0 or 1)" , count )
937937}
938938
939- /*
940-
941- // Order is always significant in the keys document.
942- if !bytes.Equal(srcSpec.KeysDocument, dstSpec.KeysDocument) {
943- results = append(results, VerificationResult{
944- NameSpace: dstSpec.Namespace,
945- Cluster: ClusterTarget,
946- ID: dstSpec.Name,
947- Field: "KeysDocument",
948- Details: Mismatch + fmt.Sprintf(" : src: %v, dst: %v", srcSpec.KeysDocument, dstSpec.KeysDocument)})
949- }
950-
951- // We don't check version because it may change when migrating between server versions.
952-
953- if !reflect.DeepEqual(srcSpec.ExpireAfterSeconds, dstSpec.ExpireAfterSeconds) {
954- results = append(results, VerificationResult{
955- NameSpace: dstSpec.Namespace,
956- Cluster: ClusterTarget,
957- ID: dstSpec.Name,
958- Field: "ExpireAfterSeconds",
959- Details: Mismatch + fmt.Sprintf(" : src: %s, dst: %s", nilableToString(srcSpec.ExpireAfterSeconds), nilableToString(dstSpec.ExpireAfterSeconds))})
960- }
961-
962- if !reflect.DeepEqual(srcSpec.Sparse, dstSpec.Sparse) {
963- results = append(results, VerificationResult{
964- NameSpace: dstSpec.Namespace,
965- Cluster: ClusterTarget,
966- ID: dstSpec.Name,
967- Field: "Sparse",
968- Details: Mismatch + fmt.Sprintf(" : src: %s, dst: %s", nilableToString(srcSpec.Sparse), nilableToString(dstSpec.Sparse))})
969- }
970-
971- if !reflect.DeepEqual(srcSpec.Unique, dstSpec.Unique) {
972- results = append(results, VerificationResult{
973- NameSpace: dstSpec.Namespace,
974- Cluster: ClusterTarget,
975- ID: dstSpec.Name,
976- Field: "Unique",
977- Details: Mismatch + fmt.Sprintf(" : src: %s, dst: %s", nilableToString(srcSpec.Unique), nilableToString(dstSpec.Unique))})
978- }
979-
980- if !reflect.DeepEqual(srcSpec.Clustered, dstSpec.Clustered) {
981- results = append(results, VerificationResult{
982- NameSpace: dstSpec.Namespace,
983- Cluster: ClusterTarget,
984- ID: dstSpec.Name,
985- Field: "Clustered",
986- Details: Mismatch + fmt.Sprintf(" : src: %s, dst: %s", nilableToString(srcSpec.Clustered), nilableToString(dstSpec.Clustered))})
987- }
988- return results
989- }
990- */
991-
992- func nilableToString [T any ](ptr * T ) string {
993- if ptr == nil {
994- return "(unset)"
995- }
996-
997- return fmt .Sprintf ("%v" , * ptr )
998- }
999-
1000939func (verifier * Verifier ) ProcessCollectionVerificationTask (ctx context.Context , workerNum int , task * VerificationTask ) {
1001940 verifier .logger .Debug ().Msgf ("[Worker %d] Processing collection" , workerNum )
1002941 verifier .verifyMetadataAndPartitionCollection (ctx , workerNum , task )
0 commit comments