165 lines
3.4 KiB
Go
165 lines
3.4 KiB
Go
package lfs
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/sha256"
|
|
"fmt"
|
|
"io"
|
|
|
|
"github.com/git-lfs/git-lfs/git"
|
|
)
|
|
|
|
// runCatFileBatch uses 'git cat-file --batch' to get the object contents of a
|
|
// git object, given its sha1. The contents will be decoded into a Git LFS
|
|
// pointer. Git Blob SHA1s are read from the sha1Ch channel and fed to STDIN.
|
|
// Results are parsed from STDOUT, and any eligible LFS pointers are sent to
|
|
// pointerCh. If a Git Blob is not an LFS pointer, check the lockableSet to see
|
|
// if that blob is for a locked file. Any errors are sent to errCh. An error is
|
|
// returned if the 'git cat-file' command fails to start.
|
|
func runCatFileBatch(pointerCh chan *WrappedPointer, lockableCh chan string, lockableSet *lockableNameSet, revs *StringChannelWrapper, errCh chan error) error {
|
|
scanner, err := NewPointerScanner()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
go func() {
|
|
for r := range revs.Results {
|
|
canScan := scanner.Scan(r)
|
|
|
|
if err := scanner.Err(); err != nil {
|
|
errCh <- err
|
|
} else if p := scanner.Pointer(); p != nil {
|
|
pointerCh <- p
|
|
} else if b := scanner.BlobSHA(); len(b) == 40 {
|
|
if name, ok := lockableSet.Check(b); ok {
|
|
lockableCh <- name
|
|
}
|
|
}
|
|
|
|
if !canScan {
|
|
break
|
|
}
|
|
}
|
|
|
|
if err := revs.Wait(); err != nil {
|
|
errCh <- err
|
|
}
|
|
|
|
if err := scanner.Close(); err != nil {
|
|
errCh <- err
|
|
}
|
|
|
|
close(pointerCh)
|
|
close(errCh)
|
|
close(lockableCh)
|
|
}()
|
|
|
|
return nil
|
|
}
|
|
|
|
type PointerScanner struct {
|
|
scanner *git.ObjectScanner
|
|
|
|
blobSha string
|
|
contentsSha string
|
|
pointer *WrappedPointer
|
|
err error
|
|
}
|
|
|
|
func NewPointerScanner() (*PointerScanner, error) {
|
|
scanner, err := git.NewObjectScanner()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &PointerScanner{scanner: scanner}, nil
|
|
}
|
|
|
|
func (s *PointerScanner) BlobSHA() string {
|
|
return s.blobSha
|
|
}
|
|
|
|
func (s *PointerScanner) ContentsSha() string {
|
|
return s.contentsSha
|
|
}
|
|
|
|
func (s *PointerScanner) Pointer() *WrappedPointer {
|
|
return s.pointer
|
|
}
|
|
|
|
func (s *PointerScanner) Err() error {
|
|
return s.err
|
|
}
|
|
|
|
func (s *PointerScanner) Scan(sha string) bool {
|
|
s.pointer, s.err = nil, nil
|
|
s.blobSha, s.contentsSha = "", ""
|
|
|
|
b, c, p, err := s.next(sha)
|
|
s.blobSha = b
|
|
s.contentsSha = c
|
|
s.pointer = p
|
|
|
|
if err != nil {
|
|
if err != io.EOF {
|
|
s.err = err
|
|
}
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
func (s *PointerScanner) Close() error {
|
|
return s.scanner.Close()
|
|
}
|
|
|
|
func (s *PointerScanner) next(blob string) (string, string, *WrappedPointer, error) {
|
|
if !s.scanner.Scan(blob) {
|
|
if err := s.scanner.Err(); err != nil {
|
|
return "", "", nil, err
|
|
}
|
|
return "", "", nil, io.EOF
|
|
}
|
|
|
|
blobSha := s.scanner.Sha1()
|
|
size := s.scanner.Size()
|
|
|
|
sha := sha256.New()
|
|
|
|
var buf *bytes.Buffer
|
|
var to io.Writer = sha
|
|
if size <= blobSizeCutoff {
|
|
buf = bytes.NewBuffer(make([]byte, 0, size))
|
|
to = io.MultiWriter(to, buf)
|
|
}
|
|
|
|
read, err := io.CopyN(to, s.scanner.Contents(), int64(size))
|
|
if err != nil {
|
|
return blobSha, "", nil, err
|
|
}
|
|
|
|
if int64(size) != read {
|
|
return blobSha, "", nil, fmt.Errorf("expected %d bytes, read %d bytes", size, read)
|
|
}
|
|
|
|
var pointer *WrappedPointer
|
|
var contentsSha string
|
|
|
|
if size <= blobSizeCutoff {
|
|
if p, err := DecodePointer(bytes.NewReader(buf.Bytes())); err != nil {
|
|
contentsSha = fmt.Sprintf("%x", sha.Sum(nil))
|
|
} else {
|
|
pointer = &WrappedPointer{
|
|
Sha1: blobSha,
|
|
Pointer: p,
|
|
}
|
|
contentsSha = p.Oid
|
|
}
|
|
} else {
|
|
contentsSha = fmt.Sprintf("%x", sha.Sum(nil))
|
|
}
|
|
|
|
return blobSha, contentsSha, pointer, err
|
|
}
|