diff options
author | Santiago M. Mola <santi@mola.io> | 2017-07-07 16:43:08 +0200 |
---|---|---|
committer | Santiago M. Mola <santi@mola.io> | 2017-07-07 17:03:20 +0200 |
commit | 35861a458b648b5f2bfc72e79e3460873c7a93db (patch) | |
tree | 7fa117a4fd619ea37c55fd85472dfc93d54f19d6 /remote.go | |
parent | 102d4b5aeb9b3cbd544c59706a1b0dd9300ddcc8 (diff) | |
download | go-git-35861a458b648b5f2bfc72e79e3460873c7a93db.tar.gz |
remote: fix push delete, closes #466
Refspecs for deletes were not being used to produce
delete commands on the update request.
Diffstat (limited to 'remote.go')
-rw-r--r-- | remote.go | 60 |
1 files changed, 48 insertions, 12 deletions
@@ -238,24 +238,60 @@ func (r *Remote) addReferencesToUpdate(refspecs []config.RefSpec, req *packp.ReferenceUpdateRequest) error { for _, rs := range refspecs { - iter, err := r.s.IterReferences() - if err != nil { - return err - } - - err = iter.ForEach(func(ref *plumbing.Reference) error { - return r.addReferenceIfRefSpecMatches( - rs, remoteRefs, ref, req, - ) - }) - if err != nil { - return err + if rs.IsDelete() { + if err := r.deleteReferences(rs, remoteRefs, req); err != nil { + return err + } + } else { + if err := r.addOrUpdateReferences(rs, remoteRefs, req); err != nil { + return err + } } } return nil } +func (r *Remote) addOrUpdateReferences(rs config.RefSpec, + remoteRefs storer.ReferenceStorer, req *packp.ReferenceUpdateRequest) error { + iter, err := r.s.IterReferences() + if err != nil { + return err + } + + return iter.ForEach(func(ref *plumbing.Reference) error { + return r.addReferenceIfRefSpecMatches( + rs, remoteRefs, ref, req, + ) + }) +} + +func (r *Remote) deleteReferences(rs config.RefSpec, + remoteRefs storer.ReferenceStorer, req *packp.ReferenceUpdateRequest) error { + iter, err := remoteRefs.IterReferences() + if err != nil { + return err + } + + return iter.ForEach(func(ref *plumbing.Reference) error { + if ref.Type() != plumbing.HashReference { + return nil + } + + if rs.Dst("") != ref.Name() { + return nil + } + + cmd := &packp.Command{ + Name: ref.Name(), + Old: ref.Hash(), + New: plumbing.ZeroHash, + } + req.Commands = append(req.Commands, cmd) + return nil + }) +} + func (r *Remote) addReferenceIfRefSpecMatches(rs config.RefSpec, remoteRefs storer.ReferenceStorer, localRef *plumbing.Reference, req *packp.ReferenceUpdateRequest) error { |