cf91d181fb
Signed-off-by: James M Snell <jasnell@gmail.com> Assisted-by: Opencode:Opus 4.6 PR-URL: https://github.com/nodejs/node/pull/62876 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Filip Skokan <panva.ip@gmail.com> Reviewed-By: Paolo Insogna <paolo@cowtech.it> Reviewed-By: Robert Nagy <ronagy@icloud.com>
67 lines
2.1 KiB
JavaScript
67 lines
2.1 KiB
JavaScript
// Flags: --experimental-quic --no-warnings
|
|
|
|
// Test: toJSON() and inspect() on stats objects.
|
|
// Verifies that stats objects from endpoints and sessions
|
|
// support toJSON() and util.inspect().
|
|
|
|
import { hasQuic, skip, mustCall } from '../common/index.mjs';
|
|
import assert from 'node:assert';
|
|
import { inspect } from 'node:util';
|
|
|
|
const { ok, strictEqual } = assert;
|
|
|
|
if (!hasQuic) {
|
|
skip('QUIC is not enabled');
|
|
}
|
|
|
|
const { listen, connect } = await import('../common/quic.mjs');
|
|
|
|
const serverDone = Promise.withResolvers();
|
|
|
|
const serverEndpoint = await listen(mustCall((serverSession) => {
|
|
// Session stats toJSON and inspect.
|
|
const sessionStatsJson = serverSession.stats.toJSON();
|
|
ok(sessionStatsJson);
|
|
strictEqual(typeof sessionStatsJson.createdAt, 'string');
|
|
strictEqual(typeof sessionStatsJson.bytesSent, 'string');
|
|
|
|
const sessionStatsInspect = inspect(serverSession.stats);
|
|
ok(sessionStatsInspect.includes('QuicSessionStats'));
|
|
|
|
serverSession.onstream = mustCall(async (stream) => {
|
|
for await (const _ of stream) { /* drain */ } // eslint-disable-line no-unused-vars
|
|
stream.writer.endSync();
|
|
await stream.closed;
|
|
serverSession.close();
|
|
serverDone.resolve();
|
|
});
|
|
}));
|
|
|
|
// Endpoint stats toJSON and inspect.
|
|
const endpointStatsJson = serverEndpoint.stats.toJSON();
|
|
ok(endpointStatsJson);
|
|
strictEqual(typeof endpointStatsJson.createdAt, 'string');
|
|
|
|
const endpointStatsInspect = inspect(serverEndpoint.stats);
|
|
ok(endpointStatsInspect.includes('QuicEndpointStats'));
|
|
|
|
const clientSession = await connect(serverEndpoint.address);
|
|
await clientSession.opened;
|
|
|
|
// Client session stats.
|
|
const clientStatsJson = clientSession.stats.toJSON();
|
|
ok(clientStatsJson);
|
|
strictEqual(typeof clientStatsJson.createdAt, 'string');
|
|
|
|
const clientStatsInspect = inspect(clientSession.stats);
|
|
ok(clientStatsInspect.includes('QuicSessionStats'));
|
|
|
|
const stream = await clientSession.createBidirectionalStream({
|
|
body: new TextEncoder().encode('test'),
|
|
});
|
|
for await (const _ of stream) { /* drain */ } // eslint-disable-line no-unused-vars
|
|
|
|
await Promise.all([stream.closed, serverDone.promise]);
|
|
|
|
await clientSession.closed;
|
|
await serverEndpoint.close();
|