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 sqliteds

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-20 17:19:03 -07:00
parent 84bbfa687e
commit ea3546f5b3
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
datastore/sql/sqliteds.nim
View File

@ -101,9 +101,10 @@ proc close*(self: SQLiteDatastore): ?!void =
return success() return success()
proc query*(self: SQLiteDatastore,
iterator query*(self: SQLiteDatastore,
query: Query query: Query
): ?!QueryIter {.async.} = ): ?!ThreadQueryRes =
var var
iter = QueryIter() iter = QueryIter()

3
datastore/threads/threadresult.nim
View File

@ -22,6 +22,9 @@ type
ThreadQueryRes* = (DataBuffer, DataBuffer) ThreadQueryRes* = (DataBuffer, DataBuffer)
ThreadResult*[T: ThreadTypes] = Result[T, ThreadResErr] ThreadResult*[T: ThreadTypes] = Result[T, ThreadResErr]
DbKey* = tuple[data: DataBuffer]
DbValue* = tuple[data: DataBuffer]
converter toThreadErr*(e: ref CatchableError): ThreadResErr {.inline, raises: [].} = converter toThreadErr*(e: ref CatchableError): ThreadResErr {.inline, raises: [].} =
if e of DatastoreKeyNotFound: (ErrorEnum.DatastoreKeyNotFoundErr, DataBuffer.new(e.msg)) if e of DatastoreKeyNotFound: (ErrorEnum.DatastoreKeyNotFoundErr, DataBuffer.new(e.msg))
elif e of QueryEndedError: (ErrorEnum.QueryEndedErr, DataBuffer.new(e.msg)) elif e of QueryEndedError: (ErrorEnum.QueryEndedErr, DataBuffer.new(e.msg))