Function handleCheckProxyRequest

_worker.js:5564–5769

(req)

}

async function handleCheckProxyRequest(req) {
	if (req.method === 'OPTIONS') {
		return new Response(null, {
			status: 204,
			headers: CHECK_RESPONSE_HEADERS,
		});
	}

	if (req.method !== 'GET' && req.method !== 'POST') {
		return checkJsonResponse(
			{ success: false, error: 'method not allowed', usage: USAGE_EXAMPLES },
			405
		);
	}

	try {
		const url = new URL(req.url);
		const pathname = url.pathname.replace(/\/+$/, '') || '/';
		if (pathname !== '/check') {
			return checkJsonResponse(
				{ success: false, error: 'not found', usage: USAGE_EXAMPLES },
				404
			);
		}

		const { searchParams } = url;
		const bodyText = req.method === 'POST' ? await req.text() : '';
		const body = bodyText ? JSON.parse(bodyText) : {};

		const rawCandidates = body.proxyips ?? body.proxyip ?? searchParams.get('proxyip');

		const rawList = Array.isArray(rawCandidates) ? rawCandidates : `${rawCandidates ?? ''}`.split(/[\s,]+/);
		const candidates = [...new Set(rawList.map((item) => `${item ?? ''}`.trim()).filter(Boolean))];
		const timeoutMs = parsePositiveInt(body.timeoutMs ?? searchParams.get('timeoutMs'), DEFAULT_TIMEOUT_MS);
		const readLimit = parsePositiveInt(body.readLimit ?? searchParams.get('readLimit'), DEFAULT_READ_LIMIT);

		if (!candidates.length) {
			return checkJsonResponse(
				{ success: false, error: 'missing proxyip', usage: USAGE_EXAMPLES },
				400
			);
		}

		const results = await Promise.all(
			candidates.map(async (rawCandidate) => {
				const defaultPort = 443;
				let candidate;
				if (rawCandidate.startsWith('[')) {
					const match = rawCandidate.match(/^\[([^\]]+)\](?::(\d+))?$/);
					if (!match) throw new Error(`invalid IPv6 candidate: ${rawCandidate}`);
					candidate = { raw: rawCandidate, hostname: match[1], port: Number(match[2]) || defaultPort };
				} else {
					const [, hostname = rawCandidate, port] = rawCandidate.match(/^([^:]+):(\d+)$/) ?? [];
					candidate = { raw: rawCandidate, hostname, port: Number(port) || defaultPort };
				}

				const probeResults = await Promise.all(
					PROBE_TARGETS.map(async (target) => {