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
|
package rosa_test
import (
"crypto/ed25519"
"io/fs"
"log"
"net/http"
"net/http/httptest"
"os"
"testing"
"testing/fstest"
"unique"
"hakurei.app/check"
"hakurei.app/fhs"
"hakurei.app/internal/pkg"
"hakurei.app/internal/rosa"
"hakurei.app/message"
)
func TestMirror(t *testing.T) {
t.Parallel()
pub, priv, err := ed25519.GenerateKey(nil)
if err != nil {
t.Fatal(err)
}
base := check.MustAbs(t.TempDir())
msg := message.New(log.New(os.Stderr, "mirror: ", 0))
msg.SwapVerbose(testing.Verbose())
var c *pkg.Cache
c, err = pkg.Open(t.Context(), msg, base, nil)
if err != nil {
t.Fatal(err)
}
t.Cleanup(c.Close)
a := pkg.NewExec(
"", "",
nil, 0, false, false,
fhs.AbsRoot, nil, fhs.AbsRoot, nil,
)
id := c.Ident(a)
ids := pkg.Encode(id.Value())
var wantChecksum pkg.Checksum
if err = pkg.SumFS(&wantChecksum, fstest.MapFS{
".": {Mode: os.ModeDir | 0500},
}, "."); err != nil {
t.Fatal(err)
}
wantChecksums := pkg.Encode(wantChecksum)
var mux http.ServeMux
rosa.NewMirror(msg, fstest.MapFS{
"identifier/" + ids: {Mode: fs.ModeSymlink | 0777, Data: []byte("../checksum/" + wantChecksums)},
"checksum/" + wantChecksums: {Mode: os.ModeDir | 0500},
}, priv).Register(&mux)
server := httptest.NewServer(&mux)
t.Cleanup(server.Close)
var extern pkg.External
extern, err = rosa.NewRemote(server.Client(), "http://example.com:80", pub)
if err != nil {
t.Fatal(err)
}
c.SetExternal(extern)
var got unique.Handle[pkg.Checksum]
if _, got, err = c.Cure(a); err != nil {
t.Fatal(err)
} else if got.Value() != wantChecksum {
t.Logf(
"Cure: checksum = %s, want %s",
pkg.Encode(got.Value()), pkg.Encode(wantChecksum),
)
}
}
|
