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

refactor tests

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-27 18:39:20 -07:00
parent 2a96b1bcef
commit 4fa532e72a
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
datastore/fsds.nim
View File

@ -65,16 +65,15 @@ proc findPath*[K,V](self: FSDatastore[K,V], key: K): ?!string =
return success fullname
proc has*[K,V](self: FSDatastore[K,V], key: KeyId): ?!bool =
let key = key.toKey()
return self.findPath(key).?fileExists()
proc has*[K,V](self: FSDatastore[K,V], key: K): ?!bool =
without path =? self.findPath(key), error:
return failure error
success path.fileExists()
proc contains*[K](self: FSDatastore, key: K): bool =
return self.has(key).get()
proc delete*[K,V](self: FSDatastore[K,V], key: KeyId): ?!void =
let key = key.toKey()
proc delete*[K,V](self: FSDatastore[K,V], key: K): ?!void =
without path =? self.findPath(key), error:
return failure error
@ -88,7 +87,7 @@ proc delete*[K,V](self: FSDatastore[K,V], key: KeyId): ?!void =
return success()
proc delete*[K,V](self: FSDatastore[K,V], keys: openArray[KeyId]): ?!void =
proc delete*[K,V](self: FSDatastore[K,V], keys: openArray[K]): ?!void =
for key in keys:
if err =? self.delete(key).errorOption:
return failure err
@ -131,8 +130,7 @@ proc readFile[V](self: FSDatastore, path: string): ?!V =
except CatchableError as e:
return failure e
proc get*[K,V](self: FSDatastore[K,V], key: KeyId): ?!DataBuffer =
let key = key.toKey()
proc get*[K,V](self: FSDatastore[K,V], key: K): ?!DataBuffer =
without path =? self.findPath(key), error:
return failure error
@ -159,9 +157,9 @@ proc put*[K,V](
return success()
proc put*(
proc put*[K,V](
self: FSDatastore,
batch: seq[DbBatchEntry[KeyId, DataBuffer]]): ?!void =
batch: seq[DbBatchEntry[K, V]]): ?!void =
for entry in batch:
if err =? self.put(entry.key, entry.data).errorOption: