From c3fe7af6cf267e6fafe5ab24cd2cc238e3ba3029 Mon Sep 17 00:00:00 2001
From: Runxi Yu
Date: Mon, 30 Mar 2026 18:06:05 +0000
Subject: object/store/dual: Add a basic dual composr

---
 object/store/dual/reader.go | 57 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100644 object/store/dual/reader.go

(limited to 'object/store/dual/reader.go')

diff --git a/object/store/dual/reader.go b/object/store/dual/reader.go
new file mode 100644
index 00000000..7b499d5d
--- /dev/null
+++ b/object/store/dual/reader.go
@@ -0,0 +1,57 @@
+package dual
+
+import (
+	"io"
+
+	objectid "codeberg.org/lindenii/furgit/object/id"
+	objecttype "codeberg.org/lindenii/furgit/object/type"
+)
+
+// ReadBytesFull reads a full serialized object as "type size\0content" from
+// either store.
+func (dual *Dual) ReadBytesFull(id objectid.ObjectID) ([]byte, error) {
+	return dual.reader.ReadBytesFull(id)
+}
+
+// ReadBytesContent reads an object's type and content bytes from either store.
+func (dual *Dual) ReadBytesContent(id objectid.ObjectID) (objecttype.Type, []byte, error) {
+	return dual.reader.ReadBytesContent(id)
+}
+
+// ReadReaderFull reads a full serialized object stream as "type size\0content"
+// from either store.
+func (dual *Dual) ReadReaderFull(id objectid.ObjectID) (io.ReadCloser, error) {
+	return dual.reader.ReadReaderFull(id)
+}
+
+// ReadReaderContent reads an object's type, declared content length, and
+// content stream from either store.
+func (dual *Dual) ReadReaderContent(id objectid.ObjectID) (objecttype.Type, int64, io.ReadCloser, error) {
+	return dual.reader.ReadReaderContent(id)
+}
+
+// ReadSize reads an object's declared content length from either store.
+func (dual *Dual) ReadSize(id objectid.ObjectID) (int64, error) {
+	return dual.reader.ReadSize(id)
+}
+
+// ReadHeader reads an object's type and declared content length from either
+// store.
+func (dual *Dual) ReadHeader(id objectid.ObjectID) (objecttype.Type, int64, error) {
+	return dual.reader.ReadHeader(id)
+}
+
+// Refresh refreshes both underlying stores and the combined read view.
+func (dual *Dual) Refresh() error {
+	err := dual.object.Refresh()
+	if err != nil {
+		return err
+	}
+
+	err = dual.pack.Refresh()
+	if err != nil {
+		return err
+	}
+
+	return dual.reader.Refresh()
+}
-- 
cgit v1.3.1-10-gc9f91