diff options
Diffstat (limited to 'storage/transactional/shallow.go')
-rw-r--r-- | storage/transactional/shallow.go | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/storage/transactional/shallow.go b/storage/transactional/shallow.go new file mode 100644 index 0000000..07663d4 --- /dev/null +++ b/storage/transactional/shallow.go @@ -0,0 +1,44 @@ +package transactional + +import ( + "gopkg.in/src-d/go-git.v4/plumbing" + "gopkg.in/src-d/go-git.v4/plumbing/storer" +) + +type ShallowStorage struct { + storer.ShallowStorer + temporal storer.ShallowStorer +} + +func NewShallowStorage(s, temporal storer.ShallowStorer) *ShallowStorage { + return &ShallowStorage{ + ShallowStorer: s, + temporal: temporal, + } +} + +func (s *ShallowStorage) SetShallow(commits []plumbing.Hash) error { + return s.temporal.SetShallow(commits) +} + +func (s *ShallowStorage) Shallow() ([]plumbing.Hash, error) { + shallow, err := s.temporal.Shallow() + if err != nil { + return nil, err + } + + if len(shallow) != 0 { + return shallow, nil + } + + return s.ShallowStorer.Shallow() +} + +func (s *ShallowStorage) Commit() error { + commits, err := s.temporal.Shallow() + if err != nil || len(commits) == 0 { + return err + } + + return s.ShallowStorer.SetShallow(commits) +} |