GraphQL Status client for microplane

status.go

const queryStatusCheckRollupState = `query($owner: String!, $name: String!, $oid: GitObjectID) {
  repository(owner: $owner, name: $name) {
    object(oid: $oid) {
      ... on Commit {
        statusCheckRollup {
          state
        }
      }
    }
  }
}`

func getStatusCheckRollupState(ctx context.Context, client *github.Client, input Input) (string, error) {
	gqlPath := client.BaseURL.String() + "graphql"

	gqlReq := map[string]interface{}{
		"query": queryStatusCheckRollupState,
		"variables": map[string]string{
			"owner": input.Repo.Owner,
			"name":  input.Repo.Name,
			"oid":   input.CommitSHA,
		},
	}

	jsonReq, err := json.Marshal(gqlReq)
	if err != nil {
		return "", err
	}

	req, err := http.NewRequest(http.MethodPost, gqlPath, bytes.NewReader(jsonReq))
	if err != nil {
		return "", err
	}

	var result struct {
		Data struct {
			Repository struct {
				Object struct {
					StatusCheckRollup struct {
						State string `json:"state"`
					} `json:"statusCheckRollup"`
				} `json:"object"`
			} `json:"repository"`
		} `json:"data"`
		Errors []struct {
			Message string `json:"message"`
		} `json:"errors"`
	}
	resp, err := client.Do(ctx, req, &result)
	if err != nil {
		return "", err
	}
	defer resp.Body.Close()

	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
		return "", fmt.Errorf("unexpected response code from graphql: %v", resp.StatusCode)
	}

	if numErrors := len(result.Errors); numErrors > 0 {
		msgs := make([]string, numErrors)
		for i := range result.Errors {
			msgs[i] = result.Errors[i].Message
		}

		return "", fmt.Errorf("unexpected errors from graphql: %+q", msgs)
	}

	return result.Data.Repository.Object.StatusCheckRollup.State, nil
}