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

test query - it runs!

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 18:45:52 -07:00
parent 9cd0ae7ea5
commit f8446de638
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 32 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
tests/datastore/querycommontests.nim
View File

@ -132,49 +132,49 @@ template queryTests*(ds: Datastore, extended = true) {.dirty.} =
(await iter.dispose()).tryGet
# test "Key should all list all keys at the same level":
# let
# queryKey = Key.init("/a").tryGet
# q = Query.init(queryKey)
test "Key should all list all keys at the same level":
let
queryKey = Key.init("/a").tryGet
q = Query.init(queryKey)
# (await ds.put(key1, val1)).tryGet
# (await ds.put(key2, val2)).tryGet
# (await ds.put(key3, val3)).tryGet
(await ds.put(key1, val1)).tryGet
(await ds.put(key2, val2)).tryGet
(await ds.put(key3, val3)).tryGet
# let
# iter = (await ds.query(q)).tryGet
let
iter = (await ds.query(q)).tryGet
# var
# res = block:
# var
# res: seq[QueryResponse]
# cnt = 0
var
res = block:
var
res: seq[QueryResponse]
cnt = 0
# for pair in iter:
# let (key, val) = (await pair).tryGet
# if key.isNone:
# break
for pair in iter:
let (key, val) = (await pair).tryGet
if key.isNone:
break
# res.add((key, val))
# cnt.inc
res.add((key, val))
cnt.inc
# res
res
# res.sort do (a, b: QueryResponse) -> int:
# cmp(a.key.get.id, b.key.get.id)
res.sort do (a, b: QueryResponse) -> int:
cmp(a.key.get.id, b.key.get.id)
# check:
# res.len == 3
# res[0].key.get == key1
# res[0].data == val1
check:
res.len == 3
res[0].key.get == key1
res[0].data == val1
# res[1].key.get == key2
# res[1].data == val2
res[1].key.get == key2
res[1].data == val2
# res[2].key.get == key3
# res[2].data == val3
res[2].key.get == key3
res[2].data == val3
# (await iter.dispose()).tryGet
(await iter.dispose()).tryGet
if extended:
test "Should apply limit":