56 lines
1.3 KiB
JavaScript
56 lines
1.3 KiB
JavaScript
'use strict';
|
|
const EventEmitter = require('node:events');
|
|
const WrapHandler = require('../handler/wrap-handler');
|
|
|
|
const wrapInterceptor = (dispatch) => (opts, handler) =>
|
|
dispatch(opts, WrapHandler.wrap(handler));
|
|
|
|
class Dispatcher extends EventEmitter {
|
|
dispatch() {
|
|
throw new Error('not implemented');
|
|
}
|
|
|
|
close() {
|
|
throw new Error('not implemented');
|
|
}
|
|
|
|
destroy() {
|
|
throw new Error('not implemented');
|
|
}
|
|
|
|
compose(...args) {
|
|
// So we handle [interceptor1, interceptor2] or interceptor1, interceptor2, ...
|
|
const interceptors = Array.isArray(args[0]) ? args[0] : args;
|
|
let dispatch = this.dispatch.bind(this);
|
|
|
|
for (const interceptor of interceptors) {
|
|
if (interceptor == null) {
|
|
continue;
|
|
}
|
|
|
|
if (typeof interceptor !== 'function') {
|
|
throw new TypeError(
|
|
`invalid interceptor, expected function received ${typeof interceptor}`
|
|
);
|
|
}
|
|
|
|
dispatch = interceptor(dispatch);
|
|
dispatch = wrapInterceptor(dispatch);
|
|
|
|
if (
|
|
dispatch == null ||
|
|
typeof dispatch !== 'function' ||
|
|
dispatch.length !== 2
|
|
) {
|
|
throw new TypeError('invalid interceptor');
|
|
}
|
|
}
|
|
|
|
return new Proxy(this, {
|
|
get: (target, key) => (key === 'dispatch' ? dispatch : target[key]),
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = Dispatcher;
|