Function createFork

cmd/patch2pr/main.go:366–410

(ctx context.Context, client *github.Client, fork, parent patch2pr.Repository, isUserFork bool)

}

func createFork(ctx context.Context, client *github.Client, fork, parent patch2pr.Repository, isUserFork bool) error {
	const (
		initDelay = 1 * time.Second
		maxDelay  = 30 * time.Second
		maxWait   = 5 * time.Minute
	)

	organization := fork.Owner
	if isUserFork {
		organization = ""
	}

	repo, _, err := client.Repositories.CreateFork(ctx, parent.Owner, parent.Name, &github.RepositoryCreateForkOptions{
		Organization:      organization,
		Name:              fork.Name,
		DefaultBranchOnly: true,
	})

	var aerr *github.AcceptedError
	if err != nil && !errors.As(err, &aerr) {
		return err
	}
	if repo.GetFullName() != fork.String() {
		return fmt.Errorf("fork of %q already exists at %q, cannot create %q", parent, repo.GetFullName(), fork)
	}

	for delay, start := initDelay, time.Now(); time.Since(start) < maxWait; delay *= 2 {
		if delay > maxDelay {
			delay = maxDelay
		}
		time.Sleep(delay)

		if _, _, err := client.Repositories.ListCommits(ctx, fork.Owner, fork.Name, &github.CommitsListOptions{
			ListOptions: github.ListOptions{
				PerPage: 1,
			},
		}); err == nil {
			return nil
		} else if !isCode(err, http.StatusConflict) {
			fmt.Fprintf(os.Stderr, "warning: waiting for fork failed, but will try again: %v", err)
		}
	}

	return fmt.Errorf("fork repository was not ready after %s", maxWait)
}

func splitMessage(m string) (title string, body string) {
	s := bufio.NewScanner(strings.NewReader(m))