package git import ( "errors" "fmt" "gopkg.in/src-d/go-git.v4/config" "gopkg.in/src-d/go-git.v4/plumbing" "gopkg.in/src-d/go-git.v4/plumbing/object" "gopkg.in/src-d/go-git.v4/plumbing/protocol/packp/sideband" "gopkg.in/src-d/go-git.v4/plumbing/storer" "gopkg.in/src-d/go-git.v4/storage/filesystem" "gopkg.in/src-d/go-git.v4/storage/memory" osfs "gopkg.in/src-d/go-git.v4/utils/fs/os" ) var ( ErrObjectNotFound = errors.New("object not found") ErrInvalidReference = errors.New("invalid reference, should be a tag or a branch") ErrRepositoryNonEmpty = errors.New("repository non empty") ErrRemoteNotFound = errors.New("remote not found") ErrRemoteExists = errors.New("remote already exists") ) // Repository giturl string, auth common.AuthMethod repository struct type Repository struct { r map[string]*Remote s Storer // Progress is where the human readable information sent by the server is // stored, if nil nothing is stored and the capability (if supported) // no-progress, is sent to the server to avoid send this information Progress sideband.Progress } // NewMemoryRepository creates a new repository, backed by a memory.Storage func NewMemoryRepository() *Repository { r, _ := NewRepository(memory.NewStorage()) return r } // NewFilesystemRepository creates a new repository, backed by a filesystem.Storage // based on a fs.OS, if you want to use a custom one you need to use the function // NewRepository and build you filesystem.Storage func NewFilesystemRepository(path string) (*Repository, error) { s, err := filesystem.NewStorage(osfs.New(path)) if err != nil { return nil, err } return NewRepository(s) } // NewRepository creates a new repository with the given Storage func NewRepository(s Storer) (*Repository, error) { return &Repository{ s: s, r: make(map[string]*Remote, 0), }, nil } // Config return the repository config func (r *Repository) Config() (*config.Config, error) { return r.s.Config() } // Remote return a remote if exists func (r *Repository) Remote(name string) (*Remote, error) { cfg, err := r.s.Config() if err != nil { return nil, err } c, ok := cfg.Remotes[name] if !ok { return nil, ErrRemoteNotFound } return newRemote(r.s, r.Progress, c), nil } // Remotes return all the remotes func (r *Repository) Remotes() ([]*Remote, error) { cfg, err := r.s.Config() if err != nil { return nil, err } remotes := make([]*Remote, len(cfg.Remotes)) var i int for _, c := range cfg.Remotes { remotes[i] = newRemote(r.s, r.Progress, c) i++ } return remotes, nil } // CreateRemote creates a new remote func (r *Repository) CreateRemote(c *config.RemoteConfig) (*Remote, error) { if err := c.Validate(); err != nil { return nil, err } remote := newRemote(r.s, r.Progress, c) cfg, err := r.s.Config() if err != nil { return nil, err } if _, ok := cfg.Remotes[c.Name]; ok { return nil, ErrRemoteExists } cfg.Remotes[c.Name] = c return remote, r.s.SetConfig(cfg) } // DeleteRemote delete a remote from the repository and delete the config func (r *Repository) DeleteRemote(name string) error { cfg, err := r.s.Config() if err != nil { return err } if _, ok := cfg.Remotes[name]; !ok { return ErrRemoteNotFound } delete(cfg.Remotes, name) return r.s.SetConfig(cfg) } // Clone clones a remote repository func (r *Repository) Clone(o *CloneOptions) error { empty, err := r.IsEmpty() if err != nil { return err } if !empty { return ErrRepositoryNonEmpty } if err := o.Validate(); err != nil { return err } // marks the repository as bare in the config, until we have Worktree, all // the repository are bare if err := r.setIsBare(true); err != nil { return err } c := &config.RemoteConfig{ Name: o.RemoteName, URL: o.URL, } remote, err := r.CreateRemote(c) if err != nil { return err } if err = remote.Connect(); err != nil { return err } defer remote.Disconnect() if err := r.updateRemoteConfig(remote, o, c); err != nil { return err } if err = remote.Fetch(&FetchOptions{Depth: o.Depth}); err != nil { return err } head, err := remote.Reference(o.ReferenceName, true) if err != nil { return err } return r.createReferences(head) } func (r *Repository) setIsBare(isBare bool) error { cfg, err := r.s.Config() if err != nil { return err } cfg.Core.IsBare = isBare return r.s.SetConfig(cfg) } const refspecSingleBranch = "+refs/heads/%s:refs/remotes/%s/%[1]s" func (r *Repository) updateRemoteConfig( remote *Remote, o *CloneOptions, c *config.RemoteConfig, ) error { if !o.SingleBranch { return nil } refs, err := remote.AdvertisedReferences().AllReferences() if err != nil { return err } head, err := storer.ResolveReference(refs, o.ReferenceName) if err != nil { return err } c.Fetch = []config.RefSpec{ config.RefSpec(fmt.Sprintf(refspecSingleBranch, head.Name().Short(), c.Name)), } cfg, err := r.s.Config() if err != nil { return err } cfg.Remotes[c.Name] = c return r.s.SetConfig(cfg) } func (r *Repository) createReferences(ref *plumbing.Reference) error { if !ref.IsBranch() { // detached HEAD mode head := plumbing.NewHashReference(plumbing.HEAD, ref.Hash()) return r.s.SetReference(head) } if err := r.s.SetReference(ref); err != nil { return err } head := plumbing.NewSymbolicReference(plumbing.HEAD, ref.Name()) return r.s.SetReference(head) } // IsEmpty returns true if the repository is empty func (r *Repository) IsEmpty() (bool, error) { iter, err := r.References() if err != nil { return false, err } var count int return count == 0, iter.ForEach(func(r *plumbing.Reference) error { count++ return nil }) } // Pull incorporates changes from a remote repository into the current branch func (r *Repository) Pull(o *PullOptions) error { if err := o.Validate(); err != nil { return err } remote, err := r.Remote(o.RemoteName) if err != nil { return err } if err = remote.Connect(); err != nil { return err } defer remote.Disconnect() head, err := remote.Reference(o.ReferenceName, true) if err != nil { return err } if err = remote.Connect(); err != nil { return err } defer remote.Disconnect() err = remote.Fetch(&FetchOptions{ Depth: o.Depth, }) if err != nil { return err } return r.createReferences(head) } // object.Commit return the commit with the given hash func (r *Repository) Commit(h plumbing.Hash) (*object.Commit, error) { return object.GetCommit(r.s, h) } // Commits decode the objects into commits func (r *Repository) Commits() (*object.CommitIter, error) { iter, err := r.s.IterEncodedObjects(plumbing.CommitObject) if err != nil { return nil, err } return object.NewCommitIter(r.s, iter), nil } // Tree return the tree with the given hash func (r *Repository) Tree(h plumbing.Hash) (*object.Tree, error) { return object.GetTree(r.s, h) } // Trees decodes the objects into trees func (r *Repository) Trees() (*object.TreeIter, error) { iter, err := r.s.IterEncodedObjects(plumbing.TreeObject) if err != nil { return nil, err } return object.NewTreeIter(r.s, iter), nil } // Blob returns the blob with the given hash func (r *Repository) Blob(h plumbing.Hash) (*object.Blob, error) { return object.GetBlob(r.s, h) } // Blobs decodes the objects into blobs func (r *Repository) Blobs() (*object.BlobIter, error) { iter, err := r.s.IterEncodedObjects(plumbing.BlobObject) if err != nil { return nil, err } return object.NewBlobIter(r.s, iter), nil } // Tag returns a tag with the given hash. func (r *Repository) Tag(h plumbing.Hash) (*object.Tag, error) { return object.GetTag(r.s, h) } // Tags returns a object.TagIter that can step through all of the annotated tags // in the repository. func (r *Repository) Tags() (*object.TagIter, error) { iter, err := r.s.IterEncodedObjects(plumbing.TagObject) if err != nil { return nil, err } return object.NewTagIter(r.s, iter), nil } // Object returns an object with the given hash. func (r *Repository) Object(t plumbing.ObjectType, h plumbing.Hash) (object.Object, error) { obj, err := r.s.EncodedObject(t, h) if err != nil { if err == plumbing.ErrObjectNotFound { return nil, ErrObjectNotFound } return nil, err } return object.DecodeObject(r.s, obj) } // Objects returns an object.ObjectIter that can step through all of the annotated tags // in the repository. func (r *Repository) Objects() (*object.ObjectIter, error) { iter, err := r.s.IterEncodedObjects(plumbing.AnyObject) if err != nil { return nil, err } return object.NewObjectIter(r.s, iter), nil } // Head returns the reference where HEAD is pointing to. func (r *Repository) Head() (*plumbing.Reference, error) { return storer.ResolveReference(r.s, plumbing.HEAD) } // Reference returns the reference for a given reference name. If resolved is // true, any symbolic reference will be resolved. func (r *Repository) Reference(name plumbing.ReferenceName, resolved bool) ( *plumbing.Reference, error) { if resolved { return storer.ResolveReference(r.s, name) } return r.s.Reference(name) } // References returns a ReferenceIter for all references. func (r *Repository) References() (storer.ReferenceIter, error) { return r.s.IterReferences() }