mirror of https://github.com/waku-org/nwaku.git
38 lines
1.3 KiB
Nim
38 lines
1.3 KiB
Nim
##
|
|
## This file is aimed to attend the requests that come directly
|
|
## from the 'self' node. It is expected to attend the store requests that
|
|
## come from REST-store endpoint when those requests don't indicate
|
|
## any store-peer address.
|
|
##
|
|
## Notice that the REST-store requests normally assume that the REST
|
|
## server is acting as a store-client. In this module, we allow that
|
|
## such REST-store node can act as store-server as well by retrieving
|
|
## its own stored messages. The typical use case for that is when
|
|
## using `nwaku-compose`, which spawn a Waku node connected to a local
|
|
## database, and the user is interested in retrieving the messages
|
|
## stored by that local store node.
|
|
##
|
|
|
|
import stew/results, chronos
|
|
import ./protocol, ./common
|
|
|
|
proc handleSelfStoreRequest*(
|
|
self: WakuStore, req: StoreQueryRequest
|
|
): Future[WakuStoreResult[StoreQueryResponse]] {.async.} =
|
|
## Handles the store requests made by the node to itself.
|
|
## Normally used in REST-store requests
|
|
|
|
let handlerResult = catch:
|
|
await self.requestHandler(req)
|
|
|
|
let resResult =
|
|
if handlerResult.isErr():
|
|
return err("exception in handleSelfStoreRequest: " & handlerResult.error.msg)
|
|
else:
|
|
handlerResult.get()
|
|
|
|
let res = resResult.valueOr:
|
|
return err("error in handleSelfStoreRequest: " & $error)
|
|
|
|
return ok(res)
|