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/blocklog_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/blocklog_test.go')
| -rw-r--r-- | internal/storage/blocklog_test.go | 14 |
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) } |