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

implementing query type

Browse Source
This commit is contained in:
Jaremy Creechley 2023-08-29 19:43:28 -07:00 committed by Dmitriy Ryajov
parent a95cd9cd26
commit b1a5b9cff8
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datastore/threadbackend.nim
View File

@ -62,6 +62,8 @@ proc convert*[T, S](ret: TResult[T], tp: typedesc[S]): Result[S, ref CatchableEr
result.ok(ret[].results.get().toString())
elif S is void:
result.ok()
elif S is QueryResponse:
result.ok(ret[].results.get().toQueryResponse())
else:
result.ok(ret[].results.get())
else:

30
datastore/threadproxyds.nim
View File

@ -130,30 +130,38 @@ method query*(
without ret =? newThreadResult(QueryResponseBuffer), err:
return failure(err)
try:
## we need to setup the query iter on the main thread
## to keep it's lifetime associated with this async Future
without it =? await self.tds[].ds.query(query), err:
ret.failure(err)
## we need to setup the query iter on the main thread
## to keep it's lifetime associated with this async Future
without it =? await self.tds[].ds.query(query), err:
ret.failure(err)
var iter = newSharedPtr(QueryIterStore)
## note that bypasses SharedPtr isolation - may need `protect` here?
iter[].it = it
var iter = newSharedPtr(QueryIterStore)
## note that bypasses SharedPtr isolation - may need `protect` here?
iter[].it = it
var iterWrapper = QueryIter.new()
proc next(): Future[?!QueryResponse] {.async.} =
echo "\n\n=== Query Start === "
while not iter[].it.finished:
if not iter[].it.finished:
echo ""
query(ret, self.tds, iter)
await wait(ret[].signal)
print "query:post: ", ret[].results
print "query:post: ", " qrb:key: ", ret[].results.get().key.toString()
print "query:post: ", " qrb:data: ", ret[].results.get().data.toString()
return ret.convert(QueryResponse)
else:
iterWrapper.finished = true
proc dispose(): Future[?!void] {.async.} =
iter[].it = nil # ensure our sharedptr doesn't try and dealloc
finally:
ret[].signal.close()
return success()
# return ret.convert(void)
iterWrapper.next = next
iterWrapper.dispose = dispose
return success iterWrapper
method close*(
self: ThreadProxyDatastore