| 24 | } |
| 25 | |
| 26 | func TestDBPutGet(t *testing.T) { |
| 27 | tmpDir, err := os.MkdirTemp("", "ipfs-synckv-test") |
| 28 | require.NoError(t, err) |
| 29 | defer os.RemoveAll(tmpDir) |
| 30 | |
| 31 | cfg := config.NewConfigDefault() |
| 32 | store := Store{} |
| 33 | db, err := store.Open(tmpDir, cfg) |
| 34 | require.NoError(t, err) |
| 35 | defer db.Close() |
| 36 | |
| 37 | key := []byte("test-key") |
| 38 | value := []byte("test-value") |
| 39 | |
| 40 | err = db.Put(key, value) |
| 41 | require.NoError(t, err) |
| 42 | |
| 43 | gotValue, err := db.Get(key) |
| 44 | require.NoError(t, err) |
| 45 | require.Equal(t, value, gotValue) |
| 46 | } |
| 47 | |
| 48 | func TestDBDelete(t *testing.T) { |
| 49 | tmpDir, err := os.MkdirTemp("", "ipfs-synckv-test") |