package file import ( "io" "os/exec" "gopkg.in/src-d/go-git.v4/plumbing/transport" "gopkg.in/src-d/go-git.v4/plumbing/transport/internal/common" ) // DefaultClient is the default local client. var DefaultClient = NewClient( transport.UploadPackServiceName, transport.ReceivePackServiceName, ) type runner struct { UploadPackBin string ReceivePackBin string } // NewClient returns a new local client using the given git-upload-pack and // git-receive-pack binaries. func NewClient(uploadPackBin, receivePackBin string) transport.Client { return common.NewClient(&runner{ UploadPackBin: uploadPackBin, ReceivePackBin: receivePackBin, }) } func (r *runner) Command(cmd string, ep transport.Endpoint) (common.Command, error) { switch cmd { case transport.UploadPackServiceName: cmd = r.UploadPackBin case transport.ReceivePackServiceName: cmd = r.ReceivePackBin } return &command{cmd: exec.Command(cmd, ep.Path)}, nil } type command struct { cmd *exec.Cmd closed bool } func (c *command) SetAuth(auth transport.AuthMethod) error { if auth != nil { return transport.ErrInvalidAuthMethod } return nil } func (c *command) Start() error { return c.cmd.Start() } func (c *command) StderrPipe() (io.Reader, error) { return c.cmd.StderrPipe() } func (c *command) StdinPipe() (io.WriteCloser, error) { return c.cmd.StdinPipe() } func (c *command) StdoutPipe() (io.Reader, error) { return c.cmd.StdoutPipe() } // Close waits for the command to exit. func (c *command) Close() error { return c.cmd.Process.Kill() } func (c *command) Wait() error { defer func() { c.closed = true }() return c.cmd.Wait() }