fiatjaf
6a686c31af
following nostr:nevent1qvzqqqqqqypzq3svyhng9ld8sv44950j957j9vchdktj7cxumsep9mvvjthc2pjuqy0hwumn8ghj7urewfsk66ty9enxjct5dfskvtnrdakj76twvfhhsqgawaehxw309aehqct5d9sj6ctjvdskucfwvdhk6tmfde3x77qqyqspzxnz3g0sway64qpjkszxx0qv666sce30dymn5mw467j709zejjvtka2
80 lines
1.8 KiB
Go
80 lines
1.8 KiB
Go
package test
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"testing"
|
|
|
|
"fiatjaf.com/nostr"
|
|
"fiatjaf.com/nostr/eventstore"
|
|
"fiatjaf.com/nostr/eventstore/boltdb"
|
|
"fiatjaf.com/nostr/eventstore/lmdb"
|
|
"fiatjaf.com/nostr/eventstore/mmm"
|
|
"fiatjaf.com/nostr/eventstore/slicestore"
|
|
"github.com/rs/zerolog"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
var (
|
|
dbpath = "/tmp/eventstore-test"
|
|
sk3 = nostr.MustSecretKeyFromHex("0000000000000000000000000000000000000000000000000000000000000003")
|
|
sk4 = nostr.MustSecretKeyFromHex("0000000000000000000000000000000000000000000000000000000000000004")
|
|
)
|
|
|
|
var ctx = context.Background()
|
|
|
|
var tests = []struct {
|
|
name string
|
|
run func(*testing.T, eventstore.Store)
|
|
}{
|
|
{"basic", basicTest},
|
|
{"first", runFirstTestOn},
|
|
{"second", runSecondTestOn},
|
|
{"manyauthors", manyAuthorsTest},
|
|
{"unbalanced", unbalancedTest},
|
|
{"count", countTest},
|
|
{"pfilter-until", pTagUntilMismatchTest},
|
|
}
|
|
|
|
func TestSliceStore(t *testing.T) {
|
|
for _, test := range tests {
|
|
t.Run(test.name, func(t *testing.T) { test.run(t, &slicestore.SliceStore{}) })
|
|
}
|
|
}
|
|
|
|
func TestLMDB(t *testing.T) {
|
|
for _, test := range tests {
|
|
os.RemoveAll(dbpath + "lmdb")
|
|
t.Run(test.name, func(t *testing.T) { test.run(t, &lmdb.LMDBBackend{Path: dbpath + "lmdb"}) })
|
|
}
|
|
}
|
|
|
|
func TestBoltDB(t *testing.T) {
|
|
for _, test := range tests {
|
|
os.RemoveAll(dbpath + "boltdb")
|
|
t.Run(test.name, func(t *testing.T) { test.run(t, &boltdb.BoltBackend{Path: dbpath + "boltdb"}) })
|
|
}
|
|
}
|
|
|
|
func TestMMM(t *testing.T) {
|
|
for _, test := range tests {
|
|
os.RemoveAll(dbpath + "mmm")
|
|
t.Run(test.name, func(t *testing.T) {
|
|
logger := zerolog.Nop()
|
|
|
|
mmmm := &mmm.MultiMmapManager{
|
|
Dir: dbpath + "mmm",
|
|
Logger: &logger,
|
|
}
|
|
|
|
err := mmmm.Init()
|
|
require.NoError(t, err)
|
|
|
|
il, err := mmmm.EnsureLayer("test")
|
|
require.NoError(t, err)
|
|
|
|
test.run(t, il)
|
|
})
|
|
}
|
|
}
|