mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-02 14:03:06 +00:00
13316201f7
* bump_dependencies.md: add nim-results dependency * change imports stew/results to results * switching to Nim 2.0.8 * waku.nimble: reflect the requirement nim 1.6.0 to 2.0.8 Adding --mm:refc as nim 2.0 enables a new garbage collector that we're not yet ready to support * adapt waku code to Nim 2.0 * gcsafe adaptations because Nim 2.0 is more strict
64 lines
1.7 KiB
Nim
64 lines
1.7 KiB
Nim
## This file contains the base message request type that will be handled.
|
|
## The requests are created by the main thread and processed by
|
|
## the Waku Thread.
|
|
|
|
import std/json, results
|
|
import chronos
|
|
import
|
|
../../../waku/factory/waku,
|
|
./requests/node_lifecycle_request,
|
|
./requests/peer_manager_request,
|
|
./requests/protocols/relay_request,
|
|
./requests/protocols/store_request,
|
|
./requests/debug_node_request,
|
|
./requests/discovery_request
|
|
|
|
type RequestType* {.pure.} = enum
|
|
LIFECYCLE
|
|
PEER_MANAGER
|
|
RELAY
|
|
STORE
|
|
DEBUG
|
|
DISCOVERY
|
|
|
|
type InterThreadRequest* = object
|
|
reqType: RequestType
|
|
reqContent: pointer
|
|
|
|
proc createShared*(
|
|
T: type InterThreadRequest, reqType: RequestType, reqContent: pointer
|
|
): ptr type T =
|
|
var ret = createShared(T)
|
|
ret[].reqType = reqType
|
|
ret[].reqContent = reqContent
|
|
return ret
|
|
|
|
proc process*(
|
|
T: type InterThreadRequest, request: ptr InterThreadRequest, waku: ptr Waku
|
|
): Future[Result[string, string]] {.async.} =
|
|
## Processes the request and deallocates its memory
|
|
defer:
|
|
deallocShared(request)
|
|
|
|
echo "Request received: " & $request[].reqType
|
|
|
|
let retFut =
|
|
case request[].reqType
|
|
of LIFECYCLE:
|
|
cast[ptr NodeLifecycleRequest](request[].reqContent).process(waku)
|
|
of PEER_MANAGER:
|
|
cast[ptr PeerManagementRequest](request[].reqContent).process(waku[])
|
|
of RELAY:
|
|
cast[ptr RelayRequest](request[].reqContent).process(waku)
|
|
of STORE:
|
|
cast[ptr StoreRequest](request[].reqContent).process(waku)
|
|
of DEBUG:
|
|
cast[ptr DebugNodeRequest](request[].reqContent).process(waku[])
|
|
of DISCOVERY:
|
|
cast[ptr DiscoveryRequest](request[].reqContent).process(waku)
|
|
|
|
return await retFut
|
|
|
|
proc `$`*(self: InterThreadRequest): string =
|
|
return $self.reqType
|