mirror of
https://github.com/logos-storage/nim-datastore.git
synced 2026-01-03 14:13:09 +00:00
passing basic ds tests
This commit is contained in:
parent
a11a681a6f
commit
8445920232
@ -84,5 +84,3 @@ proc new*(tp: typedesc[KeyBuffer], key: Key): KeyBuffer =
|
||||
KeyBuffer.new(key.id())
|
||||
proc toKey*(kb: KeyBuffer): Result[Key, ref CatchableError] =
|
||||
Key.init(kb.toString())
|
||||
proc new*(tp: typedesc[ValueBuffer], data: seq[byte]): KeyBuffer =
|
||||
DataBuffer.new(data)
|
||||
|
||||
@ -62,8 +62,9 @@ method get*(
|
||||
print "get: ", k.toString(), " v: ", v.toString().repr
|
||||
|
||||
if self.store.hasKey(dk):
|
||||
let res = self.store[dk]
|
||||
return success res.toSeq(byte)
|
||||
let res = self.store[dk].toSeq(byte)
|
||||
print "get:res: ", res
|
||||
return success res
|
||||
else:
|
||||
return failure (ref DatastoreError)(msg: "no such key")
|
||||
|
||||
@ -74,7 +75,7 @@ method put*(
|
||||
): Future[?!void] {.async.} =
|
||||
|
||||
let dk = KeyBuffer.new(key)
|
||||
let dv = ValueBuffer.new(key)
|
||||
let dv = ValueBuffer.new(data)
|
||||
self.store[dk] = dv
|
||||
return success()
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user