Warn user about non-existing configured branch

cmd/fluxd/main.go

@@ -485,7 +485,7 @@ func main() {
 		SkipMessage: *gitSkipMessage,
 	}
 
-	repo := git.NewRepo(gitRemote, git.PollInterval(*gitPollInterval), git.Timeout(*gitTimeout))
+	repo := git.NewRepo(gitRemote, git.PollInterval(*gitPollInterval), git.Timeout(*gitTimeout), git.Branch(*gitBranch))
 	{
 		shutdownWg.Add(1)
 		go func() {

git/operations.go

@@ -78,9 +78,12 @@ func checkout(ctx context.Context, workingDir, ref string) error {
 // checkPush sanity-checks that we can write to the upstream repo
 // (being able to `clone` is an adequate check that we can read the
 // upstream).
-func checkPush(ctx context.Context, workingDir, upstream string) error {
+func checkPush(ctx context.Context, workingDir, upstream, branch string) error {
 	// --force just in case we fetched the tag from upstream when cloning
 	args := []string{"tag", "--force", CheckPushTag}
+	if branch != "" {
+		args = append(args, branch)
+	}
 	if err := execGitCmd(ctx, args, gitCmdConfig{dir: workingDir}); err != nil {
 		return errors.Wrap(err, "tag for write check")
 	}

git/operations_test.go

@@ -213,7 +213,7 @@ func TestCheckPush(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	err = checkPush(context.Background(), working, upstreamDir)
+	err = checkPush(context.Background(), working, upstreamDir, "")
 	if err != nil {
 		t.Fatal(err)
 	}

git/repo.go

@@ -2,6 +2,7 @@ package git
 
 import (
 	"errors"
+	"fmt"
 	"io/ioutil"
 	"os"
 	"sync"
@@ -47,6 +48,7 @@ const (
 type Repo struct {
 	// As supplied to constructor
 	origin   Remote
+	branch   string
 	interval time.Duration
 	timeout  time.Duration
 	readonly bool
@@ -83,6 +85,12 @@ func (t Timeout) apply(r *Repo) {
 	r.timeout = time.Duration(t)
 }
 
+type Branch string
+
+func (b Branch) apply(r *Repo) {
+	r.branch = string(b)
+}
+
 var ReadOnly optionFunc = func(r *Repo) {
 	r.readonly = true
 }
@@ -261,10 +269,23 @@ func (r *Repo) step(bg context.Context) bool {
 		return false
 
 	case RepoCloned:
+		ctx, cancel := context.WithTimeout(bg, r.timeout)
+		defer cancel()
+
+		if r.branch != "" {
+			ok, err := refExists(ctx, dir, "refs/heads/"+r.branch)
+			if err != nil {
+				r.setUnready(RepoCloned, err)
+				return false
+			}
+			if !ok {
+				r.setUnready(RepoCloned, fmt.Errorf("configured branch '%s' does not exist", r.branch))
+				return false
+			}
+		}
+
 		if !r.readonly {
-			ctx, cancel := context.WithTimeout(bg, r.timeout)
-			err := checkPush(ctx, dir, url)
-			cancel()
+			err := checkPush(ctx, dir, url, r.branch)
 			if err != nil {
 				r.setUnready(RepoCloned, err)
 				return false