mirror of https://github.com/mongodb/mongo
57 lines
2.1 KiB
JavaScript
57 lines
2.1 KiB
JavaScript
// Helpers for testing the logical sessions collection.
|
|
|
|
/**
|
|
* Assumes that there is only one session chunk and two shards (shard0 and shard1).
|
|
* Returns two shards, where the first shard returned is the shard that has the session chunk
|
|
* and the second shard returned is the one that does not have the session chunk.
|
|
*/
|
|
export function getShardsWithAndWithoutChunk(st, shard0, shard1) {
|
|
let configDB = st.s.getDB("config");
|
|
let configSessionsUUID = configDB.collections.findOne({_id: "config.system.sessions"}).uuid;
|
|
let sessionChunks = configDB.chunks.find({uuid: configSessionsUUID}).toArray();
|
|
|
|
assert.eq(1, sessionChunks.length, tojson(sessionChunks));
|
|
let sessionChunk = sessionChunks[0];
|
|
|
|
if (sessionChunk.shard == shard0.shardName) {
|
|
return {shardWithSessionChunk: shard0, shardWithoutSessionChunk: shard1};
|
|
} else {
|
|
assert.eq(sessionChunk.shard, shard1.shardName, tojson(sessionChunk));
|
|
return {shardWithSessionChunk: shard1, shardWithoutSessionChunk: shard0};
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Validates that the sessions collection exists if we expect it to,
|
|
* and has a TTL index on the lastUse field, if we expect it to.
|
|
*/
|
|
export function validateSessionsCollection(conn, collectionExists, indexExists, timeout) {
|
|
let config = conn.getDB("config");
|
|
|
|
let info = config.getCollectionInfos({name: "system.sessions"});
|
|
let size = collectionExists ? 1 : 0;
|
|
assert.eq(info.length, size);
|
|
|
|
let indexes = config.system.sessions.getIndexes();
|
|
let found = false;
|
|
for (let i = 0; i < indexes.length; i++) {
|
|
let entry = indexes[i];
|
|
if (entry["name"] == "lsidTTLIndex") {
|
|
found = true;
|
|
|
|
assert.eq(entry["key"], {"lastUse": 1});
|
|
assert(entry.hasOwnProperty("expireAfterSeconds"));
|
|
if (timeout) {
|
|
assert.eq(entry["expireAfterSeconds"], timeout * 60);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (indexExists) {
|
|
assert(collectionExists);
|
|
assert(found, "expected sessions collection TTL index to exist");
|
|
} else {
|
|
assert(!found, "TTL index on sessions collection exists");
|
|
}
|
|
}
|