Aleksey Shakhmatov
d90cde394c
Advertising topologyVersion in the hello reply is what tells a driver the server speaks the streaming (awaitable) hello protocol — in the Node driver it is the only condition checked. From the second heartbeat on, the driver then monitored with an exhaust hello (exhaustAllowed + maxAwaitTimeMS) and waited for a stream of replies carrying moreToCome. We answered once with the flag clear and went back to reading, so every heartbeat failed with "Server ended moreToCome unexpectedly", destroying the connection and clearing the pool. MongoDB Compass showed this as a connect/disconnect loop once per heartbeat. We do not implement streaming hello, so we must not claim to. Omitting the field keeps monitoring on the polling path, and agrees with the maxWireVersion 8 we report: streaming hello arrived in wire version 9. The existing e2e files all passed against the broken server — they issue their commands and exit before the second heartbeat — so e2e5 watches SDAM heartbeats on an idle connection instead. Also renames mongo-light to mongo-lite throughout (binary, log messages, docs, gitVersion). Unrelated to the fix above, but squashed in at request rather than left as a commit whose message described only the fix.
76 lines
2.8 KiB
JavaScript
76 lines
2.8 KiB
JavaScript
// E2E part 5: SDAM monitoring stability, official driver.
|
|
// Every other e2e file issues its commands and exits, so all of them pass
|
|
// against a server whose *monitoring* is broken. This one just sits on an
|
|
// idle connection and watches the driver's heartbeats.
|
|
//
|
|
// The failure it guards against: advertising `topologyVersion` in the hello
|
|
// reply makes the driver monitor with an exhaust hello and expect a stream of
|
|
// moreToCome replies. A server that answers once and goes back to reading
|
|
// fails the heartbeat ("Server ended moreToCome unexpectedly"), the driver
|
|
// drops the connection and clears the pool, and the client — MongoDB Compass,
|
|
// say — shows a connect/disconnect loop once per heartbeat.
|
|
const { MongoClient } = require('mongodb');
|
|
|
|
const URL = 'mongodb://127.0.0.1:27020';
|
|
const results = [];
|
|
function check(name, cond, detail = '') {
|
|
results.push({ name, ok: !!cond, detail: String(detail) });
|
|
if (!cond) console.error(` ✗ ${name} ${detail}`);
|
|
}
|
|
|
|
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
|
|
|
|
// 500ms is the driver's floor for heartbeatFrequencyMS; over WATCH_MS it gives
|
|
// ~10 heartbeats, enough that a per-heartbeat failure cannot hide.
|
|
const HEARTBEAT_MS = 500;
|
|
const WATCH_MS = 5000;
|
|
|
|
async function main() {
|
|
const client = new MongoClient(URL, {
|
|
heartbeatFrequencyMS: HEARTBEAT_MS,
|
|
serverSelectionTimeoutMS: 5000,
|
|
});
|
|
|
|
let succeeded = 0;
|
|
const failures = [];
|
|
client.on('serverHeartbeatSucceeded', () => succeeded++);
|
|
client.on('serverHeartbeatFailed', (e) => failures.push(e.failure ? e.failure.message : 'unknown'));
|
|
// The pool is cleared when SDAM decides the server went away; on a healthy
|
|
// idle connection it should never happen.
|
|
client.on('connectionPoolCleared', () => failures.push('connectionPoolCleared'));
|
|
|
|
await client.connect();
|
|
await client.db('e2e5').command({ ping: 1 });
|
|
|
|
await sleep(WATCH_MS);
|
|
|
|
check('heartbeats actually ran', succeeded >= 5, `${succeeded} succeeded`);
|
|
check('no heartbeat failed', failures.length === 0, failures.join(', '));
|
|
|
|
// A reset pool still recovers, so liveness alone would not catch the loop —
|
|
// check it anyway, since a dead connection here means something worse.
|
|
let usable = true;
|
|
try {
|
|
await client.db('e2e5').command({ ping: 1 });
|
|
} catch (e) {
|
|
usable = false;
|
|
check('connection usable after idle period', false, e.message);
|
|
}
|
|
if (usable) check('connection usable after idle period', true);
|
|
|
|
await client.close();
|
|
|
|
const failed = results.filter((r) => !r.ok);
|
|
console.log(`\n${results.length - failed.length}/${results.length} checks passed`);
|
|
if (failed.length) {
|
|
console.log('FAILED:', failed.map((f) => f.name).join(', '));
|
|
process.exit(1);
|
|
}
|
|
console.log('E2E5_OK');
|
|
}
|
|
|
|
main().catch((e) => {
|
|
console.error('E2E5_FAIL', e);
|
|
process.exit(1);
|
|
});
|