logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-05 23: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:00:54 -07:00
parent 1c2c5f1020
commit 534555015b
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
datastore/fsds.nim
View File

@ -178,14 +178,16 @@ proc close*[K,V](self: FSDatastore[K,V]): ?!void =
return success()
type
FsQueryEnv*[K,V] = tuple[self: FSDatastore[K,V], basePath: V]
FsQueryEnv*[K,V] = object
self: FSDatastore[K,V]
basePath: DataBuffer
proc query*[K,V](
self: FSDatastore[K,V],
query: DbQuery[K],
): Result[DbQueryHandle[KeyId, V, FsQueryEnv], ref CatchableError] =
): Result[DbQueryHandle[K, V, FsQueryEnv[K,V]], ref CatchableError] =
let key = query.key.toKey()
let key = query.key
without path =? self.findPath(key), error:
return failure error
@ -199,8 +201,8 @@ proc query*[K,V](
else:
path.changeFileExt("")
let env: FsQueryEnv = (self: self, basePath: V.new(basePath))
success DbQueryHandle[KeyId, V, FsQueryEnv](env: env)
let env = FsQueryEnv[K,V](self: self, basePath: DataBuffer.new(basePath))
success DbQueryHandle[KeyId, V, FsQueryEnv[K,V]](env: env)
iterator iter*[K, V](handle: var DbQueryHandle[K, V, V]): ?!DbQueryResponse[K, V] =
let root = $(handle.env)