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

update fsds

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-27 17:31:22 -07:00
parent 131712071f
commit bda61df77e
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
datastore/fsds.nim
View File

@ -176,12 +176,12 @@ proc close*(self: FSDatastore): ?!void =
return success() return success()
type type
FsQueryEnv* = tuple[basePath: DataBuffer, self: FSDatastore] FsQueryEnv* = tuple[self: FSDatastore, basePath: DataBuffer]
proc query*( proc query*(
self: FSDatastore, self: FSDatastore,
query: DbQuery[KeyId], query: DbQuery[KeyId],
): Result[DbQueryHandle[KeyId, DataBuffer, KeyId], ref CatchableError] = ): Result[DbQueryHandle[KeyId, DataBuffer, FsQueryEnv], ref CatchableError] =
let key = query.key.toKey() let key = query.key.toKey()
without path =? self.findPath(key), error: without path =? self.findPath(key), error:
@ -196,6 +196,9 @@ proc query*(
path.parentDir path.parentDir
else: else:
path.changeFileExt("") path.changeFileExt("")
let env: FsQueryEnv = (self: self, basePath: DataBuffer.new(basePath))
success DbQueryHandle[KeyId, DataBuffer, FsQueryEnv](env: env)
iterator iter*[K, V](handle: var DbQueryHandle[K, V, DataBuffer]): ?!DbQueryResponse[K, V] = iterator iter*[K, V](handle: var DbQueryHandle[K, V, DataBuffer]): ?!DbQueryResponse[K, V] =
let root = $(handle.env) let root = $(handle.env)