index.js

const core = require('@actions/core')
const github = require('@actions/github')
const axios = require('axios')

const READY_STATES = ['ready', 'current']

function getNetlifyUrl(url) {
  return axios.get(url, {
    headers: {
      Authorization: `Bearer ${process.env.NETLIFY_TOKEN}`,
    },
  })
}

const waitForDeployCreation = (url, commitSha, MAX_TIMEOUT, context) => {
  const increment = 15

  return new Promise((resolve, reject) => {
    let elapsedTimeSeconds = 0

    const handle = setInterval(async () => {
      elapsedTimeSeconds += increment

      if (elapsedTimeSeconds >= MAX_TIMEOUT) {
        clearInterval(handle)

        return reject(
          `Timeout reached: Deployment was not created within ${MAX_TIMEOUT} seconds.`,
        )
      }

      const { data: netlifyDeployments } = await getNetlifyUrl(url)

      if (!netlifyDeployments) {
        return reject(`Failed to get deployments for site`)
      }

      const commitDeployment = netlifyDeployments.find(
        (d) =>
          d.commit_ref === commitSha && (!context || d.context === context),
      )

      if (commitDeployment) {
        clearInterval(handle)

        return resolve(commitDeployment)
      }

      console.log(`Not yet created, waiting ${increment} more seconds...`)
    }, increment * 1000)
  })
}

const waitForReadiness = (url, MAX_TIMEOUT) => {
  const increment = 30

  return new Promise((resolve, reject) => {
    let elapsedTimeSeconds = 0
    let state

    const handle = setInterval(async () => {
      elapsedTimeSeconds += increment

      if (elapsedTimeSeconds >= MAX_TIMEOUT) {
        clearInterval(handle)

        return reject(
          `Timeout reached: Deployment was not ready within ${MAX_TIMEOUT} seconds. Last known deployment state: ${state}.`,
        )
      }

      const { data: deploy } = await getNetlifyUrl(url)

      state = deploy.state

      if (READY_STATES.includes(state)) {
        clearInterval(handle)

        return resolve()
      }

      console.log(`Not yet ready, waiting ${increment} more seconds...`)
    }, increment * 1000)
  })
}

const waitForUrl = async (url, MAX_TIMEOUT) => {
  const iterations = MAX_TIMEOUT / 3
  for (let i = 0; i < iterations; i++) {
    try {
      await axios.get(url)

      return
    } catch (e) {
      console.log(`URL ${url} unavailable, retrying...`)
      await new Promise((r) => setTimeout(r, 3000))
    }
  }
  core.setFailed(`Timeout reached: Unable to connect to ${url}`)
}

const run = async () => {
  try {
    const netlifyToken = process.env.NETLIFY_TOKEN
    const commitSha =
      github.context.eventName === 'pull_request'
        ? github.context.payload.pull_request.head.sha
        : github.context.sha

    const DEPLOY_TIMEOUT = Number(core.getInput('deploy_timeout')) || 60 * 5
    const READINESS_TIMEOUT =
      Number(core.getInput('readiness_timeout')) || 60 * 15
    // keep max_timeout for backwards compatibility
    const RESPONSE_TIMEOUT =
      Number(core.getInput('response_timeout')) ||
      Number(core.getInput('max_timeout')) ||
      60
    const siteId = core.getInput('site_id')
    const context = core.getInput('context')

    if (!netlifyToken) {
      core.setFailed(
        'Please set NETLIFY_TOKEN env variable to your Netlify Personal Access Token secret',
      )
    }
    if (!commitSha) {
      core.setFailed('Could not determine GitHub commit')
    }
    if (!siteId) {
      core.setFailed('Required field `site_id` was not provided')
    }

    let message = `Waiting for Netlify to create a deployment for git SHA ${commitSha}`

    if (context) {
      message += ` and context ${context}`
    }

    console.log(message)
    const commitDeployment = await waitForDeployCreation(
      `https://api.netlify.com/api/v1/sites/${siteId}/deploys`,
      commitSha,
      DEPLOY_TIMEOUT,
      context,
    )

    const url = `https://${commitDeployment.id}--${commitDeployment.name}.netlify.app`

    core.setOutput('deploy_id', commitDeployment.id)
    core.setOutput('url', url)

    console.log(
      `Waiting for Netlify deployment ${commitDeployment.id} in site ${commitDeployment.name} to be ready`,
    )
    await waitForReadiness(
      `https://api.netlify.com/api/v1/sites/${siteId}/deploys/${commitDeployment.id}`,
      READINESS_TIMEOUT,
    )

    console.log(`Waiting for a 200 from: ${url}`)
    await waitForUrl(url, RESPONSE_TIMEOUT)
  } catch (error) {
    core.setFailed(typeof error === 'string' ? error : error.message)
  }
}

run()