From d7e90798170265b37ea5f980f94ca310cfda3180 Mon Sep 17 00:00:00 2001
From: Runxi Yu
Date: Fri, 27 Mar 2026 09:08:40 +0000
Subject: object/store: Rename from object/storer

---
 object/storer/loose/write_reader.go | 81 -------------------------------------
 1 file changed, 81 deletions(-)
 delete mode 100644 object/storer/loose/write_reader.go

(limited to 'object/storer/loose/write_reader.go')

diff --git a/object/storer/loose/write_reader.go b/object/storer/loose/write_reader.go
deleted file mode 100644
index 42d01ad8..00000000
--- a/object/storer/loose/write_reader.go
+++ /dev/null
@@ -1,81 +0,0 @@
-package loose
-
-import (
-	"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 loose object from typed content bytes read from src.
-// src must provide exactly size bytes.
-// size is required because loose object headers are "type size\0content", so the
-// header must be emitted before streaming content without buffering.
-func (store *Store) WriteReaderContent(ty objecttype.Type, size int64, src io.Reader) (objectid.ObjectID, error) {
-	if size < 0 {
-		return objectid.ObjectID{}, fmt.Errorf("objectstorer/loose: negative content size: %d", size)
-	}
-
-	header, ok := objectheader.Encode(ty, size)
-	if !ok {
-		return objectid.ObjectID{}, fmt.Errorf("objectstorer/loose: failed to encode object header for type %v", ty)
-	}
-
-	writer, err := store.newStreamWriter(false)
-	if err != nil {
-		return objectid.ObjectID{}, err
-	}
-
-	writer.headerDone = true
-	writer.expectedContentLeft = size
-
-	err = writer.writeRawChunk(header)
-	if err != nil {
-		_ = writer.Close()
-		_ = store.root.Remove(writer.tmpRelPath)
-
-		return objectid.ObjectID{}, err
-	}
-
-	return writeReaderIntoStreamWriter(writer, src)
-}
-
-// WriteReaderFull writes one loose object from raw bytes "type size\0content"
-// read from src.
-func (store *Store) WriteReaderFull(src io.Reader) (objectid.ObjectID, error) {
-	writer, err := store.newStreamWriter(true)
-	if err != nil {
-		return objectid.ObjectID{}, err
-	}
-
-	return writeReaderIntoStreamWriter(writer, src)
-}
-
-// writeReaderIntoStreamWriter copies src into writer and publishes the object.
-func writeReaderIntoStreamWriter(writer *streamWriter, src io.Reader) (objectid.ObjectID, error) {
-	_, err := io.Copy(writer, src)
-	if err != nil {
-		_ = writer.Close()
-		_ = writer.store.root.Remove(writer.tmpRelPath)
-
-		return objectid.ObjectID{}, err
-	}
-
-	err = writer.Close()
-	if err != nil {
-		_ = writer.store.root.Remove(writer.tmpRelPath)
-
-		return objectid.ObjectID{}, err
-	}
-
-	id, err := writer.finalize()
-	if err != nil {
-		_ = writer.store.root.Remove(writer.tmpRelPath)
-
-		return objectid.ObjectID{}, err
-	}
-
-	return id, nil
-}
-- 
cgit v1.3.1-10-gc9f91