From 65427f64599e9383ab926aed75fc02f2db32022d Mon Sep 17 00:00:00 2001
From: Máximo Cuadros <mcuadros@gmail.com>
Date: Mon, 5 Sep 2016 07:59:20 +0200
Subject: core: ObjectStorage.Begin and TxObjectStorage

---
 storage/filesystem/object.go      | 17 +++++++++++++++++
 storage/filesystem/object_test.go |  8 ++++----
 2 files changed, 21 insertions(+), 4 deletions(-)

(limited to 'storage/filesystem')

diff --git a/storage/filesystem/object.go b/storage/filesystem/object.go
index 3888fd8..0696c70 100644
--- a/storage/filesystem/object.go
+++ b/storage/filesystem/object.go
@@ -217,3 +217,20 @@ func buildIndexFromIdxfile(fs fs.FS, path string) (index.Index, error) {
 
 	return index.NewFromIdx(f)
 }
+func (o *ObjectStorage) Begin() core.TxObjectStorage {
+	return &TxObjectStorage{}
+}
+
+type TxObjectStorage struct{}
+
+func (tx *TxObjectStorage) Set(obj core.Object) (core.Hash, error) {
+	return core.ZeroHash, fmt.Errorf("not implemented yet")
+}
+
+func (tx *TxObjectStorage) Commit() error {
+	return fmt.Errorf("not implemented yet")
+}
+
+func (tx *TxObjectStorage) Rollback() error {
+	return fmt.Errorf("not implemented yet")
+}
diff --git a/storage/filesystem/object_test.go b/storage/filesystem/object_test.go
index 361ae32..5752f79 100644
--- a/storage/filesystem/object_test.go
+++ b/storage/filesystem/object_test.go
@@ -124,9 +124,9 @@ func memStorageFromGitDir(fs fs.FS, path string) (core.ObjectStorage, error) {
 
 	sto := memory.NewStorage()
 	r := packfile.NewStream(f)
-	d := packfile.NewDecoder(r)
+	d := packfile.NewDecoder(r, sto.ObjectStorage())
 
-	err = d.Decode(sto.ObjectStorage())
+	err = d.Decode()
 	if err != nil {
 		return nil, err
 	}
@@ -267,8 +267,8 @@ func memStorageFromDirPath(fs fs.FS, path string) (core.ObjectStorage, error) {
 	}
 
 	r := packfile.NewStream(f)
-	d := packfile.NewDecoder(r)
-	err = d.Decode(sto.ObjectStorage())
+	d := packfile.NewDecoder(r, sto.ObjectStorage())
+	err = d.Decode()
 	if err != nil {
 		return nil, err
 	}
-- 
cgit