Function GetPaginatedResult

pkg/github/utils/utils.go:91–166

(
	ctx context.Context,
	globalBackoff *backoff.Backoff,
	callOpts *github.ListOptions,
	githubCall func(opts *github.ListOptions) (K, *github.Response, error),
	aggregator func(K) []T,
)

}

func GetPaginatedResult[T any, K any](
	ctx context.Context,
	globalBackoff *backoff.Backoff,
	callOpts *github.ListOptions,
	githubCall func(opts *github.ListOptions) (K, *github.Response, error),
	aggregator func(K) []T,
) ([]T, error) {

	var results []T
	retries := 0

	var back *backoff.Backoff
	if globalBackoff != nil {
		back = &backoff.Backoff{
			Min:    globalBackoff.Min,
			Max:    globalBackoff.Max,
			Jitter: globalBackoff.Jitter,
		}
	} else {
		back = &backoff.Backoff{
			Min:    30 * time.Second,
			Max:    30 * time.Minute,
			Jitter: true,
		}
	}

	for {
		raw, resp, err := githubCall(callOpts)

		_, ok := err.(*github.RateLimitError)
		if ok || resp == nil {
			d := back.Duration()
			log.Logger.Infof("Hit rate limit, sleeping for %v", d)
			time.Sleep(d)
			if resp == nil {
				retries += 1
				if retries > 10 {
					return results, fmt.Errorf(
						"Aborting after 5 failed retries",
					)
				}
			}
			continue
		}

		retries = 0
		if err != nil && resp != nil {
			if resp.StatusCode == 403 {
				log.Logger.Debugf(
					"It appears the token being used doesn't have access to call %v",
					runtime.FuncForPC(reflect.ValueOf(githubCall).Pointer()).
						Name(),
				)
				log.Logger.Errorf(
					"The token used does not have premissions to make this API call",
				)
			} else {
				log.Logger.Error(err)