diff --git a/src/helpers/dhtservers_observer/DHTserversObserver.js b/src/helpers/dhtservers_observer/DHTserversObserver.js index 497bb5f..a3f6e70 100644 --- a/src/helpers/dhtservers_observer/DHTserversObserver.js +++ b/src/helpers/dhtservers_observer/DHTserversObserver.js @@ -27,9 +27,11 @@ class DHTserverObserver { get_dhtservers(config) { let ip_arr = [] let hexString - for (const dhtserver of config.data.dht) { - hexString = dhtserver.ip.toString(16); - ip_arr.push({ip: this.hex2dotted(hexString), port: dhtserver.port, time:0}) + for (const dhtserver of config.data.dht.static_nodes.nodes) { + for (const address of dhtserver.addr_list.addrs) { + hexString = address.ip.toString(16); + ip_arr.push({ip: this.hex2dotted(hexString), port: address.port, time:0}) + } } return ip_arr; } diff --git a/src/wsserver.js b/src/wsserver.js index 72e3feb..9272090 100644 --- a/src/wsserver.js +++ b/src/wsserver.js @@ -2,6 +2,7 @@ const dotenv = require('dotenv').config() const WebSocket = require('ws'); var ServicesObserver = require('./services_observer/ServicesObserver'); var LiteserverObserver = require('./liteservers_observer/LiteserversObserver'); +var DHTserversObserver = require('./dhtservers_Observer/DHTserversObserver'); let {metrics_service,bridge_service, interval_service} = require('./request') module.exports = async function start_wsserver() @@ -10,10 +11,12 @@ module.exports = async function start_wsserver() let servicesObserver = new ServicesObserver() let liteserversObserver = await LiteserverObserver.build(dotenv.parsed.LITESERVER_CONFIG_URL) + let dhtserversObserver = await DHTserversObserver.build(dotenv.parsed.LITESERVER_CONFIG_URL) let lastData = JSON.stringify({ services: await servicesObserver.checkServices(), liteservers: liteserversObserver.liteservers, + dhtservers: dhtserversObserver.dhtservers, elections: metrics_service.get_elections_data(), complaints: metrics_service.get_complaints(), blocks_rate:metrics_service.get_blocks_rate(), @@ -46,10 +49,12 @@ module.exports = async function start_wsserver() console.log("fetching data..."); await liteserversObserver.check_liteservers() + await dhtserversObserver.check_dhtservers() lastData = JSON.stringify({ services: await servicesObserver.checkServices(), liteservers: liteserversObserver.liteservers, + dhtservers: dhtserversObserver.dhtservers, elections: metrics_service.get_elections_data(), complaints: metrics_service.get_complaints(), blocks_rate:metrics_service.get_blocks_rate(),