const { defineConfig } = require('cypress')
const net = require('net')
const http = require('http')
const https = require('https')

const DEFAULT_DB_HOST = process.env.CYPRESS_DB_HOST ?? process.env.MARIADB_HOST ?? '127.0.0.1'
const DEFAULT_DB_PORT = Number(process.env.CYPRESS_DB_PORT ?? process.env.MARIADB_PORT ?? 3306)
const DEFAULT_DB_WAIT_TIMEOUT_MS = Number(process.env.CYPRESS_DB_WAIT_TIMEOUT ?? 30_000)
const DEFAULT_APP_BASE_URL = process.env.CYPRESS_baseUrl ?? 'http://localhost:5173/'
const DEFAULT_APP_WAIT_TIMEOUT_MS = Number(process.env.CYPRESS_APP_WAIT_TIMEOUT ?? 60_000)

const RETRY_DELAY_MS = 1_000
const SOCKET_TIMEOUT_MS = 2_000

/**
 * @param {{ host?: string; port?: number; timeoutMs?: number }} [options]
 * @param {{ dbHost?: string; dbPort?: number; dbWaitTimeoutMs?: number }} [env]
 */
async function waitForDatabase(options = {}, env = {}) {
  const host = options.host ?? env.dbHost ?? DEFAULT_DB_HOST
  const port = Number(options.port ?? env.dbPort ?? DEFAULT_DB_PORT)
  const timeoutMs = Number(options.timeoutMs ?? env.dbWaitTimeoutMs ?? DEFAULT_DB_WAIT_TIMEOUT_MS)

  if (!Number.isFinite(port)) {
    throw new Error(`Invalid database port provided for waitForDbHealthy: ${port}`)
  }

  const deadline = Date.now() + timeoutMs

  return new Promise((resolve, reject) => {
    const attemptConnection = () => {
      const socket = net.createConnection({ host, port })

      const cleanup = () => {
        socket.removeAllListeners()
      }

      const scheduleRetry = error => {
        cleanup()
        socket.destroy()

        if (Date.now() >= deadline) {
          reject(new Error(`Timed out waiting for MariaDB at ${host}:${port} (${error.message})`))
          return
        }

        setTimeout(attemptConnection, RETRY_DELAY_MS)
      }

      socket.once('connect', () => {
        cleanup()
        socket.end()
        resolve(null)
      })

      socket.once('error', scheduleRetry)
      socket.setTimeout(SOCKET_TIMEOUT_MS, () => {
        scheduleRetry(new Error('Connection attempt timed out'))
      })
    }

    attemptConnection()
  })
}

/**
 * @param {{ url?: string; timeoutMs?: number }} [options]
 * @param {{ appBaseUrl?: string; appWaitTimeoutMs?: number }} [env]
 */
async function waitForHttpUrl(options = {}, env = {}) {
  const url = options.url ?? env.appBaseUrl ?? DEFAULT_APP_BASE_URL
  const timeoutMs = Number(options.timeoutMs ?? env.appWaitTimeoutMs ?? DEFAULT_APP_WAIT_TIMEOUT_MS)
  const parsedUrl = new URL(url)
  const client = parsedUrl.protocol === 'https:' ? https : http
  const deadline = Date.now() + timeoutMs

  return new Promise((resolve, reject) => {
    const attemptRequest = () => {
      const request = client.request(
        parsedUrl,
        { method: 'GET', timeout: SOCKET_TIMEOUT_MS },
        response => {
          response.resume()

          if (response.statusCode && response.statusCode < 500) {
            resolve(null)
            return
          }

          if (Date.now() >= deadline) {
            reject(new Error(`Timed out waiting for app at ${url} (status ${response.statusCode ?? 'unknown'})`))
            return
          }

          setTimeout(attemptRequest, RETRY_DELAY_MS)
        }
      )

      const retry = error => {
        request.destroy()

        if (Date.now() >= deadline) {
          reject(new Error(`Timed out waiting for app at ${url} (${error.message})`))
          return
        }

        setTimeout(attemptRequest, RETRY_DELAY_MS)
      }

      request.on('error', retry)
      request.on('timeout', () => {
        retry(new Error('Connection attempt timed out'))
      })
      request.end()
    }

    attemptRequest()
  })
}

module.exports = defineConfig({
  e2e: {
    setupNodeEvents(on, config) {
      require('@cypress/code-coverage/task')(on, config)

      on('task', {
        waitForDbHealthy(options) {
          return waitForDatabase(options, config.env)
        },
        waitForAppHealthy(options) {
          return waitForHttpUrl(options, {
            ...config.env,
            appBaseUrl: config.baseUrl,
          })
        },
      })

      // It's IMPORTANT to return the config object
      // with any changed environment variables
      return config
    },
    baseUrl: 'http://localhost:5173/',
    specPattern: ['cypress/e2e/**/*.cy.{js,jsx,ts,tsx}', 'cypress/e2e/**/*.spec.{js,jsx,ts,tsx}'],
    // Performance optimizations
    experimentalMemoryManagement: true,
    numTestsKeptInMemory: 0,
    defaultCommandTimeout: 8000,
    requestTimeout: 8000,
    responseTimeout: 8000,
  },
  env: {
    databaseResetUrl: 'http://localhost:4000/test/reset-test-database',
    dbHost: DEFAULT_DB_HOST,
    dbPort: DEFAULT_DB_PORT,
    dbWaitTimeoutMs: DEFAULT_DB_WAIT_TIMEOUT_MS,
    appBaseUrl: DEFAULT_APP_BASE_URL,
    appWaitTimeoutMs: DEFAULT_APP_WAIT_TIMEOUT_MS,
  },
  viewportHeight: 900,
  viewportWidth: 1200,
})