diff options
author | Davis Haupt <davis.haupt@mongodb.com> | 2019-07-24 16:12:13 -0400 |
---|---|---|
committer | Davis Haupt <davis.haupt@mongodb.com> | 2019-07-30 12:52:24 -0400 |
commit | 07d7310dde398690d41987f1687864a48c270bde (patch) | |
tree | 869161875caa885462c9fa14ab36971a88300052 /jstests/change_streams | |
parent | b35de8802fb2c7f17fdf57d90b1829ddc303c4c0 (diff) | |
download | mongo-07d7310dde398690d41987f1687864a48c270bde.tar.gz |
SERVER-42210 relax test assertions for whole_cluster_metadata_notifications
Diffstat (limited to 'jstests/change_streams')
-rw-r--r-- | jstests/change_streams/whole_cluster_metadata_notifications.js | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/jstests/change_streams/whole_cluster_metadata_notifications.js b/jstests/change_streams/whole_cluster_metadata_notifications.js index 6b6ebc3143f..0ac9c660ea6 100644 --- a/jstests/change_streams/whole_cluster_metadata_notifications.js +++ b/jstests/change_streams/whole_cluster_metadata_notifications.js @@ -38,17 +38,22 @@ for (let coll of [db1Coll, db2Coll]) { // by a 'dropDatabase' entry. assert.commandWorked(testDB2.dropDatabase()); +const changes = { + [testDB1.getName()]: [], + [testDB2.getName()]: [] +}; + +for (let i = 0; i < 6; i++) { + const change = cst.getOneChange(aggCursor); + changes[change.ns.db].push(change); +} + // We should get 6 oplog entries; three ops of type insert, update, delete from each database. for (let expectedDB of [testDB1, testDB2]) { - let change = cst.getOneChange(aggCursor); - assert.eq(change.operationType, "insert", tojson(change)); - assert.eq(change.ns.db, expectedDB.getName(), tojson(change)); - change = cst.getOneChange(aggCursor); - assert.eq(change.operationType, "update", tojson(change)); - assert.eq(change.ns.db, expectedDB.getName(), tojson(change)); - change = cst.getOneChange(aggCursor); - assert.eq(change.operationType, "delete", tojson(change)); - assert.eq(change.ns.db, expectedDB.getName(), tojson(change)); + const dbChanges = changes[expectedDB.getName()]; + assert.eq(dbChanges[0].operationType, "insert", tojson(changes)); + assert.eq(dbChanges[1].operationType, "update", tojson(changes)); + assert.eq(dbChanges[2].operationType, "delete", tojson(changes)); } cst.assertDatabaseDrop({cursor: aggCursor, db: testDB2}); |