aboutsummaryrefslogtreecommitdiff
path: root/internal/storage/blocklog_test.go
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-02-26 15:41:45 -0800
committerFuwn <[email protected]>2026-02-26 15:41:45 -0800
commitfec9114caaa7d274e524793d5eb0cf2ef2c5af11 (patch)
tree0897394ccdfaf6633e1a4ca8eb02bff49bb93c00 /internal/storage/blocklog_test.go
parentfeat: add read-only PLC API compatibility endpoints (diff)
downloadplutia-test-fec9114caaa7d274e524793d5eb0cf2ef2c5af11.tar.xz
plutia-test-fec9114caaa7d274e524793d5eb0cf2ef2c5af11.zip
feat: Apply Iku formatting
Diffstat (limited to 'internal/storage/blocklog_test.go')
-rw-r--r--internal/storage/blocklog_test.go14
1 files changed, 14 insertions, 0 deletions
diff --git a/internal/storage/blocklog_test.go b/internal/storage/blocklog_test.go
index 23045cc..a71febf 100644
--- a/internal/storage/blocklog_test.go
+++ b/internal/storage/blocklog_test.go
@@ -9,6 +9,7 @@ import (
func TestBlockLogAppendReadFlush(t *testing.T) {
tmp := t.TempDir()
log, err := OpenBlockLog(tmp, 3, 4)
+
if err != nil {
t.Fatalf("OpenBlockLog: %v", err)
}
@@ -16,40 +17,53 @@ func TestBlockLogAppendReadFlush(t *testing.T) {
payload1 := []byte(`{"op":1}`)
payload2 := []byte(`{"op":2}`)
ref1, flush, err := log.Append(1, "did:plc:a", "cid1", "", payload1)
+
if err != nil {
t.Fatalf("append 1: %v", err)
}
+
if flush != nil {
t.Fatalf("unexpected automatic flush")
}
+
ref2, _, err := log.Append(2, "did:plc:a", "cid2", "cid1", payload2)
+
if err != nil {
t.Fatalf("append 2: %v", err)
}
flushed, err := log.Flush()
+
if err != nil {
t.Fatalf("flush: %v", err)
}
+
if flushed == nil {
t.Fatalf("expected flushed block")
}
+
blockFile := filepath.Join(tmp, "ops", "000001.zst")
+
if _, err := os.Stat(blockFile); err != nil {
t.Fatalf("expected block file: %v", err)
}
got1, err := log.ReadRecord(ref1)
+
if err != nil {
t.Fatalf("read record1: %v", err)
}
+
if string(got1) != string(payload1) {
t.Fatalf("payload1 mismatch: got %s want %s", got1, payload1)
}
+
got2, err := log.ReadRecord(ref2)
+
if err != nil {
t.Fatalf("read record2: %v", err)
}
+
if string(got2) != string(payload2) {
t.Fatalf("payload2 mismatch: got %s want %s", got2, payload2)
}