-func (m *monitor) collectDiscoveredNodes(discvWg *sync.WaitGroup) {
- for node := range m.discvCh {
- if err := m.upSertNode(&config.Node{
- PublicKey: node.ID.String(),
- Host: node.IP.String(),
- Port: node.TCP,
- }); err == nil {
- m.discvMap[node.ID.String()] = node
- } else {
- log.Error(err)
- }
- discvWg.Done()
+func (m *monitor) saveDiscoveredNode(node *dht.Node) {
+ if err := m.upSertNode(&config.Node{
+ PublicKey: node.ID.String(),
+ Host: node.IP.String(),
+ Port: node.TCP,
+ }); err == nil {
+ m.discvMap[node.ID.String()] = node
+ } else {
+ log.Error(err)