src/workflows/projects.ts

// eslint-disable-next-line import/no-extraneous-dependencies
import { graphql } from '@octokit/graphql'

// Shared functions for managing projects (memex)

// Pull out the node ID of a project field
export function findFieldID(fieldName: string, data: Record<string, any>) {
  const field = data.organization.projectV2.fields.nodes.find(
    (fieldNode: Record<string, any>) => fieldNode.name === fieldName,
  )

  if (field && field.id) {
    return field.id
  } else {
    throw new Error(`A field called "${fieldName}" was not found. Check if the field was renamed.`)
  }
}

// Pull out the node ID of a single select field value
export function findSingleSelectID(
  singleSelectName: string,
  fieldName: string,
  data: Record<string, any>,
) {
  const field = data.organization.projectV2.fields.nodes.find(
    (fieldData: Record<string, any>) => fieldData.name === fieldName,
  )
  if (!field) {
    throw new Error(`A field called "${fieldName}" was not found. Check if the field was renamed.`)
  }

  const singleSelect = field.options.find(
    (option: Record<string, any>) => option.name === singleSelectName,
  )

  if (singleSelect && singleSelect.id) {
    return singleSelect.id
  } else {
    throw new Error(
      `A single select called "${singleSelectName}" for the field "${fieldName}" was not found. Check if the single select was renamed.`,
    )
  }
}

// Given a list of PR/issue node IDs and a project node ID,
// adds the PRs/issues to the project
// and returns the node IDs of the project items
export async function addItemsToProject(items: string[], project: string) {
  console.log(`Adding ${items} to project ${project}`)

  const mutations = items.map(
    (item, index) => `
    item_${index}: addProjectV2ItemById(input: {
      projectId: $project
      contentId: "${item}"
    }) {
      item {
        id
      }
    }
    `,
  )

  const mutation = `
  mutation($project:ID!) {
    ${mutations.join(' ')}
  }
  `

  const newItems: Record<string, any> = await graphql(mutation, {
    project,
    headers: {
      authorization: `token ${process.env.TOKEN}`,
    },
  })

  // The output of the mutation is
  // {"item_0":{"projectNextItem":{"id":ID!}},...}
  // Pull out the ID for each new item

  const newItemIDs = Object.entries(newItems).map((item) => item[1].item.id)

  return newItemIDs
}

export async function addItemToProject(item: string, project: string) {
  const newItemIDs = await addItemsToProject([item], project)

  const newItemID = newItemIDs[0]

  return newItemID
}

// Given a GitHub login, returns a bool indicating
// whether the login is part of the docs team
export async function isDocsTeamMember(login: string) {
  // Returns true if login is docs-bot or copilot, to bypass the checks and make PRs opened by docs-bot or copilot be treated as though they were made by a docs team member
  if (login === 'docs-bot' || login === 'copilot') {
    return true
  }
  // Get all members of the docs team
  const data: Record<string, any> = await graphql(
    `
      query {
        organization(login: "github") {
          team(slug: "docs") {
            members {
              nodes {
                login
              }
            }
          }
        }
      }
    `,
    {
      headers: {
        authorization: `token ${process.env.TOKEN}`,
      },
    },
  )

  const teamMembers = data.organization.team.members.nodes.map(
    (entry: Record<string, any>) => entry.login,
  )

  return teamMembers.includes(login)
}

// Given a GitHub login, returns a bool indicating
// whether the login is part of the GitHub org
export async function isGitHubOrgMember(login: string) {
  const data: Record<string, any> = await graphql(
    `
      query {
        user(login: "${login}") {
          organization(login: "github"){
            name
          }
        }
      }
    `,
    {
      headers: {
        authorization: `token ${process.env.TOKEN}`,
      },
    },
  )

  return Boolean(data.user.organization)
}

// Formats a date object into the required format for projects
export function formatDateForProject(date: Date) {
  return date.toISOString()
}

// Given a date object and optional turnaround time
// Calculate the date {turnaround} business days from now
// (excluding weekends; not considering holidays)
export function calculateDueDate(datePosted: Date, turnaround = 2) {
  let daysUntilDue
  switch (datePosted.getDay()) {
    case 4: // Thursday
      daysUntilDue = turnaround + 2
      break
    case 5: // Friday
      daysUntilDue = turnaround + 2
      break
    case 6: // Saturday
      daysUntilDue = turnaround + 1
      break
    default:
      daysUntilDue = turnaround
  }
  const millisecPerDay = 24 * 60 * 60 * 1000
  const dueDate = new Date(datePosted.getTime() + millisecPerDay * daysUntilDue)
  return dueDate
}

// Given a project item node ID and author login
// generates a GraphQL mutation to populate:
//   - "Status" (as variable passed with the request)
//   - "Date posted" (as today)
//   - "Review due date" (as today + {turnaround} weekdays)
//   - "Contributor type" (as variable passed with the request)
//   - "Feature" (as {feature})
//   - "Author" (as {author})"
export function generateUpdateProjectV2ItemFieldMutation({
  item,
  author,
  turnaround = 2,
  feature = '',
}: {
  item: string
  author: string
  turnaround?: number
  feature?: string
}) {
  const datePosted = new Date()
  const dueDate = calculateDueDate(datePosted, turnaround)

  // Build the mutation to update a single project field
  // Specify literal=true to indicate that the value should be used as a string, not a variable
  function generateMutationToUpdateField({
    item: itemId,
    fieldID,
    value,
    fieldType,
    literal = false,
  }: {
    item: string
    fieldID: string
    value: string
    fieldType: string
    literal?: boolean
  }) {
    const parsedValue = literal ? `${fieldType}: "${value}"` : `${fieldType}: ${value}`

    // Strip all non-alphanumeric out of the item ID when creating the mutation ID to avoid a GraphQL parsing error
    // (statistically, this should still give us a unique mutation ID)
    return `
      set_${fieldID.slice(1)}_item_${itemId.replaceAll(
        /[^a-z0-9]/g,
        '',
      )}: updateProjectV2ItemFieldValue(input: {
        projectId: $project
        itemId: "${itemId}"
        fieldId: ${fieldID}
        value: { ${parsedValue} }
      }) {
      projectV2Item {
        id
      }
    }
    `
  }

  const mutation = `
    mutation(
      $project: ID!
      $statusID: ID!
      $statusValueID: String!
      $datePostedID: ID!
      $reviewDueDateID: ID!
      $contributorTypeID: ID!
      $contributorType: String!
      $sizeTypeID: ID!
      $sizeType: String!
      $featureID: ID!
      $authorID: ID!
    ) {
      ${generateMutationToUpdateField({
        item,
        fieldID: '$statusID',
        value: '$statusValueID',
        fieldType: 'singleSelectOptionId',
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$datePostedID',
        value: formatDateForProject(datePosted),
        fieldType: 'date',
        literal: true,
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$reviewDueDateID',
        value: formatDateForProject(dueDate),
        fieldType: 'date',
        literal: true,
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$contributorTypeID',
        value: '$contributorType',
        fieldType: 'singleSelectOptionId',
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$sizeTypeID',
        value: '$sizeType',
        fieldType: 'singleSelectOptionId',
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$featureID',
        value: feature,
        fieldType: 'text',
        literal: true,
      })}
      ${generateMutationToUpdateField({
        item,
        fieldID: '$authorID',
        value: author,
        fieldType: 'text',
        literal: true,
      })}
      }
    `

  return mutation
}

// Guess the affected docs sets based on the files that the PR changed
export function getFeature(data: Record<string, any>) {
  // For issues, just use an empty string
  if (data.item.__typename !== 'PullRequest') {
    return ''
  }

  const paths = data.item.files.nodes.map((node: Record<string, any>) => node.path)

  // For docs and docs-internal and docs-early-access PRs,
  // determine the affected docs sets by looking at which
  // directories under `content/` were affected.
  // (Ignores changes to the data files.)
  if (
    process.env.REPO === 'github/docs-internal' ||
    process.env.REPO === 'github/docs' ||
    process.env.REPO === 'github/docs-early-access'
  ) {
    const features: Set<string> = new Set([])
    for (const path of paths as string[]) {
      const pathComponents = path.split('/')
      if (pathComponents[0] === 'content') {
        features.add(pathComponents[1])
      }
    }
    const feature = Array.from(features).join()

    return feature
  }

  // for github/github PRs, try to classify the OpenAPI files
  if (process.env.REPO === 'github/github') {
    const features: Set<string> = new Set([])
    if (paths.some((path: string) => path.startsWith('app/api/description'))) {
      features.add('OpenAPI')
      for (const path of paths as string[]) {
        if (path.startsWith('app/api/description/operations')) {
          features.add(path.split('/')[4])
          features.add('rest')
        }
        if (path.startsWith('app/api/description/webhooks')) {
          features.add(path.split('/')[4])
          features.add('webhooks')
        }
        if (path.startsWith('app/api/description/components/schemas/webhooks')) {
          features.add('webhooks')
        }
      }
    }

    const feature = Array.from(features).join()

    return feature
  }

  if (process.env.REPO === 'github/docs-strategy') {
    return 'CD plan'
  }

  return ''
}

// Guess the size of an item
export function getSize(data: Record<string, any>) {
  // We need to set something in case this is an issue, so just guesstimate small
  if (data.item.__typename !== 'PullRequest') {
    return 'S'
  }

  // for github/github PRs, estimate the size based on the number of OpenAPI files that were changed
  if (process.env.REPO === 'github/github') {
    let numFiles = 0
    let numChanges = 0
    for (const node of data.item.files.nodes as Record<string, any>[]) {
      if (node.path.startsWith('app/api/description')) {
        numFiles += 1
        numChanges += node.additions
        numChanges += node.deletions
      }
    }
    if (numFiles < 5 && numChanges < 10) {
      return 'XS'
    } else if (numFiles < 10 && numChanges < 50) {
      return 'S'
    } else if (numFiles < 10 && numChanges < 250) {
      return 'M'
    } else {
      return 'L'
    }
  } else {
    // Otherwise, estimated the size based on all files
    let numFiles = 0
    let numChanges = 0
    for (const node of data.item.files.nodes as Record<string, any>[]) {
      numFiles += 1
      numChanges += node.additions
      numChanges += node.deletions
    }
    if (numFiles < 5 && numChanges < 10) {
      return 'XS'
    } else if (numFiles < 10 && numChanges < 50) {
      return 'S'
    } else if (numFiles < 10 && numChanges < 250) {
      return 'M'
    } else {
      return 'L'
    }
  }
}

export default {
  addItemsToProject,
  addItemToProject,
  isDocsTeamMember,
  isGitHubOrgMember,
  findFieldID,
  findSingleSelectID,
  formatDateForProject,
  calculateDueDate,
  generateUpdateProjectV2ItemFieldMutation,
  getFeature,
  getSize,
}