From a041d523de389b65b98a5373a8034041db2a8d83 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Thu, 2 Apr 2026 06:23:30 +0000 Subject: *: Remove --- object/store/memory/write_reader.go | 55 ------------------------------------- 1 file changed, 55 deletions(-) delete mode 100644 object/store/memory/write_reader.go (limited to 'object/store/memory/write_reader.go') diff --git a/object/store/memory/write_reader.go b/object/store/memory/write_reader.go deleted file mode 100644 index 0fa6a13f..00000000 --- a/object/store/memory/write_reader.go +++ /dev/null @@ -1,55 +0,0 @@ -package memory - -import ( - "errors" - "fmt" - "io" - - objectheader "codeberg.org/lindenii/furgit/object/header" - objectid "codeberg.org/lindenii/furgit/object/id" - objecttype "codeberg.org/lindenii/furgit/object/type" -) - -// WriteReaderContent writes one typed object content stream. -func (store *Store) WriteReaderContent(ty objecttype.Type, size int64, src io.Reader) (objectid.ObjectID, error) { - if size < 0 { - return objectid.ObjectID{}, fmt.Errorf("objectstore/memory: negative content size: %d", size) - } - - content, err := io.ReadAll(io.LimitReader(src, size+1)) - if err != nil { - return objectid.ObjectID{}, err - } - - switch { - case int64(len(content)) > size: - return objectid.ObjectID{}, errors.New("objectstore/memory: object content longer than declared size") - case int64(len(content)) < size: - return objectid.ObjectID{}, errors.New("objectstore/memory: object content shorter than declared size") - } - - return store.WriteBytesContent(ty, content) -} - -// WriteReaderFull writes one full serialized object stream as "type size\0content". -func (store *Store) WriteReaderFull(src io.Reader) (objectid.ObjectID, error) { - raw, err := io.ReadAll(src) - if err != nil { - return objectid.ObjectID{}, err - } - - ty, size, headerLen, ok := objectheader.Parse(raw) - if !ok { - return objectid.ObjectID{}, errors.New("objectstore/memory: malformed object header") - } - - content := raw[headerLen:] - if int64(len(content)) != size { - return objectid.ObjectID{}, errors.New("objectstore/memory: object header size/content mismatch") - } - - id := store.algo.Sum(raw) - store.objects[id] = storedObject{ty: ty, content: append([]byte(nil), content...)} - - return id, nil -} -- cgit v1.3.1-10-gc9f91