1package commands
 2
 3import (
 4	"errors"
 5
 6	"github.com/spf13/cobra"
 7
 8	"github.com/git-bug/git-bug/commands/completion"
 9	"github.com/git-bug/git-bug/commands/execenv"
10	"github.com/git-bug/git-bug/entity"
11	"github.com/git-bug/git-bug/repository"
12)
13
14func newPullCommand(env *execenv.Env) *cobra.Command {
15	cmd := &cobra.Command{
16		Use:     "pull [REMOTE]",
17		Short:   "Pull updates from a git remote",
18		PreRunE: execenv.LoadBackend(env),
19		RunE: execenv.CloseBackend(env, func(cmd *cobra.Command, args []string) error {
20			return runPull(env, args)
21		}),
22		ValidArgsFunction: completion.GitRemote(env),
23	}
24
25	return cmd
26}
27
28func runPull(env *execenv.Env, args []string) error {
29	var remote string
30	switch {
31	case len(args) > 1:
32		return errors.New("Only pulling from one remote at a time is supported")
33	case len(args) == 1:
34		remote = args[0]
35	default:
36		v, err := repository.GetDefaultString("git-bug.remote", env.Repo.AnyConfig(), "origin")
37		if err != nil {
38			return err
39		}
40		remote = v
41	}
42
43	env.Out.Println("Fetching remote ...")
44
45	stdout, err := env.Backend.Fetch(remote)
46	if err != nil {
47		return err
48	}
49
50	env.Out.Println(stdout)
51
52	env.Out.Println("Merging data ...")
53
54	for result := range env.Backend.MergeAll(remote) {
55		if result.Err != nil {
56			env.Err.Println(result.Err)
57		}
58
59		if result.Status != entity.MergeStatusNothing {
60			env.Out.Printf("%s: %s\n", result.Id.Human(), result)
61		}
62	}
63
64	return nil
65}