cb78a7f484PR-URL: https://github.com/nodejs/node/pull/61680 Reviewed-By: James M Snell <jasnell@gmail.com>
66 lines
2 KiB
JavaScript
66 lines
2 KiB
JavaScript
'use strict';
|
|
const common = require('../common');
|
|
const assert = require('node:assert');
|
|
const dc = require('node:diagnostics_channel');
|
|
const { AsyncLocalStorage } = require('node:async_hooks');
|
|
|
|
// Test BoundedChannelScope with transform error
|
|
// Transform errors are scheduled via process.nextTick(triggerUncaughtException)
|
|
|
|
const boundedChannel = dc.boundedChannel('test-transform-error');
|
|
const store = new AsyncLocalStorage();
|
|
const events = [];
|
|
|
|
const transformError = new Error('transform failed');
|
|
|
|
// Set up uncaughtException handler to catch the transform error
|
|
process.on('uncaughtException', common.mustCall((err) => {
|
|
assert.strictEqual(err, transformError);
|
|
events.push('uncaughtException');
|
|
}));
|
|
|
|
boundedChannel.subscribe({
|
|
start(message) {
|
|
events.push({ type: 'start', data: message });
|
|
},
|
|
end(message) {
|
|
events.push({ type: 'end', data: message });
|
|
},
|
|
});
|
|
|
|
// Bind store with a transform that throws
|
|
boundedChannel.start.bindStore(store, () => {
|
|
throw transformError;
|
|
});
|
|
|
|
// Store should remain undefined since transform will fail
|
|
assert.strictEqual(store.getStore(), undefined);
|
|
|
|
const context = { id: 123 };
|
|
{
|
|
// eslint-disable-next-line no-unused-vars
|
|
using scope = boundedChannel.withScope(context);
|
|
|
|
// Store should still be undefined because transform threw
|
|
assert.strictEqual(store.getStore(), undefined);
|
|
|
|
events.push('inside-scope');
|
|
context.result = 42;
|
|
}
|
|
|
|
// Store should still be undefined after scope exit
|
|
assert.strictEqual(store.getStore(), undefined);
|
|
|
|
// Start and end events should still be published despite transform error
|
|
assert.strictEqual(events.length, 3);
|
|
assert.strictEqual(events[0].type, 'start');
|
|
assert.strictEqual(events[0].data.id, 123);
|
|
assert.strictEqual(events[1], 'inside-scope');
|
|
assert.strictEqual(events[2].type, 'end');
|
|
assert.strictEqual(events[2].data.result, 42);
|
|
|
|
// Validate uncaughtException was triggered via nextTick
|
|
process.on('beforeExit', common.mustCall(() => {
|
|
assert.strictEqual(events.length, 4);
|
|
assert.strictEqual(events[3], 'uncaughtException');
|
|
}));
|