fix(node_config): fix bad error management in the node_config service
Part of #16895
This commit is contained in:
parent
ac3d609bd8
commit
ce1235563b
|
@ -1,4 +1,4 @@
|
||||||
import chronicles
|
import chronicles, json_serialization
|
||||||
|
|
||||||
import ./dto/node_config
|
import ./dto/node_config
|
||||||
import ../settings/service as settings_service
|
import ../settings/service as settings_service
|
||||||
|
@ -6,6 +6,7 @@ import ../../../app/core/eventemitter
|
||||||
import ../../../app/core/fleets/fleet_configuration
|
import ../../../app/core/fleets/fleet_configuration
|
||||||
import ../../../backend/node_config as status_node_config
|
import ../../../backend/node_config as status_node_config
|
||||||
import ../../../constants as main_constants
|
import ../../../constants as main_constants
|
||||||
|
import ../../../app/core/signals/types
|
||||||
|
|
||||||
export node_config
|
export node_config
|
||||||
|
|
||||||
|
@ -105,22 +106,30 @@ proc isCommunityHistoryArchiveSupportEnabled*(self: Service): bool =
|
||||||
return self.configuration.TorrentConfig.Enabled
|
return self.configuration.TorrentConfig.Enabled
|
||||||
|
|
||||||
proc enableCommunityHistoryArchiveSupport*(self: Service): bool =
|
proc enableCommunityHistoryArchiveSupport*(self: Service): bool =
|
||||||
|
try:
|
||||||
let response = status_node_config.enableCommunityHistoryArchiveSupport()
|
let response = status_node_config.enableCommunityHistoryArchiveSupport()
|
||||||
if(not response.error.isNil):
|
if response.error != nil:
|
||||||
error "error enabling community history archive support: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.TorrentConfig.Enabled = true
|
self.configuration.TorrentConfig.Enabled = true
|
||||||
return true
|
return true
|
||||||
|
except Exception as e:
|
||||||
|
error "error enabling community history archive support: ", errDescription = e.msg
|
||||||
|
return false
|
||||||
|
|
||||||
proc disableCommunityHistoryArchiveSupport*(self: Service): bool =
|
proc disableCommunityHistoryArchiveSupport*(self: Service): bool =
|
||||||
|
try:
|
||||||
let response = status_node_config.disableCommunityHistoryArchiveSupport()
|
let response = status_node_config.disableCommunityHistoryArchiveSupport()
|
||||||
if(not response.error.isNil):
|
if response.error != nil:
|
||||||
error "error disabling community history archive support: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.TorrentConfig.Enabled = false
|
self.configuration.TorrentConfig.Enabled = false
|
||||||
return true
|
return true
|
||||||
|
except Exception as e:
|
||||||
|
error "error disabling community history archive support: ", errDescription = e.msg
|
||||||
|
return false
|
||||||
|
|
||||||
proc getFleet*(self: Service): Fleet =
|
proc getFleet*(self: Service): Fleet =
|
||||||
result = self.settingsService.getFleet()
|
result = self.settingsService.getFleet()
|
||||||
|
@ -138,18 +147,18 @@ proc saveNewWakuNode*(self: Service, nodeAddress: string): bool =
|
||||||
try:
|
try:
|
||||||
let response = status_node_config.saveNewWakuNode(nodeAddress)
|
let response = status_node_config.saveNewWakuNode(nodeAddress)
|
||||||
|
|
||||||
if not response.error.isNil:
|
if response.error != nil:
|
||||||
error "failed to add new waku node: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.ClusterConfig.WakuNodes.add(nodeAddress)
|
self.configuration.ClusterConfig.WakuNodes.add(nodeAddress)
|
||||||
|
return true
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
error "error saving new waku node: ", errDescription = e.msg
|
error "error saving new waku node: ", errDescription = e.msg
|
||||||
return false
|
return false
|
||||||
return true
|
|
||||||
|
|
||||||
proc setFleet*(self: Service, fleet: string): bool =
|
proc setFleet*(self: Service, fleet: string): bool =
|
||||||
if (not self.settingsService.saveFleet(fleet)):
|
if not self.settingsService.saveFleet(fleet):
|
||||||
error "error saving fleet ", procName = "setFleet"
|
error "error saving fleet ", procName = "setFleet"
|
||||||
return false
|
return false
|
||||||
|
|
||||||
|
@ -205,14 +214,18 @@ proc setFleet*(self: Service, fleet: string): bool =
|
||||||
return false
|
return false
|
||||||
|
|
||||||
proc setLightClient*(self: Service, enabled: bool): bool =
|
proc setLightClient*(self: Service, enabled: bool): bool =
|
||||||
|
try:
|
||||||
let response = status_node_config.setLightClient(enabled)
|
let response = status_node_config.setLightClient(enabled)
|
||||||
|
|
||||||
if not response.error.isNil:
|
if response.error != nil:
|
||||||
error "failed to set light client: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.WakuV2Config.LightClient = enabled
|
self.configuration.WakuV2Config.LightClient = enabled
|
||||||
return true
|
return true
|
||||||
|
except Exception as e:
|
||||||
|
error "failed to set light client", errDescription = e.msg
|
||||||
|
return false
|
||||||
|
|
||||||
proc getLogLevel(self: Service): string =
|
proc getLogLevel(self: Service): string =
|
||||||
return self.configuration.LogLevel
|
return self.configuration.LogLevel
|
||||||
|
@ -224,15 +237,19 @@ proc isDebugEnabled*(self: Service): bool =
|
||||||
return logLevel in DEBUG_LOG_LEVELS
|
return logLevel in DEBUG_LOG_LEVELS
|
||||||
|
|
||||||
proc setLogLevel*(self: Service, logLevel: LogLevel): bool =
|
proc setLogLevel*(self: Service, logLevel: LogLevel): bool =
|
||||||
|
try:
|
||||||
let response = status_node_config.setLogLevel(logLevel)
|
let response = status_node_config.setLogLevel(logLevel)
|
||||||
|
|
||||||
if not response.error.isNil:
|
if response.error != nil:
|
||||||
error "failed to set log level: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.LogLevel = $logLevel
|
self.configuration.LogLevel = $logLevel
|
||||||
self.events.emit(SIGNAL_NODE_LOG_LEVEL_UPDATE, NodeLogLevelUpdatedArgs(logLevel: logLevel))
|
self.events.emit(SIGNAL_NODE_LOG_LEVEL_UPDATE, NodeLogLevelUpdatedArgs(logLevel: logLevel))
|
||||||
return true
|
return true
|
||||||
|
except Exception as e:
|
||||||
|
error "failed to set log level", errDescription = e.msg
|
||||||
|
return false
|
||||||
|
|
||||||
proc getNimbusProxyConfig(self: Service): bool =
|
proc getNimbusProxyConfig(self: Service): bool =
|
||||||
return self.configuration.NimbusProxyConfig.Enabled
|
return self.configuration.NimbusProxyConfig.Enabled
|
||||||
|
@ -256,11 +273,15 @@ proc getLogMaxBackups*(self: Service): int =
|
||||||
return self.configuration.LogMaxBackups
|
return self.configuration.LogMaxBackups
|
||||||
|
|
||||||
proc setMaxLogBackups*(self: Service, value: int): bool =
|
proc setMaxLogBackups*(self: Service, value: int): bool =
|
||||||
|
try:
|
||||||
let response = status_node_config.setMaxLogBackups(value)
|
let response = status_node_config.setMaxLogBackups(value)
|
||||||
|
|
||||||
if not response.error.isNil:
|
if response.error != nil:
|
||||||
error "failed to set max log backups: ", errDescription = response.error.message
|
let error = Json.decode($response.error, RpcError)
|
||||||
return false
|
raise newException(RpcException, error.message)
|
||||||
|
|
||||||
self.configuration.LogMaxBackups = value
|
self.configuration.LogMaxBackups = value
|
||||||
return true
|
return true
|
||||||
|
except Exception as e:
|
||||||
|
error "failed to set max log backups", errDescription = e.msg
|
||||||
|
return false
|
||||||
|
|
Loading…
Reference in New Issue