nwaku/apps/wakunode2/wakunode2_setup_rpc.nim

when (NimMajor, NimMinor) < (1, 4):
  {.push raises: [Defect].}
else:
  {.push raises: [].}

import
  std/tables,
  stew/shims/net,
  chronicles,
  json_rpc/rpcserver
import
  ../../waku/v2/protocol/waku_message,
  ../../waku/v2/node/waku_node,
  ../../waku/v2/node/jsonrpc/[admin_api,
                              debug_api,
                              filter_api,
                              relay_api,
                              store_api,
                              private_api,
                              debug_api],
  ./config

logScope:
  topics = "wakunode jsonrpc"


proc startRpcServer*(node: WakuNode, rpcIp: ValidIpAddress, rpcPort: Port, conf: WakuNodeConf)
  {.raises: [RpcBindError].} =

  let
    ta = initTAddress(rpcIp, rpcPort)
    rpcServer = newRpcHttpServer([ta])
  
  installDebugApiHandlers(node, rpcServer)

  # TODO: Move to setup protocols proc
  if conf.relay:
    let topicCache = newTable[PubsubTopic, seq[WakuMessage]]()
    installRelayApiHandlers(node, rpcServer, topicCache)

    if conf.rpcPrivate:
      # Private API access allows WakuRelay functionality that 
      # is backwards compatible with Waku v1.
      installPrivateApiHandlers(node, rpcServer, topicCache)
  
  # TODO: Move to setup protocols proc
  if conf.filternode != "":
    let messageCache = newTable[ContentTopic, seq[WakuMessage]]()
    installFilterApiHandlers(node, rpcServer, messageCache)
  
  # TODO: Move to setup protocols proc
  if conf.storenode != "":
    installStoreApiHandlers(node, rpcServer)
  
  if conf.rpcAdmin:
    installAdminApiHandlers(node, rpcServer)
  
  rpcServer.start()
  info "RPC Server started", address=ta