aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--bug/bug_actions.go26
-rw-r--r--bug/operations/label_change.go1
-rw-r--r--cache/repo_cache.go6
-rw-r--r--commands/pull.go26
-rw-r--r--tests/bug_actions_test.go18
5 files changed, 39 insertions, 38 deletions
diff --git a/bug/bug_actions.go b/bug/bug_actions.go
index f9e6d0c6..37c3aa05 100644
--- a/bug/bug_actions.go
+++ b/bug/bug_actions.go
@@ -2,8 +2,6 @@ package bug
import (
"fmt"
- "io"
- "io/ioutil"
"strings"
"github.com/MichaelMure/git-bug/repository"
@@ -28,33 +26,19 @@ func Push(repo repository.Repo, remote string) (string, error) {
return repo.PushRefs(remote, bugsRefPattern+"*")
}
-// Pull does a Fetch and merge the updates into the local bug states
-func Pull(repo repository.Repo, out io.Writer, remote string) error {
- // TODO: return a chan of changes for the cache to be updated properly
-
- if out == nil {
- out = ioutil.Discard
- }
-
- fmt.Fprintf(out, "Fetching remote ...\n")
-
- stdout, err := Fetch(repo, remote)
+// Pull will do a Fetch + MergeAll
+// This function won't give details on the underlying process. If you need more
+// use Fetch and MergeAll separately.
+func Pull(repo repository.Repo, remote string) error {
+ _, err := Fetch(repo, remote)
if err != nil {
return err
}
- out.Write([]byte(stdout))
-
- fmt.Fprintf(out, "Merging data ...\n")
-
for merge := range MergeAll(repo, remote) {
if merge.Err != nil {
return merge.Err
}
-
- if merge.Status != MsgMergeNothing {
- fmt.Fprintf(out, "%s: %s\n", merge.HumanId, merge.Status)
- }
}
return nil
diff --git a/bug/operations/label_change.go b/bug/operations/label_change.go
index 5d343e5b..551b8be0 100644
--- a/bug/operations/label_change.go
+++ b/bug/operations/label_change.go
@@ -61,6 +61,7 @@ func NewLabelChangeOperation(author bug.Person, added, removed []bug.Label) Labe
// ChangeLabels is a convenience function to apply the operation
func ChangeLabels(out io.Writer, b bug.Interface, author bug.Person, add, remove []string) error {
+ // TODO: return a channel of result (like MergeAll) instead of formatting the result for the upper layers
var added, removed []bug.Label
if out == nil {
diff --git a/cache/repo_cache.go b/cache/repo_cache.go
index d3d02c45..a187b43c 100644
--- a/cache/repo_cache.go
+++ b/cache/repo_cache.go
@@ -266,12 +266,6 @@ func (c *RepoCache) MergeAll(remote string) <-chan bug.MergeResult {
return bug.MergeAll(c.repo, remote)
}
-// Pull does a Fetch and merge the updates into the local bug states
-func (c *RepoCache) Pull(remote string, out io.Writer) error {
- // Todo: update the cache properly
- return bug.Pull(c.repo, out, remote)
-}
-
// Push update a remote with the local changes
func (c *RepoCache) Push(remote string) (string, error) {
return bug.Push(c.repo, remote)
diff --git a/commands/pull.go b/commands/pull.go
index e9f0ad3e..ea064d99 100644
--- a/commands/pull.go
+++ b/commands/pull.go
@@ -2,8 +2,9 @@ package commands
import (
"errors"
- "os"
+ "fmt"
+ "github.com/MichaelMure/git-bug/bug"
"github.com/MichaelMure/git-bug/cache"
"github.com/spf13/cobra"
)
@@ -24,7 +25,28 @@ func runPull(cmd *cobra.Command, args []string) error {
}
defer backend.Close()
- return backend.Pull(remote, os.Stdout)
+ fmt.Println("Fetching remote ...")
+
+ stdout, err := backend.Fetch(remote)
+ if err != nil {
+ return err
+ }
+
+ fmt.Println(stdout)
+
+ fmt.Println("Merging data ...")
+
+ for merge := range backend.MergeAll(remote) {
+ if merge.Err != nil {
+ return merge.Err
+ }
+
+ if merge.Status != bug.MsgMergeNothing {
+ fmt.Printf("%s: %s\n", merge.HumanId, merge.Status)
+ }
+ }
+
+ return nil
}
// showCmd defines the "push" subcommand.
diff --git a/tests/bug_actions_test.go b/tests/bug_actions_test.go
index 64f9aa97..afd6e4b4 100644
--- a/tests/bug_actions_test.go
+++ b/tests/bug_actions_test.go
@@ -80,7 +80,7 @@ func TestPushPull(t *testing.T) {
_, err = bug.Push(repoA, "origin")
checkErr(t, err)
- err = bug.Pull(repoB, nil, "origin")
+ err = bug.Pull(repoB, "origin")
checkErr(t, err)
bugs := allBugs(t, bug.ReadAllLocalBugs(repoB))
@@ -98,7 +98,7 @@ func TestPushPull(t *testing.T) {
_, err = bug.Push(repoB, "origin")
checkErr(t, err)
- err = bug.Pull(repoA, nil, "origin")
+ err = bug.Pull(repoA, "origin")
checkErr(t, err)
bugs = allBugs(t, bug.ReadAllLocalBugs(repoA))
@@ -149,7 +149,7 @@ func _RebaseTheirs(t testing.TB) {
checkErr(t, err)
// remote --> B
- err = bug.Pull(repoB, nil, "origin")
+ err = bug.Pull(repoB, "origin")
checkErr(t, err)
bug2, err := bug.ReadLocalBug(repoB, bug1.Id())
@@ -166,7 +166,7 @@ func _RebaseTheirs(t testing.TB) {
checkErr(t, err)
// remote --> A
- err = bug.Pull(repoA, nil, "origin")
+ err = bug.Pull(repoA, "origin")
checkErr(t, err)
bugs := allBugs(t, bug.ReadAllLocalBugs(repoB))
@@ -207,7 +207,7 @@ func _RebaseOurs(t testing.TB) {
checkErr(t, err)
// remote --> B
- err = bug.Pull(repoB, nil, "origin")
+ err = bug.Pull(repoB, "origin")
checkErr(t, err)
operations.Comment(bug1, rene, "message2")
@@ -229,7 +229,7 @@ func _RebaseOurs(t testing.TB) {
checkErr(t, err)
// remote --> A
- err = bug.Pull(repoA, nil, "origin")
+ err = bug.Pull(repoA, "origin")
checkErr(t, err)
bugs := allBugs(t, bug.ReadAllLocalBugs(repoA))
@@ -279,7 +279,7 @@ func _RebaseConflict(t testing.TB) {
checkErr(t, err)
// remote --> B
- err = bug.Pull(repoB, nil, "origin")
+ err = bug.Pull(repoB, "origin")
checkErr(t, err)
operations.Comment(bug1, rene, "message2")
@@ -326,7 +326,7 @@ func _RebaseConflict(t testing.TB) {
checkErr(t, err)
// remote --> B
- err = bug.Pull(repoB, nil, "origin")
+ err = bug.Pull(repoB, "origin")
checkErr(t, err)
bugs := allBugs(t, bug.ReadAllLocalBugs(repoB))
@@ -347,7 +347,7 @@ func _RebaseConflict(t testing.TB) {
checkErr(t, err)
// remote --> A
- err = bug.Pull(repoA, nil, "origin")
+ err = bug.Pull(repoA, "origin")
checkErr(t, err)
bugs = allBugs(t, bug.ReadAllLocalBugs(repoA))
generated by cgit (git 2.34.1) at 2024-11-05 19:41:10 +0000