lunny/git-lfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

teach GitScanner how to ScanLeftToRemote()

Browse Source
This commit is contained in:
risk danger olson 2016-11-16 13:43:12 -07:00
parent 6dd78c6bca
commit 496654b2b3
2 changed files with 26 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
commands/command_pre_push.go
View File

@ -54,9 +54,8 @@ func prePushCommand(cmd *cobra.Command, args []string) {
cfg.CurrentRemote = args[0]
ctx := newUploadContext(prePushDryRun)
scanOpt := lfs.NewScanRefsOptions()
scanOpt.ScanMode = lfs.ScanLeftToRemoteMode
scanOpt.RemoteName = cfg.CurrentRemote
gitscanner := lfs.NewGitScanner()
gitscanner.Remote(cfg.CurrentRemote)
// We can be passed multiple lines of refs
scanner := bufio.NewScanner(os.Stdin)
@ -69,17 +68,16 @@ func prePushCommand(cmd *cobra.Command, args []string) {
tracerx.Printf("pre-push: %s", line)
left, right := decodeRefs(line)
left, _ := decodeRefs(line)
if left == prePushDeleteBranch {
continue
}
pointers, err := lfs.ScanRefsToChan(left, right, scanOpt)
pointerCh, err := gitscanner.ScanLeftToRemote(left)
if err != nil {
Panic(err, "Error scanning for Git LFS files")
}
upload(ctx, pointers)
upload(ctx, pointerCh)
}
}

27
lfs/gitscanner.go
View File

@ -1,15 +1,23 @@
package lfs
type GitScanner struct {
remote string
}
func NewGitScanner() *GitScanner {
return &GitScanner{}
}
func (s *GitScanner) Remote(r string) {
s.remote = r
}
func (s *GitScanner) ScanLeftToRemote(left string) (*PointerChannelWrapper, error) {
return ScanRefsToChan(left, "", s.opts(ScanLeftToRemoteMode))
}
func (s *GitScanner) ScanRefRange(left, right string) (*PointerChannelWrapper, error) {
opts := NewScanRefsOptions()
opts.ScanMode = ScanRefsMode
opts := s.opts(ScanRefsMode)
opts.SkipDeletedBlobs = false
return ScanRefsToChan(left, right, opts)
}
@ -19,15 +27,22 @@ func (s *GitScanner) ScanRefWithDeleted(ref string) (*PointerChannelWrapper, err
}
func (s *GitScanner) ScanRef(ref string) (*PointerChannelWrapper, error) {
opts := NewScanRefsOptions()
opts.ScanMode = ScanRefsMode
opts := s.opts(ScanRefsMode)
opts.SkipDeletedBlobs = true
return ScanRefsToChan(ref, "", opts)
}
func (s *GitScanner) ScanAll() (*PointerChannelWrapper, error) {
opts := NewScanRefsOptions()
opts.ScanMode = ScanAllMode
opts := s.opts(ScanAllMode)
opts.SkipDeletedBlobs = false
return ScanRefsToChan("", "", opts)
}
func (s *GitScanner) opts(mode ScanningMode) *ScanRefsOptions {
opts := NewScanRefsOptions()
opts.ScanMode = mode
if len(s.remote) > 0 {
opts.RemoteName = s.remote
}
return opts
}