aboutsummaryrefslogblamecommitdiffstats
path: root/plumbing/transport/client/client.go
blob: 76c14694701db7328588d8c5f3b8e98d5c259752 (plain) (tree)
1
2
3
4
5
6
7

                                                                            




              




                                                          


                                                    
                                               


                                    
                                   
                                    


                                                         
                                                            




                                         



                                                                                

                                                    
                                                                          
                                               
                
                                                                                    

         
                     
                                                                                                                       

         

                     
// Package client contains helper function to deal with the different client
// protocols.
package client

import (
	"fmt"

	"gopkg.in/src-d/go-git.v4/plumbing/transport"
	"gopkg.in/src-d/go-git.v4/plumbing/transport/file"
	"gopkg.in/src-d/go-git.v4/plumbing/transport/git"
	"gopkg.in/src-d/go-git.v4/plumbing/transport/http"
	"gopkg.in/src-d/go-git.v4/plumbing/transport/ssh"
)

// Protocols are the protocols supported by default.
var Protocols = map[string]transport.Transport{
	"http":  http.DefaultClient,
	"https": http.DefaultClient,
	"ssh":   ssh.DefaultClient,
	"git":   git.DefaultClient,
	"file":  file.DefaultClient,
}

// InstallProtocol adds or modifies an existing protocol.
func InstallProtocol(scheme string, c transport.Transport) {
	if c == nil {
		delete(Protocols, scheme)
		return
	}

	Protocols[scheme] = c
}

// NewClient returns the appropriate client among of the set of known protocols:
// http://, https://, ssh:// and file://.
// See `InstallProtocol` to add or modify protocols.
func NewClient(endpoint transport.Endpoint) (transport.Transport, error) {
	f, ok := Protocols[endpoint.Protocol()]
	if !ok {
		return nil, fmt.Errorf("unsupported scheme %q", endpoint.Protocol())
	}

	if f == nil {
		return nil, fmt.Errorf("malformed client for scheme %q, client is defined as nil", endpoint.Protocol())
	}

	return f, nil
}