node/test/fixtures/proxy-server-worker.js

25 lines
561 B
JavaScript

'use strict';
const { parentPort } = require('worker_threads');
const { createProxyServer } = require('../common/proxy-server');
const { proxy, logs } = createProxyServer();
proxy.listen(0);
proxy.on('listening', () => {
parentPort.postMessage({
type: 'proxy-listening',
port: proxy.address().port,
});
});
parentPort.on('message', (msg) => {
console.log('Received message from main thread:', msg.type);
if (msg.type === 'stop-proxy') {
parentPort.postMessage({
type: 'proxy-stopped',
logs,
});
proxy.close();
}
});