From dfc53e474a0b41c02dd1d57465b375bb72dbcd2d Mon Sep 17 00:00:00 2001
From: HAOYUatHZ <haoyu@protonmail.com>
Date: Fri, 2 Aug 2019 16:08:22 +0800
Subject: [PATCH] add

---
 toolbar/precog/database/orm/node.go |  9 +++++++++
 toolbar/precog/monitor/monitor.go   | 14 ++++++++++++--
 2 files changed, 21 insertions(+), 2 deletions(-)
 create mode 100644 toolbar/precog/database/orm/node.go

diff --git a/toolbar/precog/database/orm/node.go b/toolbar/precog/database/orm/node.go
new file mode 100644
index 00000000..bdd7c1f2
--- /dev/null
+++ b/toolbar/precog/database/orm/node.go
@@ -0,0 +1,9 @@
+package orm
+
+type Node struct {
+	Alias      string       `json:"alias"`
+	HostPort   string       `json:"host_port"`
+	PubKey     chainkd.XPub `json:"pubkey"`
+	BestHeight uint64       `json:"best_height"`
+	LantencyMS uint64       `json:"lantency_ms"` // TODO:
+}
diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go
index 777ad249..7f2e4454 100644
--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -31,13 +31,23 @@ func (m *monitor) Run() {
 
 	ticker := time.NewTicker(checkFreqSeconds * time.Second)
 	for ; true; <-ticker.C {
-		// TODO: use goroutine?
 		// TODO: lock?
-		go m.monitorRountine()
+		m.monitorRountine()
 	}
 }
 
 func (m *monitor) updateBootstrapNodes() error {
+	var existedNodes, newNodes []config.Node
+
+	// TODO: use affected comlumns?
+	for _, node := range m.cfg.Nodes {
+		if true {
+			existedNodes = append(existedNodes, node)
+		} else {
+			newNodes = append(newNodes, node)
+		}
+	}
+
 	return nil
 }
 
-- 
2.11.0