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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
// Sessions are asynchronously flushed to disk, so a stepdown immediately after calling
// startSession may cause this test to fail to find the returned sessionId.
// The test runs commands that are not allowed with security token: connectionStatus.
// @tags: [
// not_allowed_with_security_token,
// does_not_support_stepdowns,
// uses_testing_only_commands,
// no_selinux,
// # The config fuzzer may run logical session cache refreshes in the background, which interferes
// # with this test.
// does_not_support_config_fuzzer,
// ]
// Basic tests for the $listSessions aggregation stage.
(function() {
'use strict';
load('jstests/aggregation/extras/utils.js');
const admin = db.getSiblingDB('admin');
const config = db.getSiblingDB('config');
const pipeline = [{'$listSessions': {}}];
function listSessions() {
return config.system.sessions.aggregate(pipeline);
}
// Start a new session and capture its sessionId.
const myid = assert.commandWorked(admin.runCommand({startSession: 1})).id.id;
assert(myid !== undefined);
// Sync cache to collection and ensure it arrived.
assert.commandWorked(admin.runCommand({refreshLogicalSessionCacheNow: 1}));
var resultArrayMine;
assert.soon(function() {
const resultArray = listSessions().toArray();
if (resultArray.length < 1) {
return false;
}
resultArrayMine = resultArray
.map(function(sess) {
return sess._id;
})
.filter(function(id) {
return 0 == bsonWoCompare({x: id.id}, {x: myid});
});
return resultArrayMine.length == 1;
}, "Failed to locate session in collection");
// Try asking for the session by username.
const myusername = (function() {
if (0 == bsonWoCompare({x: resultArrayMine[0].uid}, {x: computeSHA256Block("")})) {
// Code for "we're running in no-auth mode"
return {user: "", db: ""};
}
const connstats = assert.commandWorked(db.runCommand({connectionStatus: 1}));
const authUsers = connstats.authInfo.authenticatedUsers;
assert(authUsers !== undefined);
assert.eq(authUsers.length, 1);
assert(authUsers[0].user !== undefined);
assert(authUsers[0].db !== undefined);
return {user: authUsers[0].user, db: authUsers[0].db};
})();
function listMySessions() {
return config.system.sessions.aggregate([{'$listSessions': {users: [myusername]}}]);
}
const myArray = listMySessions()
.toArray()
.map(function(sess) {
return sess._id;
})
.filter(function(id) {
return 0 == bsonWoCompare({x: id.id}, {x: myid});
});
assert.eq(0, bsonWoCompare(myArray, resultArrayMine));
// Make sure pipelining other collections fail.
assertErrorCode(admin.system.collections, pipeline, ErrorCodes.InvalidNamespace);
})();
|
