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

setup OpenArrayHolder conversion

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-16 14:44:06 -07:00
parent ee418a09d3
commit 2ed1b2102e
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/apatheia/tasks.nim
View File

@ -10,7 +10,7 @@ export jobs
template convertParamType*[T](obj: OpenArrayHolder[T]): auto =
static:
echo "CONVERTPARAMTYPE:: ", $typeof(obj)
obj
obj.toOpenArray()
template convertParamType*(obj: typed): auto =
obj
@ -45,7 +45,6 @@ macro asyncTask*(p: untyped): untyped =
let val {.inject.} = `tcall`
discard jobResult.queue.send((jobResult.id, val))
var asyncParams = params.copyNimTree()
let retType =
if not hasReturnType(params):
ident"void"
@ -55,8 +54,21 @@ macro asyncTask*(p: untyped): untyped =
let jobArg = nnkIdentDefs.newTree(
ident"jobResult", nnkBracketExpr.newTree(ident"JobResult", retType), newEmptyNode()
)
asyncParams[0] = newEmptyNode()
asyncParams.insert(1, jobArg)
var asyncParams = nnkFormalParams.newTree()
echo "TASKER: ", asyncParams.treeRepr
asyncParams.add newEmptyNode()
asyncParams.add jobArg
for i, p in params[1..^1]:
echo "TASKER: PARAM: ", p.treeRepr
let pt = p[1]
if pt.kind == nnkBracketExpr and pt[0].repr == "openArray":
echo "TASKER: PARAM: ", "FOUND OPEN PARAM"
p[1] = nnkBracketExpr.newTree(ident"OpenArrayHolder", pt[1])
asyncParams.add p
else:
asyncParams.add p
let fn = mkProc(procId, asyncParams, asyncBody)
result = newStmtList()