Merge pull request #9 from Alethio/fix-http-polling

Fix for issue #8.
Alethio · Dec 2, 2019 · fa48d85 · fa48d85
2 parents 11a3936 + 1edba7e
commit fa48d85
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/commands/run.go b/commands/run.go
@@ -38,7 +38,7 @@ var runCmd = &cobra.Command{
 			BestBlockTracker: bestblock.Config{
 				NodeURL:      viper.GetString("eth.client.http"),
 				NodeURLWS:    viper.GetString("eth.client.ws"),
-				PollInterval: viper.GetDuration("eth.poll-interval"),
+				PollInterval: viper.GetDuration("eth.client.poll-interval"),
 			},
 			TaskManager: taskmanager.Config{
 				RedisServer:     viper.GetString("redis.server"),

diff --git a/eth/bestblock/bestblock.go b/eth/bestblock/bestblock.go
@@ -50,14 +50,14 @@ func (b *Tracker) Run() {
 	log.Info("starting best block tracker")
 
 	for {
-		log.Info("setting up websocket connection")
-
 		var conn *ethrpc.ETH
 		var err error
 
 		if b.config.NodeURLWS != "" {
+			log.Info("setting up websocket connection")
 			conn, err = ethrpc.NewWithDefaults(b.config.NodeURLWS)
 		} else {
+			log.Info("setting up best block polling")
 			conn, err = ethrpc.NewWithDefaults(b.config.NodeURL)
 		}
 		if err != nil {

diff --git a/eth/bestblock/http.go b/eth/bestblock/http.go
@@ -4,6 +4,7 @@ import "time"
 
 // runHTTP polls the node for the best block number every [config.PollInterval]
 func (b *Tracker) runHTTP() {
+	log.Tracef("tracking best block via HTTP polling, every %s", b.config.PollInterval)
 	for {
 		select {
 		case <-time.Tick(b.config.PollInterval):