network/protocol: Rename from protocol v0.1.110

1 files changed, 0 insertions, 293 deletions

diff --git a/protocol/v0v1/server/receivepack/report_status_test.go b/protocol/v0v1/server/receivepack/report_status_test.go
deleted file mode 100644
index 0f22612b..00000000
--- a/protocol/v0v1/server/receivepack/report_status_test.go
+++ /dev/null
@@ -1,293 +0,0 @@
-package receivepack_test
-
-import (
-	"errors"
-	"io"
-	"strings"
-	"testing"
-
-	"codeberg.org/lindenii/furgit/internal/testgit"
-	objectid "codeberg.org/lindenii/furgit/object/id"
-	"codeberg.org/lindenii/furgit/protocol/pktline"
-	"codeberg.org/lindenii/furgit/protocol/sideband64k"
-	common "codeberg.org/lindenii/furgit/protocol/v0v1/server"
-	receivepack "codeberg.org/lindenii/furgit/protocol/v0v1/server/receivepack"
-)
-
-func TestWriteReportStatusWritesClassicStatus(t *testing.T) {
-	t.Parallel()
-
-	var out bufferWriteFlusher
-
-	base := common.NewSession(strings.NewReader(""), &out, common.Options{})
-	session := receivepack.NewSession(base, receivepack.Capabilities{})
-
-	err := session.WriteReportStatus(receivepack.ReportStatusResult{
-		Commands: []receivepack.CommandResult{
-			{Name: "refs/heads/main"},
-			{Name: "refs/heads/dev", Error: "non-fast-forward"},
-		},
-	})
-	if err != nil {
-		t.Fatalf("WriteReportStatus: %v", err)
-	}
-
-	got := out.String()
-	wantParts := []string{
-		"unpack ok\n",
-		"ok refs/heads/main\n",
-		"ng refs/heads/dev non-fast-forward\n",
-		"0000",
-	}
-
-	for _, part := range wantParts {
-		if !strings.Contains(got, part) {
-			t.Fatalf("report-status missing %q in %q", part, got)
-		}
-	}
-}
-
-func TestWriteReportStatusUsesSideBand64KWhenNegotiated(t *testing.T) {
-	t.Parallel()
-
-	//nolint:thelper
-	testgit.ForEachAlgorithm(t, func(t *testing.T, algo objectid.Algorithm) {
-		t.Parallel()
-
-		var requestWire bufferWriteFlusher
-
-		requestEnc := pktline.NewEncoder(&requestWire)
-
-		err := requestEnc.WriteData([]byte(
-			objectid.Zero(algo).String() + " " + mustHexID(t, algo, "1").String() + " refs/heads/main\x00report-status side-band-64k object-format=" + algo.String() + "\n",
-		))
-		if err != nil {
-			t.Fatalf("WriteData(request): %v", err)
-		}
-
-		err = requestEnc.WriteFlush()
-		if err != nil {
-			t.Fatalf("WriteFlush(request): %v", err)
-		}
-
-		var out bufferWriteFlusher
-
-		base := common.NewSession(strings.NewReader(requestWire.String()), &out, common.Options{
-			Algorithm: algo,
-		})
-		session := receivepack.NewSession(base, receivepack.Capabilities{
-			ReportStatus: true,
-			SideBand64K:  true,
-			ObjectFormat: algo,
-		})
-
-		_, err = session.ReadRequest()
-		if err != nil {
-			t.Fatalf("ReadRequest: %v", err)
-		}
-
-		err = session.WriteReportStatus(receivepack.ReportStatusResult{
-			Commands: []receivepack.CommandResult{
-				{Name: "refs/heads/main"},
-			},
-		})
-		if err != nil {
-			t.Fatalf("WriteReportStatus: %v", err)
-		}
-
-		dec := sideband64k.NewDecoder(strings.NewReader(out.String()), sideband64k.ReadOptions{})
-
-		frame, err := dec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(unpack): %v", err)
-		}
-
-		if frame.Type != sideband64k.FrameData {
-			t.Fatalf("first frame = %#v", frame)
-		}
-
-		statusDec := pktline.NewDecoder(strings.NewReader(string(frame.Payload)), pktline.ReadOptions{})
-
-		statusFrame, err := statusDec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(unpack status): %v", err)
-		}
-
-		if statusFrame.Type != pktline.PacketData || string(statusFrame.Payload) != "unpack ok\n" {
-			t.Fatalf("first status frame = %#v", statusFrame)
-		}
-
-		statusFrame, err = statusDec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(ok status): %v", err)
-		}
-
-		if statusFrame.Type != pktline.PacketData || string(statusFrame.Payload) != "ok refs/heads/main\n" {
-			t.Fatalf("second status frame = %#v", statusFrame)
-		}
-
-		statusFrame, err = statusDec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(status flush): %v", err)
-		}
-
-		if statusFrame.Type != pktline.PacketFlush {
-			t.Fatalf("status flush frame.Type = %v, want FrameFlush", statusFrame.Type)
-		}
-
-		frame, err = dec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(outer flush): %v", err)
-		}
-
-		if frame.Type != sideband64k.FrameFlush {
-			t.Fatalf("outer flush frame.Type = %v, want FrameFlush", frame.Type)
-		}
-	})
-}
-
-func TestWriteReportStatusV2WritesOptionLines(t *testing.T) {
-	t.Parallel()
-
-	//nolint:thelper
-	testgit.ForEachAlgorithm(t, func(t *testing.T, algo objectid.Algorithm) {
-		t.Parallel()
-
-		oldID := mustHexID(t, algo, "1")
-		newID := mustHexID(t, algo, "2")
-
-		var out bufferWriteFlusher
-
-		base := common.NewSession(strings.NewReader(""), &out, common.Options{})
-		session := receivepack.NewSession(base, receivepack.Capabilities{})
-
-		err := session.WriteReportStatusV2(receivepack.ReportStatusResult{
-			Commands: []receivepack.CommandResult{
-				{
-					Name:         "refs/pseudo/proc",
-					RefName:      "refs/heads/main",
-					OldID:        &oldID,
-					NewID:        &newID,
-					ForcedUpdate: true,
-				},
-				{Name: "refs/heads/dev", Error: "rejected"},
-			},
-		})
-		if err != nil {
-			t.Fatalf("WriteReportStatusV2: %v", err)
-		}
-
-		got := out.String()
-		wantParts := []string{
-			"unpack ok\n",
-			"ok refs/pseudo/proc\n",
-			"option refname refs/heads/main\n",
-			"option old-oid " + oldID.String() + "\n",
-			"option new-oid " + newID.String() + "\n",
-			"option forced-update\n",
-			"ng refs/heads/dev rejected\n",
-			"0000",
-		}
-
-		for _, part := range wantParts {
-			if !strings.Contains(got, part) {
-				t.Fatalf("report-status-v2 missing %q in %q", part, got)
-			}
-		}
-	})
-}
-
-func TestWriteProgressRequiresSideBand64K(t *testing.T) {
-	t.Parallel()
-
-	base := common.NewSession(strings.NewReader(""), &bufferWriteFlusher{}, common.Options{})
-	session := receivepack.NewSession(base, receivepack.Capabilities{})
-
-	err := session.WriteProgress([]byte("progress\n"))
-	if !errors.Is(err, common.ErrSideBandNotEnabled) {
-		t.Fatalf("WriteProgress error = %v, want %v", err, common.ErrSideBandNotEnabled)
-	}
-}
-
-func TestProgressWriterDiscardsWithoutSideBand64K(t *testing.T) {
-	t.Parallel()
-
-	var out bufferWriteFlusher
-
-	base := common.NewSession(strings.NewReader(""), &out, common.Options{})
-	session := receivepack.NewSession(base, receivepack.Capabilities{})
-
-	n, err := io.WriteString(session.ProgressWriter(), "progress line\n")
-	if err != nil {
-		t.Fatalf("ProgressWriter.Write: %v", err)
-	}
-
-	if n != len("progress line\n") {
-		t.Fatalf("ProgressWriter.Write n = %d, want %d", n, len("progress line\n"))
-	}
-
-	if out.String() != "" {
-		t.Fatalf("unexpected wire output without side-band-64k: %q", out.String())
-	}
-}
-
-func TestProgressWriterUsesSideBand64KWhenNegotiated(t *testing.T) {
-	t.Parallel()
-
-	//nolint:thelper
-	testgit.ForEachAlgorithm(t, func(t *testing.T, algo objectid.Algorithm) {
-		t.Parallel()
-
-		var requestWire bufferWriteFlusher
-
-		requestEnc := pktline.NewEncoder(&requestWire)
-
-		err := requestEnc.WriteData([]byte(
-			objectid.Zero(algo).String() + " " + mustHexID(t, algo, "1").String() + " refs/heads/main\x00report-status side-band-64k object-format=" + algo.String() + "\n",
-		))
-		if err != nil {
-			t.Fatalf("WriteData(request): %v", err)
-		}
-
-		err = requestEnc.WriteFlush()
-		if err != nil {
-			t.Fatalf("WriteFlush(request): %v", err)
-		}
-
-		var out bufferWriteFlusher
-
-		base := common.NewSession(strings.NewReader(requestWire.String()), &out, common.Options{
-			Algorithm: algo,
-		})
-		session := receivepack.NewSession(base, receivepack.Capabilities{
-			ReportStatus: true,
-			SideBand64K:  true,
-			ObjectFormat: algo,
-		})
-
-		_, err = session.ReadRequest()
-		if err != nil {
-			t.Fatalf("ReadRequest: %v", err)
-		}
-
-		_, err = io.WriteString(session.ProgressWriter(), "remote: stage 1\r")
-		if err != nil {
-			t.Fatalf("ProgressWriter.Write: %v", err)
-		}
-
-		dec := sideband64k.NewDecoder(strings.NewReader(out.String()), sideband64k.ReadOptions{})
-
-		frame, err := dec.ReadFrame()
-		if err != nil {
-			t.Fatalf("ReadFrame(progress): %v", err)
-		}
-
-		if frame.Type != sideband64k.FrameProgress {
-			t.Fatalf("frame.Type = %v, want FrameProgress", frame.Type)
-		}
-
-		if string(frame.Payload) != "remote: stage 1\r" {
-			t.Fatalf("frame.Payload = %q, want %q", frame.Payload, "remote: stage 1\r")
-		}
-	})
-}