Method GetCommits

pkg/commands/git_commands/commit_loader.go:74–153

GetCommits obtains the commits of the current branch

(opts GetCommitsOptions)

// GetCommits obtains the commits of the current branch
func (self *CommitLoader) GetCommits(opts GetCommitsOptions) ([]*models.Commit, error) {
	commits := []*models.Commit{}

	if opts.IncludeRebaseCommits && opts.FilterPath == "" {
		var err error
		commits, err = self.MergeRebasingCommits(opts.HashPool, commits)
		if err != nil {
			return nil, err
		}
	}

	wg := sync.WaitGroup{}

	wg.Add(2)

	var logErr error
	go utils.Safe(func() {
		defer wg.Done()

		var realCommits []*models.Commit
		realCommits, logErr = loadCommits(self.getLogCmd(opts), opts.FilterPath, func(line string) (*models.Commit, bool) {
			return self.extractCommitFromLine(opts.HashPool, line, opts.RefToShowDivergenceFrom != ""), false
		})
		if logErr == nil {
			commits = append(commits, realCommits...)
		}
	})

	var unmergedCommitHashes *set.Set[string]
	var remoteUnmergedCommitHashes *set.Set[string]
	mainBranches := opts.MainBranches.Get()

	go utils.Safe(func() {
		defer wg.Done()

		if len(mainBranches) > 0 {
			unmergedCommitHashes = self.getReachableHashes(opts.RefName, mainBranches)
			if opts.RefToShowDivergenceFrom != "" {
				remoteUnmergedCommitHashes = self.getReachableHashes(opts.RefToShowDivergenceFrom, mainBranches)
			}
		}
	})

	var unpushedCommitHashes *set.Set[string]
	if opts.RefForPushedStatus != nil {
		unpushedCommitHashes = self.getReachableHashes(opts.RefForPushedStatus.FullRefName(),
			append([]string{opts.RefForPushedStatus.RefName() + "@{u}"}, mainBranches...))
	}

	wg.Wait()

	if logErr != nil {
		return nil, logErr
	}

	if len(commits) == 0 {
		return commits, nil
	}