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
|
package api
import (
"net/http/httptest"
"path/filepath"
"strings"
"testing"
"github.com/Fuwn/plutia/internal/config"
"github.com/Fuwn/plutia/internal/storage"
"github.com/Fuwn/plutia/internal/types"
)
func TestSelectCheckpointForProofDetectsLatestAdvance(t *testing.T) {
dataDir := t.TempDir()
store, err := storage.OpenPebble(dataDir)
if err != nil {
t.Fatalf("open pebble: %v", err)
}
defer store.Close()
if err := store.PutCheckpoint(types.CheckpointV1{
Version: 1,
Sequence: 10,
DIDMerkleRoot: "root-10",
CheckpointHash: "cp-10",
Signature: "sig-10",
}); err != nil {
t.Fatalf("put checkpoint 10: %v", err)
}
srv := NewServer(config.Default(), store, nil, nil)
req := httptest.NewRequest("GET", "/did/did:plc:alice/proof", nil)
cp, verifyUnchanged, err := srv.selectCheckpointForProof(req)
if err != nil {
t.Fatalf("select checkpoint: %v", err)
}
if cp.Sequence != 10 {
t.Fatalf("selected unexpected checkpoint sequence: got %d want 10", cp.Sequence)
}
if err := store.PutCheckpoint(types.CheckpointV1{
Version: 1,
Sequence: 11,
DIDMerkleRoot: "root-11",
CheckpointHash: "cp-11",
Signature: "sig-11",
}); err != nil {
t.Fatalf("put checkpoint 11: %v", err)
}
if err := verifyUnchanged(); err == nil || !strings.Contains(err.Error(), "advanced") {
t.Fatalf("expected latest-checkpoint advance error, got: %v", err)
}
}
func TestSelectCheckpointForProofDetectsHistoricalMutation(t *testing.T) {
dataDir := t.TempDir()
store, err := storage.OpenPebble(filepath.Clean(dataDir))
if err != nil {
t.Fatalf("open pebble: %v", err)
}
defer store.Close()
if err := store.PutCheckpoint(types.CheckpointV1{
Version: 1,
Sequence: 20,
DIDMerkleRoot: "root-20-a",
CheckpointHash: "cp-20-a",
Signature: "sig-20-a",
}); err != nil {
t.Fatalf("put checkpoint 20(a): %v", err)
}
srv := NewServer(config.Default(), store, nil, nil)
req := httptest.NewRequest("GET", "/did/did:plc:alice/proof?checkpoint=20", nil)
cp, verifyUnchanged, err := srv.selectCheckpointForProof(req)
if err != nil {
t.Fatalf("select historical checkpoint: %v", err)
}
if cp.CheckpointHash != "cp-20-a" {
t.Fatalf("selected unexpected checkpoint hash: got %s", cp.CheckpointHash)
}
if err := store.PutCheckpoint(types.CheckpointV1{
Version: 1,
Sequence: 20,
DIDMerkleRoot: "root-20-b",
CheckpointHash: "cp-20-b",
Signature: "sig-20-b",
}); err != nil {
t.Fatalf("put checkpoint 20(b): %v", err)
}
if err := verifyUnchanged(); err == nil || !strings.Contains(err.Error(), "changed") {
t.Fatalf("expected historical-checkpoint changed error, got: %v", err)
}
}
|