Method fetchRequiredChecksStatus

github/githubclient/client.go:663–771

fetchRequiredChecksStatus makes a single batched GraphQL query to fetch individual check contexts for all given pull requests. It evaluates only the checks listed in config.Repo.RequiredChecks and returns a map from PR number to the computed status.

(ctx context.Context, pullRequests []*github.PullRequest)

// the checks listed in config.Repo.RequiredChecks and returns a map from
// PR number to the computed status.
func (c *client) fetchRequiredChecksStatus(ctx context.Context, pullRequests []*github.PullRequest) map[int]github.CheckStatus {
	if len(pullRequests) == 0 {
		return nil
	}

	if c.config.User.LogGitHubCalls {
		fmt.Printf("> github fetch required check status\n")
	}

	// Build a single GraphQL query with one aliased field per PR.
	var queryBuilder strings.Builder
	queryBuilder.WriteString("query {")
	for _, pr := range pullRequests {
		fmt.Fprintf(&queryBuilder, `
  pr_%d: node(id: %q) {
    ... on PullRequest {
      number
      commits(last: 1) {
        nodes {
          commit {
            statusCheckRollup {
              contexts(first: 100) {
                nodes {
                  __typename
                  ... on CheckRun {
                    name
                    conclusion
                    status
                  }
                  ... on StatusContext {
                    context
                    state
                  }
                }
              }
            }
          }
        }
      }
    }
  }`, pr.Number, pr.ID)
	}
	queryBuilder.WriteString("\n}")

	reqBody, err := json.Marshal(graphqlRequest{
		Query: queryBuilder.String(),
	})
	if err != nil {
		log.Warn().Err(err).Msg("failed to marshal required checks query")
		return nil
	}

	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, c.graphqlEndpoint, bytes.NewReader(reqBody))
	if err != nil {
		log.Warn().Err(err).Msg("failed to create required checks request")
		return nil
	}
	httpReq.Header.Set("Content-Type", "application/json; charset=utf-8")