aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/rosa/mirror_test.go
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2026-06-07 21:12:15 +0900
committerOphestra <cat@gensokyo.uk>2026-06-07 22:08:57 +0900
commit38450db74abdddfb3e366516f46e0e9c291002b1 (patch)
treef985cd99b1be1d094d7465c07132d32f2046a8eb /internal/rosa/mirror_test.go
parent9344f694c7d8ec02f118bffa6f556f5b1cc7395c (diff)
internal/rosa: access backing storage through fs
This is more versatile than hardcoding the os.Root implementation. Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/rosa/mirror_test.go')
-rw-r--r--internal/rosa/mirror_test.go77
1 files changed, 77 insertions, 0 deletions
diff --git a/internal/rosa/mirror_test.go b/internal/rosa/mirror_test.go
new file mode 100644
index 00000000..a671cd31
--- /dev/null
+++ b/internal/rosa/mirror_test.go
@@ -0,0 +1,77 @@
+package rosa_test
+
+import (
+ "crypto/ed25519"
+ "io/fs"
+ "log"
+ "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, 0, 0, 0, base)
+ 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)
+
+ server := httptest.NewServer(rosa.NewMirror(msg, fstest.MapFS{
+ "identifier/" + ids: {Mode: fs.ModeSymlink | 0777, Data: []byte("../checksum/" + wantChecksums)},
+ "checksum/" + wantChecksums: {Mode: os.ModeDir | 0500},
+ }, priv))
+ t.Cleanup(server.Close)
+
+ var extern pkg.External
+ extern, err = rosa.NewRemote("http://example.com:80", pub, server.Client())
+ 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),
+ )
+ }
+}