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

refactor - tests

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-27 19:12:42 -07:00
parent e778fdbb8e
commit d5850ebe90
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
datastore/fsds.nim
View File

@ -117,7 +117,7 @@ proc readFile[V](self: FSDatastore, path: string): ?!V =
var
read = 0
echo "BYTES: ", bytes.repr
# echo "BYTES: ", bytes.repr
while read < size:
read += file.readBytes(bytes.toOpenArray(0, size-1), read, size)
@ -208,7 +208,9 @@ iterator iter*[K, V](handle: var DbQueryHandle[K, V, FsQueryEnv[K,V]]): ?!DbQuer
let root = $(handle.env)
for path in root.dirIter():
echo "FS:path: ", path
if handle.cancel:
echo "FS:CANCELLED!"
break
var
@ -222,6 +224,7 @@ iterator iter*[K, V](handle: var DbQueryHandle[K, V, FsQueryEnv[K,V]]): ?!DbQuer
let
flres = (basePath / path).absolutePath().catch
if flres.isErr():
echo "FS:ERROR: ", flres.error()
yield DbQueryResponse[K,V].failure flres.error()
let
@ -230,11 +233,13 @@ iterator iter*[K, V](handle: var DbQueryHandle[K, V, FsQueryEnv[K,V]]): ?!DbQuer
if handle.query.value:
let res = readFile[V](handle.env.self, flres.get)
if res.isErr():
echo "FS:ERROR: ", res.error()
yield DbQueryResponse[K,V].failure res.error()
res.get()
else:
V.new()
echo "FS:SUCCESS: ", key
yield success (key.some, data)
proc newFSDatastore*[K,V](root: string,