114 lines
3.1 KiB
Go
114 lines
3.1 KiB
Go
package sync
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/cli/cli/v2/git"
|
|
)
|
|
|
|
type gitClient interface {
|
|
CurrentBranch() (string, error)
|
|
UpdateBranch(string, string) error
|
|
CreateBranch(string, string, string) error
|
|
Fetch(string, string) error
|
|
HasLocalBranch(string) bool
|
|
IsAncestor(string, string) (bool, error)
|
|
IsDirty() (bool, error)
|
|
MergeFastForward(string) error
|
|
ResetHard(string) error
|
|
}
|
|
|
|
type gitExecuter struct {
|
|
client *git.Client
|
|
}
|
|
|
|
// UpdateBranch updates the given branch to point to the specified ref.
|
|
func (g *gitExecuter) UpdateBranch(branch, ref string) error {
|
|
cmd, err := g.client.Command(context.Background(), "update-ref", fmt.Sprintf("refs/heads/%s", branch), ref)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = cmd.Output()
|
|
return err
|
|
}
|
|
|
|
// CreateBranch creates a new branch at the specified ref with the given upstream.
|
|
func (g *gitExecuter) CreateBranch(branch, ref, upstream string) error {
|
|
ctx := context.Background()
|
|
cmd, err := g.client.Command(ctx, "branch", branch, ref)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if _, err := cmd.Output(); err != nil {
|
|
return err
|
|
}
|
|
cmd, err = g.client.Command(ctx, "branch", "--set-upstream-to", upstream, branch)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = cmd.Output()
|
|
return err
|
|
}
|
|
|
|
// CurrentBranch returns the name of the currently checked-out branch.
|
|
func (g *gitExecuter) CurrentBranch() (string, error) {
|
|
return g.client.CurrentBranch(context.Background())
|
|
}
|
|
|
|
// Fetch fetches the specified ref from the given remote.
|
|
func (g *gitExecuter) Fetch(remote, ref string) error {
|
|
args := []string{"fetch", "-q", remote, ref}
|
|
cmd, err := g.client.AuthenticatedCommand(context.Background(), git.AllMatchingCredentialsPattern, args...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return cmd.Run()
|
|
}
|
|
|
|
// HasLocalBranch reports whether the given local branch exists.
|
|
func (g *gitExecuter) HasLocalBranch(branch string) bool {
|
|
return g.client.HasLocalBranch(context.Background(), branch)
|
|
}
|
|
|
|
// IsAncestor reports whether the ancestor commit is an ancestor of the progeny commit.
|
|
func (g *gitExecuter) IsAncestor(ancestor, progeny string) (bool, error) {
|
|
args := []string{"merge-base", "--is-ancestor", ancestor, progeny}
|
|
cmd, err := g.client.Command(context.Background(), args...)
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
_, err = cmd.Output()
|
|
return err == nil, nil
|
|
}
|
|
|
|
// IsDirty reports whether the working tree has uncommitted changes.
|
|
func (g *gitExecuter) IsDirty() (bool, error) {
|
|
changeCount, err := g.client.UncommittedChangeCount(context.Background())
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
return changeCount != 0, nil
|
|
}
|
|
|
|
// MergeFastForward performs a fast-forward merge to the given ref.
|
|
func (g *gitExecuter) MergeFastForward(ref string) error {
|
|
args := []string{"merge", "--ff-only", "--quiet", ref}
|
|
cmd, err := g.client.Command(context.Background(), args...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = cmd.Output()
|
|
return err
|
|
}
|
|
|
|
// ResetHard performs a hard reset of the current branch to the given ref.
|
|
func (g *gitExecuter) ResetHard(ref string) error {
|
|
args := []string{"reset", "--hard", ref}
|
|
cmd, err := g.client.Command(context.Background(), args...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = cmd.Output()
|
|
return err
|
|
}
|