plumbing/client/common.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

// Package clients includes the implementation for diferent transport protocols
//
// go-git needs the packfile and the refs of the repo. The
// `NewGitUploadPackService` function returns an object that allows to
// download them.
//
// go-git supports HTTP and SSH (see `Protocols`) for downloading the packfile
// and the refs, but you can also install your own protocols (see
// `InstallProtocol` below).
//
// Each protocol has its own implementation of
// `NewGitUploadPackService`, but you should generally not use them
// directly, use this package's `NewGitUploadPackService` instead.
package clients

import (
	"fmt"

	"gopkg.in/src-d/go-git.v4/plumbing/client/common"
	"gopkg.in/src-d/go-git.v4/plumbing/client/http"
	"gopkg.in/src-d/go-git.v4/plumbing/client/ssh"
)

type GitUploadPackServiceFactory func(common.Endpoint) common.GitUploadPackService

// Protocols are the protocols supported by default.
var Protocols = map[string]GitUploadPackServiceFactory{
	"http":  http.NewGitUploadPackService,
	"https": http.NewGitUploadPackService,
	"ssh":   ssh.NewGitUploadPackService,
}

// InstallProtocol adds or modifies an existing protocol.
func InstallProtocol(scheme string, f GitUploadPackServiceFactory) {
	Protocols[scheme] = f
}

// NewGitUploadPackService returns the appropriate upload pack service
// among of the set of known protocols: HTTP, SSH. See `InstallProtocol`
// to add or modify protocols.
func NewGitUploadPackService(endpoint common.Endpoint) (common.GitUploadPackService, error) {
	f, ok := Protocols[endpoint.Scheme]
	if !ok {
		return nil, fmt.Errorf("unsupported scheme %q", endpoint.Scheme)
	}

	return f(endpoint), nil
}