jstests/replsets/view_catalog_oplog_entries.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

/**
 * Test that creating and modifying a view publishes entries to the oplog for each operation and
 * that both entries include a UUID for the "system.views" collection.
 */

(function() {
    "use strict";

    const dbName = "view_catalog_oplog_entries";
    const collName = "test_coll";
    const viewName = "test_view";

    const replTest = new ReplSetTest({nodes: 1});
    replTest.startSet();
    replTest.initiate();

    const primary = replTest.getPrimary();

    assert.commandWorked(primary.getDB(dbName)[collName].insert({a: 1}));

    // Create the view.
    assert.commandWorked(primary.getDB(dbName).createView(viewName, collName, []));

    // Modify the view with the "collMod" command.
    assert.commandWorked(primary.getDB(dbName).runCommand(
        {collMod: viewName, viewOn: collName, pipeline: [{$project: {a: 1}}]}));

    // There should be exactly one insert into "system.views" for the view creation...
    const oplog = primary.getDB("local").oplog.rs;
    const createViewOplogEntry = oplog.find({op: "i", ns: (dbName + ".system.views")}).toArray();
    assert.eq(createViewOplogEntry.length, 1);
    assert(createViewOplogEntry[0].hasOwnProperty("ui"),
           "Oplog entry for view creation missing UUID for view catalog: " +
               tojson(createViewOplogEntry[0]));
    const viewCatalogUUID = createViewOplogEntry[0].ui;

    // ...and exactly one update on "system.views" for the view collMod.
    const modViewOplogEntry = oplog.find({op: "u", ns: (dbName + ".system.views")}).toArray();
    assert.eq(modViewOplogEntry.length, 1);
    assert(modViewOplogEntry[0].hasOwnProperty("ui"),
           "Oplog entry for view modification missing UUID for view catalog: " +
               tojson(modViewOplogEntry[0]));

    // Both entries should have the same UUID.
    assert.eq(viewCatalogUUID, modViewOplogEntry[0].ui);

    replTest.stopSet();
}());