From 11ecd10958ce91d48c6d0aa64361a63c12d4ef2d Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Mon, 8 Jun 2026 07:15:10 +0000 Subject: object/fetch: Port reader --- object/fetch/reader.go | 26 ++++++++++++++++++++++++++ 1 file changed, 26 insertions(+) create mode 100644 object/fetch/reader.go (limited to 'object/fetch/reader.go') diff --git a/object/fetch/reader.go b/object/fetch/reader.go new file mode 100644 index 00000000..197efd84 --- /dev/null +++ b/object/fetch/reader.go @@ -0,0 +1,26 @@ +package fetch + +import ( + "io" + + "lindenii.org/go/furgit/errs" + oid "lindenii.org/go/furgit/object/id" + "lindenii.org/go/furgit/object/typ" +) + +// exactReader reads one object's content stream +// and verifies that its header type matches wantType. +func (r *Fetcher) exactReader(id oid.ObjectID, wantType typ.Type) (io.ReadCloser, int64, error) { + gotType, size, rc, err := r.store.ReadReaderContent(id) + if err != nil { + return nil, 0, wrapObjectReadError(id, err) + } + + if gotType != wantType { + _ = rc.Close() + + return nil, 0, &errs.ObjectTypeError{OID: id, Got: gotType, Want: wantType} + } + + return rc, size, nil +} -- cgit v1.3.1-10-gc9f91