1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
package service_test
import (
"context"
"os"
"strings"
"testing"
"codeberg.org/lindenii/furgit/internal/testgit"
"codeberg.org/lindenii/furgit/network/receivepack/service"
objectid "codeberg.org/lindenii/furgit/object/id"
objectstore "codeberg.org/lindenii/furgit/object/store"
objectdual "codeberg.org/lindenii/furgit/object/store/dual"
objectloose "codeberg.org/lindenii/furgit/object/store/loose"
"codeberg.org/lindenii/furgit/object/store/memory"
objectpacked "codeberg.org/lindenii/furgit/object/store/packed"
)
func TestExecutePackExpectedWithoutObjectIngress(t *testing.T) {
t.Parallel()
//nolint:thelper
testgit.ForEachAlgorithm(t, func(t *testing.T, algo objectid.Algorithm) {
t.Parallel()
store := memory.New(algo)
svc := service.New(service.Options{
ExistingObjects: store,
})
result, err := svc.Execute(context.Background(), &service.Request{
Commands: []service.Command{{
Name: "refs/heads/main",
OldID: algo.Zero(),
NewID: algo.Zero(),
}},
PackExpected: true,
Pack: strings.NewReader("not a pack"),
})
if err != nil {
t.Fatalf("Execute: %v", err)
}
if result.UnpackError != "object ingress not configured" {
t.Fatalf("unexpected unpack error %q", result.UnpackError)
}
})
}
func TestExecuteDiscardedQuarantineAfterIngestFailure(t *testing.T) {
t.Parallel()
//nolint:thelper
testgit.ForEachAlgorithm(t, func(t *testing.T, algo objectid.Algorithm) {
t.Parallel()
store := memory.New(algo)
objectIngress := newDualIngress(t, algo)
svc := service.New(service.Options{
ExistingObjects: store,
ObjectIngress: objectIngress,
})
result, err := svc.Execute(context.Background(), &service.Request{
Commands: []service.Command{{
Name: "refs/heads/main",
OldID: algo.Zero(),
NewID: algo.Zero(),
}},
PackExpected: true,
Pack: strings.NewReader("not a pack"),
})
if err != nil {
t.Fatalf("Execute: %v", err)
}
if result.UnpackError == "" {
t.Fatal("Execute returned empty unpack error for invalid pack")
}
})
}
func newDualIngress(tb testing.TB, algo objectid.Algorithm) objectstore.Quarantiner {
tb.Helper()
objectsRoot, err := os.OpenRoot(tb.TempDir())
if err != nil {
tb.Fatalf("os.OpenRoot: %v", err)
}
tb.Cleanup(func() {
_ = objectsRoot.Close()
})
err = objectsRoot.Mkdir("pack", 0o755)
if err != nil {
tb.Fatalf("Mkdir(pack): %v", err)
}
packRoot, err := objectsRoot.OpenRoot("pack")
if err != nil {
tb.Fatalf("OpenRoot(pack): %v", err)
}
tb.Cleanup(func() {
_ = packRoot.Close()
})
looseStore, err := objectloose.New(objectsRoot, algo)
if err != nil {
tb.Fatalf("loose.New: %v", err)
}
tb.Cleanup(func() {
_ = looseStore.Close()
})
packedStore, err := objectpacked.New(packRoot, algo, objectpacked.Options{WriteRev: true})
if err != nil {
tb.Fatalf("packed.New: %v", err)
}
tb.Cleanup(func() {
_ = packedStore.Close()
})
return objectdual.New(looseStore, packedStore)
}
|
