diff options
author | Jhih-Ming Huang <jm@byzantine-lab.io> | 2020-09-12 19:25:57 +0800 |
---|---|---|
committer | Jhih-Ming Huang <jm@byzantine-lab.io> | 2020-09-12 19:25:57 +0800 |
commit | b5ebe6dc0b0123d2f55bbbc9a0c24502551bf1e3 (patch) | |
tree | 211116ff5970ebc1f13f0e157a902e63891cad08 | |
parent | 00c26ac3565cbf44364c67e42c2f76a29448f223 (diff) | |
download | tangerine-monitor-b5ebe6dc0b0123d2f55bbbc9a0c24502551bf1e3.tar.gz tangerine-monitor-b5ebe6dc0b0123d2f55bbbc9a0c24502551bf1e3.tar.zst tangerine-monitor-b5ebe6dc0b0123d2f55bbbc9a0c24502551bf1e3.zip |
implement print nodes status
-rw-r--r-- | main.go | 44 | ||||
-rw-r--r-- | monitor/monitor.go | 10 |
2 files changed, 41 insertions, 13 deletions
@@ -1,16 +1,16 @@ package main import ( + "bufio" "fmt" "io/ioutil" "log" "os" "path/filepath" "strconv" - "bufio" - "github.com/urfave/cli" "github.com/tangerine-network/tan-monitor/monitor" + "github.com/urfave/cli" ) var app *cli.App @@ -21,21 +21,39 @@ func init() { app.Usage = "Tangerine Newtwork Monitor" app.Commands = []cli.Command{ commandStart, + commandGetNodeStatus, } } func getLines(path string) ([]string, error) { - file, err := os.Open(path) - if err != nil { - return nil, err - } - defer file.Close() + file, err := os.Open(path) + if err != nil { + return nil, err + } + defer file.Close() - var lines []string - scanner := bufio.NewScanner(file) - for scanner.Scan() { - lines = append(lines, scanner.Text()) - } - return lines, scanner.Err() + var lines []string + scanner := bufio.NewScanner(file) + for scanner.Scan() { + lines = append(lines, scanner.Text()) + } + return lines, scanner.Err() +} + +var commandGetNodeStatus = cli.Command{ + Name: "get_nodes_status", + Usage: "Get nodes' status", + ArgsUsage: "", + Description: `Print out current nodes's status`, + Flags: []cli.Flag{}, + Action: func(ctx *cli.Context) error { + networkID := 411 + backend := monitor.NewBlockchainBackend(networkID) + nodes := backend.NodeSet() + for _, node := range nodes { + node.Print() + } + return nil + }, } var commandStart = cli.Command{ Name: "start", diff --git a/monitor/monitor.go b/monitor/monitor.go index 2c9cc57..ac224a0 100644 --- a/monitor/monitor.go +++ b/monitor/monitor.go @@ -1,6 +1,7 @@ package monitor import ( + "fmt" "log" "math" "math/big" @@ -20,6 +21,15 @@ type node struct { nodeKeyAddress common.Address } +func (n node) Print() { + fmt.Println("========") + fmt.Println(n.name) + fmt.Println("fined: ", n.fined) + fmt.Println("email: ", n.email) + fmt.Println("owner: ", n.owner) + fmt.Println("address: ", n.nodeKeyAddress) +} + // NetworkConfig represents the network config. type NetworkConfig struct { WSEndpoint string |