Function GetJobs

pkg/cmd/run/shared/shared.go:487–520

(client *api.Client, repo ghrepo.Interface, runID int64, jobsURL safeurl.SafeURL, attempt uint64)

}

func GetJobs(client *api.Client, repo ghrepo.Interface, runID int64, jobsURL safeurl.SafeURL, attempt uint64) ([]Job, error) {
	var jobsPath safeurl.SafeURL
	if attempt > 0 {
		p, err := safeurl.JoinPath("repos", repo.RepoOwner(), repo.RepoName(), "actions", "runs", strconv.FormatInt(runID, 10), "attempts", strconv.FormatUint(attempt, 10), "jobs")
		if err != nil {
			return nil, err
		}
		p.SetQuery("per_page", "100")
		jobsPath = p
	} else {
		u, err := url.Parse(jobsURL.String())
		if err != nil {
			return nil, err
		}
		query := url.Values{}
		query.Set("per_page", "100")
		u.RawQuery = query.Encode()
		// Since u is derived from jobsURL, an already-trusted safeurl.SafeURL, the resulting URL is safe to declare as such.
		jobsPath = safeurl.NewImmutableSafeURL(u.String())
	}

	// A non-nil empty slice is returned so callers can tell that jobs were fetched and there are none (if len is zero).
	jobs := []Job{}
	for jobsPath.String() != "" {
		var resp JobsPayload
		next, err := client.RESTWithNext(repo.RepoHost(), http.MethodGet, jobsPath.String(), nil, &resp)
		if err != nil {
			return nil, err
		}
		jobs = append(jobs, resp.Jobs...)
		jobsPath = safeurl.NewImmutableSafeURL(next)
	}
	return jobs, nil
}

func GetJob(client *api.Client, repo ghrepo.Interface, jobID string) (*Job, error) {
	path, err := safeurl.JoinPath("repos", repo.RepoOwner(), repo.RepoName(), "actions", "jobs", jobID)