info-refs.go 2.32 KB
Newer Older
1 2 3 4 5 6 7 8 9
package git

import (
	"fmt"
	"net/http"

	"gitlab.com/gitlab-org/gitlab-workhorse/internal/api"
	"gitlab.com/gitlab-org/gitlab-workhorse/internal/gitaly"
	"gitlab.com/gitlab-org/gitlab-workhorse/internal/helper"
10 11

	"golang.org/x/net/context"
12 13
)

14 15
func GetInfoRefsHandler(a *api.API) http.Handler {
	return repoPreAuthorizeHandler(a, handleGetInfoRefs)
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
}

func handleGetInfoRefs(rw http.ResponseWriter, r *http.Request, a *api.Response) {
	w := NewGitHttpResponseWriter(rw)
	// Log 0 bytes in because we ignore the request body (and there usually is none anyway).
	defer w.Log(r, 0)

	rpc := getService(r)
	if !(rpc == "git-upload-pack" || rpc == "git-receive-pack") {
		// The 'dumb' Git HTTP protocol is not supported
		http.Error(w, "Not Found", 404)
		return
	}

	w.Header().Set("Content-Type", fmt.Sprintf("application/x-%s-advertisement", rpc))
	w.Header().Set("Cache-Control", "no-cache")
32

33
	var err error
34
	if a.GitalyServer.Address == "" {
35 36 37 38 39 40
		err = handleGetInfoRefsLocally(w, a, rpc)
	} else {
		err = handleGetInfoRefsWithGitaly(w, a, rpc)
	}

	if err != nil {
41
		helper.Fail500(w, r, fmt.Errorf("handleGetInfoRefs: %v", err))
42 43 44
	}
}

45
func handleGetInfoRefsLocally(w http.ResponseWriter, a *api.Response, rpc string) error {
46
	if err := pktLine(w, fmt.Sprintf("# service=%s\n", rpc)); err != nil {
47
		return fmt.Errorf("pktLine: %v", err)
48 49
	}
	if err := pktFlush(w); err != nil {
50
		return fmt.Errorf("pktFlush: %v", err)
51
	}
52 53 54 55

	cmd, err := startGitCommand(a, nil, w, rpc, "--advertise-refs")
	if err != nil {
		return fmt.Errorf("startGitCommand: %v", err)
56
	}
57 58
	defer helper.CleanUpProcessGroup(cmd) // Ensure brute force subprocess clean-up

59
	if err := cmd.Wait(); err != nil {
60
		return fmt.Errorf("wait for %v: %v", cmd.Args, err)
61
	}
62 63

	return nil
64
}
65 66

func handleGetInfoRefsWithGitaly(w http.ResponseWriter, a *api.Response, rpc string) error {
67
	smarthttp, err := gitaly.NewSmartHTTPClient(a.GitalyServer)
68 69 70 71
	if err != nil {
		return fmt.Errorf("GetInfoRefsHandler: %v", err)
	}

72 73 74
	ctx, cancelFunc := context.WithCancel(context.Background())
	defer cancelFunc()
	infoRefsResponseWriter, err := smarthttp.InfoRefsResponseWriterTo(ctx, &a.Repository, rpc)
75 76 77 78 79
	if err != nil {
		return fmt.Errorf("GetInfoRefsHandler: %v", err)
	}

	if _, err = infoRefsResponseWriter.WriteTo(w); err != nil {
80
		return fmt.Errorf("GetInfoRefsHandler: copy Gitaly response: %v", err)
81 82 83 84
	}

	return nil
}