logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-07 16:13:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

make sure all tests pass

Browse Source
This commit is contained in:
Dmitriy Ryajov 2023-09-13 14:43:25 -06:00
parent 88eb96edb3
commit 6c86d2b10e
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
1 changed files with 22 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
tests/datastore/testthreadproxyds.nim
View File

@ -1,6 +1,7 @@
import std/options import std/options
import std/sequtils import std/sequtils
import std/os import std/os
import std/cpuinfo
import std/algorithm import std/algorithm
import pkg/asynctest import pkg/asynctest
@ -9,55 +10,16 @@ import pkg/stew/results
import pkg/stew/byteutils import pkg/stew/byteutils
import pkg/taskpools import pkg/taskpools
import pkg/datastore/memoryds import pkg/datastore/sql
import pkg/datastore/threads/threadproxyds import pkg/datastore/threads/threadproxyds
import ./dscommontests import ./dscommontests
# import ./querycommontests import ./querycommontests
import pretty suite "Test Basic ThreadDatastore":
# suite "Test Basic ThreadProxyDatastore":
# var
# sds: ThreadDatastore
# mem: MemoryDatastore
# key1: Key
# data: seq[byte]
# taskPool: Taskpool
# setupAll:
# mem = MemoryDatastore.new()
# taskPool = TaskPool.new(3)
# sds = ThreadDatastore.new(mem, taskPool).expect("should work")
# key1 = Key.init("/a").tryGet
# data = "value for 1".toBytes()
# test "check put":
# echo "\n\n=== put ==="
# let res1 = await sds.put(key1, data)
# print "res1: ", res1
# test "check get":
# echo "\n\n=== get ==="
# let res2 = await sds.get(key1)
# check res2.get() == data
# var val = ""
# for c in res2.get():
# val &= char(c)
# print "get res2: ", $val
# # echo "\n\n=== put cancel ==="
# # # let res1 = await sds.put(key1, "value for 1".toBytes())
# # let res3 = sds.put(key1, "value for 1".toBytes())
# # res3.cancel()
# # # print "res3: ", res3
suite "Test Basic ThreadProxyDatastore":
var var
memStore: MemoryDatastore memStore: Datastore
ds: ThreadDatastore ds: ThreadDatastore
key = Key.init("/a/b").tryGet() key = Key.init("/a/b").tryGet()
bytes = "some bytes".toBytes bytes = "some bytes".toBytes
@ -65,23 +27,29 @@ suite "Test Basic ThreadProxyDatastore":
taskPool: Taskpool taskPool: Taskpool
setupAll: setupAll:
memStore = MemoryDatastore.new() memStore = SQLiteDatastore.new(Memory).tryGet()
taskPool = Taskpool.new(2) taskPool = Taskpool.new(countProcessors() * 2)
ds = ThreadDatastore.new(memStore, taskPool).tryGet() ds = ThreadDatastore.new(memStore, taskPool).tryGet()
teardownAll: teardownAll:
(await memStore.close()).get() (await ds.close()).tryGet()
taskPool.shutdown()
basicStoreTests(ds, key, bytes, otherBytes) basicStoreTests(ds, key, bytes, otherBytes)
# suite "Test Query": suite "Test Query ThreadDatastore":
# var var
# mem: MemoryDatastore mem: Datastore
# sds: ThreadProxyDatastore ds: ThreadDatastore
taskPool: Taskpool
# setup: setup:
# mem = MemoryDatastore.new() taskPool = Taskpool.new(countProcessors() * 2)
# sds = newThreadProxyDatastore(mem).expect("should work") mem = SQLiteDatastore.new(Memory).tryGet()
ds = ThreadDatastore.new(mem, taskPool).tryGet()
# queryTests(sds, false) teardown:
(await ds.close()).tryGet()
taskPool.shutdown()
queryTests(ds, false)