diff options
| author | Fuwn <[email protected]> | 2026-02-26 15:41:45 -0800 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2026-02-26 15:41:45 -0800 |
| commit | fec9114caaa7d274e524793d5eb0cf2ef2c5af11 (patch) | |
| tree | 0897394ccdfaf6633e1a4ca8eb02bff49bb93c00 /internal/storage/pebble_store_batch_test.go | |
| parent | feat: add read-only PLC API compatibility endpoints (diff) | |
| download | plutia-test-fec9114caaa7d274e524793d5eb0cf2ef2c5af11.tar.xz plutia-test-fec9114caaa7d274e524793d5eb0cf2ef2c5af11.zip | |
feat: Apply Iku formatting
Diffstat (limited to 'internal/storage/pebble_store_batch_test.go')
| -rw-r--r-- | internal/storage/pebble_store_batch_test.go | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/internal/storage/pebble_store_batch_test.go b/internal/storage/pebble_store_batch_test.go index 85afc92..742e7bf 100644 --- a/internal/storage/pebble_store_batch_test.go +++ b/internal/storage/pebble_store_batch_test.go @@ -3,16 +3,17 @@ package storage import ( "testing" "time" - "github.com/Fuwn/plutia/internal/types" ) func TestPebbleStoreApplyOperationBatch(t *testing.T) { tmp := t.TempDir() store, err := OpenPebble(tmp) + if err != nil { t.Fatalf("open pebble: %v", err) } + defer store.Close() state := types.StateV1{ @@ -39,35 +40,43 @@ func TestPebbleStoreApplyOperationBatch(t *testing.T) { } gotState, ok, err := store.GetState(state.DID) + if err != nil || !ok { t.Fatalf("get state: ok=%v err=%v", ok, err) } + if gotState.ChainTipHash != state.ChainTipHash || gotState.LatestOpSeq != state.LatestOpSeq { t.Fatalf("state mismatch: got tip=%s seq=%d", gotState.ChainTipHash, gotState.LatestOpSeq) } head, ok, err := store.GetChainHead(state.DID) + if err != nil || !ok || head != state.LatestOpSeq { t.Fatalf("chain head mismatch: head=%d ok=%v err=%v", head, ok, err) } seqs, err := store.ListDIDSequences(state.DID) + if err != nil { t.Fatalf("list did sequences: %v", err) } + if len(seqs) != 1 || seqs[0] != state.LatestOpSeq { t.Fatalf("did sequence mismatch: %v", seqs) } gotRef, ok, err := store.GetOpSeqRef(state.LatestOpSeq) + if err != nil || !ok { t.Fatalf("get opseq ref: ok=%v err=%v", ok, err) } + if gotRef.BlockID != ref.BlockID || gotRef.CID != ref.CID { t.Fatalf("op ref mismatch: got block=%d cid=%s", gotRef.BlockID, gotRef.CID) } globalSeq, err := store.GetGlobalSeq() + if err != nil || globalSeq != state.LatestOpSeq { t.Fatalf("global seq mismatch: seq=%d err=%v", globalSeq, err) } |