Function portsHandler

api/ports.js:43–92

(url, event, context)

}

const portsHandler = async (url, event, context) => {
  const { hostname: domain } = parseTarget(url);

  const delay = (ms) => new Promise((res) => setTimeout(res, ms));
  const timeout = delay(9000);

  const openPorts = [];
  const failedPorts = [];

  const promises = PORTS.map((port) =>
    checkPort(port, domain)
      .then(() => {
        openPorts.push(port);
        return { status: 'fulfilled', port };
      })
      .catch(() => {
        failedPorts.push(port);
        return { status: 'rejected', port };
      }),
  );

  let timeoutReached = false;

  for (const promise of promises) {
    const result = await Promise.race([
      promise,
      timeout.then(() => ({ status: 'timeout', timeout: true })),
    ]);
    if (result.status === 'timeout') {
      timeoutReached = true;
      if (result.timeout) {
        // Add the ports not checked yet to the failedPorts array
        const checkedPorts = [...openPorts, ...failedPorts];
        const portsNotChecked = PORTS.filter((port) => !checkedPorts.includes(port));
        failedPorts.push(...portsNotChecked);
      }
      break;
    }
  }

  if (timeoutReached) {
    return errorResponse('The function timed out before completing.');
  }

  // Sort openPorts and failedPorts before returning
  openPorts.sort((a, b) => a - b);
  failedPorts.sort((a, b) => a - b);

  return { openPorts, failedPorts };
};

const errorResponse = (message, statusCode = 444) => {
  return { error: message };