const { default: fetch } = require('node-fetch');

async function clearWorkflowRuns() {
  const runs = await getWorkflowRuns();
  const basePath = getActionsBasePath();
  await Promise.all(runs.map((run) => api(`${basePath}/runs/${run.id}`, { method: 'DELETE' })));
}
exports.clearWorkflowRuns = clearWorkflowRuns;

async function getMostRecentWorkflowRun() {
  const runs = await getWorkflowRuns();
  if (runs.length === 0) {
    return null;
  }
  const mostRecentRun = runs.reduce((previous, current) => {
    const prevDate = new Date(previous.created_at);
    const currDate = new Date(current.created_at);
    if (prevDate < currDate) {
      return current;
    } else {
      return previous;
    }
  });
  return mostRecentRun;
}
exports.getMostRecentWorkflowRun = getMostRecentWorkflowRun;

async function getWorkflowRun(id) {
  const basePath = getActionsBasePath();
  const run = await api(`${basePath}/runs/${id}`);
  return run;
}
exports.getWorkflowRun = getWorkflowRun;

async function getWorkflowRuns() {
  const basePath = getActionsBasePath();
  const result = await api(`${basePath}/runs`);
  return result.workflow_runs || [];
}

function getActionsBasePath() {
  const repoUrl = process.env.TEST_REPO;
  const match = /\/([^/]*)\/([^/]*)\.git$/.exec(repoUrl);
  const owner = match[1];
  const repo = match[2];
  return `repos/${owner}/${repo}/actions`;
}

const retryAttempts = 10;
const retryInterval = 10;

async function api(path, options) {
  options = options || {};
  const username = process.env.TEST_USER;
  const token = process.env.TEST_TOKEN;
  for (let attempts = 0; attempts < retryAttempts; attempts++) {
    const response = await fetch(`https://api.github.com/${path}`, {
      method: options.method || 'GET',
      headers: {
        Authorization: `Basic ${Buffer.from(`${username}:${token}`, 'ascii').toString('base64')}`,
        accept: 'application/vnd.github.v3+json',
        'User-Agent': username,
        ...options.headers,
      },
    });
    if (response.ok) {
      const responseText = await response.text();
      if (responseText.length > 0) {
        return JSON.parse(responseText);
      } else {
        return;
      }
    } else if (response.status === 404) {
      console.log(
        `Received a 404 error while executing request at ${path}. Waiting ${retryInterval} seconds and retrying...`,
      );
      await new Promise((resolve) => setTimeout(resolve, retryInterval * 1000));
    } else {
      throw new Error(`${response.status} ${response.statusText}`);
    }
  }
  throw new Error(
    `Received ${retryAttempts} 404 errors in a row while executing request at ${path} in ${retryInterval}-second intervals.`,
  );
}