mirror of
https://github.com/logos-messaging/logos-messaging-nim.git
synced 2026-01-24 16:53:10 +00:00
dd8d664311
Split `WakuNodeConfig` object for better separation of concerns and to introduce a tree-like structure to configuration. * fix: ensure twn cluster conf is still applied when clusterId=1 * test: remove usage of `WakuNodeConf` * Remove macro, split builder files, remove wakunodeconf from tests * rm network_conf_builder module as it is not used --------- Co-authored-by: NagyZoltanPeter <113987313+NagyZoltanPeter@users.noreply.github.com> Co-authored-by: Ivan Folgueira Bande <ivansete@status.im>
69 lines
1.9 KiB
Nim
69 lines
1.9 KiB
Nim
import chronicles, std/[net, options], results
|
|
import ../network_conf
|
|
|
|
logScope:
|
|
topics = "waku conf builder websocket"
|
|
|
|
##############################
|
|
## WebSocket Config Builder ##
|
|
##############################
|
|
type WebSocketConfBuilder* = object
|
|
enabled*: Option[bool]
|
|
webSocketPort*: Option[Port]
|
|
secureEnabled*: Option[bool]
|
|
keyPath*: Option[string]
|
|
certPath*: Option[string]
|
|
|
|
proc init*(T: type WebSocketConfBuilder): WebSocketConfBuilder =
|
|
WebSocketConfBuilder()
|
|
|
|
proc withEnabled*(b: var WebSocketConfBuilder, enabled: bool) =
|
|
b.enabled = some(enabled)
|
|
|
|
proc withSecureEnabled*(b: var WebSocketConfBuilder, secureEnabled: bool) =
|
|
b.secureEnabled = some(secureEnabled)
|
|
|
|
proc withWebSocketPort*(b: var WebSocketConfBuilder, webSocketPort: Port) =
|
|
b.webSocketPort = some(webSocketPort)
|
|
|
|
proc withWebSocketPort*(b: var WebSocketConfBuilder, webSocketPort: uint16) =
|
|
b.webSocketPort = some(Port(webSocketPort))
|
|
|
|
proc withKeyPath*(b: var WebSocketConfBuilder, keyPath: string) =
|
|
b.keyPath = some(keyPath)
|
|
|
|
proc withCertPath*(b: var WebSocketConfBuilder, certPath: string) =
|
|
b.certPath = some(certPath)
|
|
|
|
proc build*(b: WebSocketConfBuilder): Result[Option[WebSocketConf], string] =
|
|
if not b.enabled.get(false):
|
|
return ok(none(WebSocketConf))
|
|
|
|
if b.webSocketPort.isNone():
|
|
return err("websocket.port is not specified")
|
|
|
|
if not b.secureEnabled.get(false):
|
|
return ok(
|
|
some(
|
|
WebSocketConf(
|
|
port: b.websocketPort.get(), secureConf: none(WebSocketSecureConf)
|
|
)
|
|
)
|
|
)
|
|
|
|
if b.keyPath.get("") == "":
|
|
return err("WebSocketSecure enabled but key path is not specified")
|
|
if b.certPath.get("") == "":
|
|
return err("WebSocketSecure enabled but cert path is not specified")
|
|
|
|
return ok(
|
|
some(
|
|
WebSocketConf(
|
|
port: b.webSocketPort.get(),
|
|
secureConf: some(
|
|
WebSocketSecureConf(keyPath: b.keyPath.get(), certPath: b.certPath.get())
|
|
),
|
|
)
|
|
)
|
|
)
|