0fe48b693d
Signed-off-by: James M Snell <jasnell@gmail.com> PR-URL: https://github.com/nodejs/node/pull/63536 Reviewed-By: Stephen Belanger <admin@stephenbelanger.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
105 lines
2.8 KiB
JavaScript
105 lines
2.8 KiB
JavaScript
// Flags: --experimental-quic --no-warnings
|
|
|
|
// Test: listEndpoints returns live endpoints filtered by active state.
|
|
// - Returns an empty array when no endpoints exist.
|
|
// - Includes all created endpoints.
|
|
// - active=true (default) filters out destroyed, closing, and busy endpoints.
|
|
// - active=false returns all registered endpoints regardless of state.
|
|
// - Validates options argument types.
|
|
|
|
import { hasQuic, skip } from '../common/index.mjs';
|
|
import assert from 'node:assert';
|
|
|
|
const { deepStrictEqual, strictEqual, throws, ok } = assert;
|
|
|
|
if (!hasQuic) {
|
|
skip('QUIC is not enabled');
|
|
}
|
|
|
|
const { listEndpoints, QuicEndpoint } = await import('node:quic');
|
|
|
|
// listEndpoints is exported as a function.
|
|
strictEqual(typeof listEndpoints, 'function');
|
|
|
|
// Empty when no endpoints have been created.
|
|
deepStrictEqual(listEndpoints(), []);
|
|
deepStrictEqual(listEndpoints({ active: false }), []);
|
|
|
|
// Created endpoints appear in the list.
|
|
{
|
|
const ep1 = new QuicEndpoint();
|
|
const ep2 = new QuicEndpoint();
|
|
|
|
const list = listEndpoints();
|
|
strictEqual(list.length, 2);
|
|
ok(list.includes(ep1));
|
|
ok(list.includes(ep2));
|
|
|
|
// active=false also returns them.
|
|
const all = listEndpoints({ active: false });
|
|
strictEqual(all.length, 2);
|
|
ok(all.includes(ep1));
|
|
ok(all.includes(ep2));
|
|
|
|
// Returns plain QuicEndpoint instances, not wrapped in arrays.
|
|
ok(list[0] instanceof QuicEndpoint);
|
|
ok(list[1] instanceof QuicEndpoint);
|
|
|
|
await ep1.close();
|
|
await ep2.close();
|
|
}
|
|
|
|
// Destroyed endpoints are excluded by active filter.
|
|
{
|
|
const ep = new QuicEndpoint();
|
|
strictEqual(listEndpoints().length, 1);
|
|
|
|
await ep.close();
|
|
await ep.closed;
|
|
strictEqual(ep.destroyed, true);
|
|
|
|
// Default (active=true) excludes destroyed endpoint.
|
|
strictEqual(listEndpoints().length, 0);
|
|
|
|
// active=false still includes it... but destroyed endpoints are removed
|
|
// from the registry entirely in kFinishClose, so it won't appear at all.
|
|
strictEqual(listEndpoints({ active: false }).length, 0);
|
|
}
|
|
|
|
// Busy endpoints are excluded by the active filter.
|
|
{
|
|
const ep = new QuicEndpoint();
|
|
strictEqual(listEndpoints().length, 1);
|
|
|
|
ep.busy = true;
|
|
strictEqual(ep.busy, true);
|
|
|
|
// active=true excludes busy endpoint.
|
|
strictEqual(listEndpoints().length, 0);
|
|
|
|
// active=false includes it.
|
|
const all = listEndpoints({ active: false });
|
|
strictEqual(all.length, 1);
|
|
ok(all.includes(ep));
|
|
|
|
ep.busy = false;
|
|
|
|
// After un-busying, it reappears in the active list.
|
|
strictEqual(listEndpoints().length, 1);
|
|
|
|
await ep.close();
|
|
}
|
|
|
|
// Options validation.
|
|
throws(() => listEndpoints('bad'), {
|
|
code: 'ERR_INVALID_ARG_TYPE',
|
|
});
|
|
throws(() => listEndpoints(null), {
|
|
code: 'ERR_INVALID_ARG_TYPE',
|
|
});
|
|
throws(() => listEndpoints({ active: 'yes' }), {
|
|
code: 'ERR_INVALID_ARG_TYPE',
|
|
});
|
|
throws(() => listEndpoints({ active: 1 }), {
|
|
code: 'ERR_INVALID_ARG_TYPE',
|
|
});
|