Function TestCommitServiceV1ReturnsProtobuf

internal/connect/api_test.go:316–361

--- Handler content-type tests ---

(t *testing.T)

// --- Handler content-type tests ---

func TestCommitServiceV1ReturnsProtobuf(t *testing.T) {
	p := &mockProvider{
		meta: content.Meta{
			Commit:        "deadbeef",
			DefaultBranch: "main",
		},
		files: []content.File{
			{Path: "test.proto", Data: []byte("syntax = \"proto3\";"), Hash: shake256.Hash{}},
		},
	}
	mux := testMux(p)
	server := httptest.NewServer(mux)
	defer server.Close()

	for _, path := range []string{
		"/buf.registry.module.v1.CommitService/GetCommits",
		"/buf.registry.module.v1beta1.CommitService/GetCommits",
	} {
		t.Run(path, func(t *testing.T) {
			body := buildGetCommitsRequest("owner", "repo")
			resp, err := http.Post(server.URL+path, "application/proto", bytes.NewReader(body))
			if err != nil {
				t.Fatalf("request failed: %v", err)
			}
			defer resp.Body.Close()

			if ct := resp.Header.Get("Content-Type"); ct != "application/proto" {
				t.Errorf("Content-Type = %q, want %q", ct, "application/proto")
			}
			if resp.StatusCode != http.StatusOK {
				respBody, _ := io.ReadAll(resp.Body)
				t.Fatalf("status = %d, want 200; body: %s", resp.StatusCode, respBody)
			}

			respBody, _ := io.ReadAll(resp.Body)
			if len(respBody) == 0 {
				t.Fatal("empty response body")
			}
			// Verify it's valid protobuf: should start with field tag
			_, _, n := protowire.ConsumeTag(respBody)
			if n < 0 {
				t.Fatalf("response is not valid protobuf: %x", respBody[:min(len(respBody), 32)])
			}
		})
	}
}

func TestGraphServiceV1ReturnsProtobuf(t *testing.T) {
	p := &mockProvider{