import assert from 'node:assert';

import { once } from 'events';

import { runProxiedRequest } from '../common/proxy-server.js';

import dgram from 'node:dgram';

import http from 'node:http';

if (!common.hasCrypto)

common.skip('missing crypto');

const serverHost = `localhost:${server.address().port}`;

const requestUrl = `https://${serverHost}/test`;

// Make it fail on connection refused by connecting to a UDP port with TCP.

const udp = dgram.createSocket('udp4');

udp.bind(0, '127.0.0.1');

await once(udp, 'listening');

const port = udp.address().port;

const { code, signal, stderr, stdout } = await runProxiedRequest({

NODE_USE_ENV_PROXY: 1,

REQUEST_URL: requestUrl,

HTTPS_PROXY: `http://localhost:${port}`,

NODE_EXTRA_CA_CERTS: fixtures.path('keys', 'fake-startcom-root-cert.pem'),

});

// The proxy client should get a connection refused error.

assert.match(stderr, /Error.*connect ECONNREFUSED/);

assert.strictEqual(stdout.trim(), '');

assert.strictEqual(code, 0);

assert.strictEqual(signal, null);

let maxRetries = 10;

let foundRefused = false;

while (maxRetries-- > 0) {

// Make it fail on connection refused by connecting to a port of a closed server.

// If it succeeds, get a different port and retry.

const proxy = http.createServer((req, res) => {

res.destroy();

});

proxy.listen(0);

await once(proxy, 'listening');

const port = proxy.address().port;

proxy.close();

await once(proxy, 'close');

console.log(`Trying proxy at port ${port}`);

const { stderr } = await runProxiedRequest({

NODE_USE_ENV_PROXY: 1,

REQUEST_URL: requestUrl,

HTTPS_PROXY: `http://localhost:${port}`,

NODE_EXTRA_CA_CERTS: fixtures.path('keys', 'fake-startcom-root-cert.pem'),

REQUEST_TIMEOUT: 5000,

});

foundRefused = /Error.*connect ECONNREFUSED/.test(stderr);

if (foundRefused) {

// The proxy client should get a connection refused error.

break;

}

}

server.close();

udp.close();

assert(foundRefused, 'Expected ECONNREFUSED error from proxy request');