fix(health): improved healthcheck worker

code/go/0chain.net/blobber/config.go

@@ -47,6 +47,8 @@ func setupConfig(configDir string, deploymentMode int) {
 	config.Configuration.RMRedeemFreq = viper.GetInt64("readmarker_redeem.frequency")
 	config.Configuration.RMRedeemNumWorkers = viper.GetInt("readmarker_redeem.num_workers")
 
+	config.Configuration.HealthCheckWorkerFreq = viper.GetDuration("healthcheck.frequency")
+
 	config.Configuration.ChallengeResolveFreq = viper.GetInt64("challenge_response.frequency")
 	config.Configuration.ChallengeResolveNumWorkers = viper.GetInt("challenge_response.num_workers")
 	config.Configuration.ChallengeMaxRetires = viper.GetInt("challenge_response.max_retries")

code/go/0chain.net/blobber/worker.go

@@ -53,19 +53,23 @@ func refreshPriceOnChain(ctx context.Context) {
 func startHealthCheck(ctx context.Context) {
 
 	const REPEAT_DELAY = 10 * 1 // 60s
-	var err error
+
 	for {
 		select {
 		case <-ctx.Done():
 			break
 		case <-time.After(REPEAT_DELAY * time.Second):
-
-			err = handler.SendHealthCheck()
-			if err == nil {
-				logging.Logger.Info("success to send heartbeat")
-			} else {
-				logging.Logger.Warn("failed to send heartbeat", zap.Error(err))
-			}
+			go func() {
+				start := time.Now()
+
+				txnHash, err := handler.SendHealthCheck()
+				end := time.Now()
+				if err == nil {
+					logging.Logger.Info("success to send heartbeat", zap.String("txn_hash", txnHash), zap.Time("start", start), zap.Time("end", end), zap.Duration("duration", end.Sub(start)))
+				} else {
+					logging.Logger.Warn("failed to send heartbeat", zap.String("txn_hash", txnHash), zap.Time("start", start), zap.Time("end", end), zap.Duration("duration", end.Sub(start)))
+				}
+			}()
 		}
 	}
 }

code/go/0chain.net/blobbercore/config/config.go

@@ -25,6 +25,8 @@ func SetupDefaultConfig() {
 	viper.SetDefault("challenge_response.num_workers", 5)
 	viper.SetDefault("challenge_response.max_retries", 10)
 
+	viper.SetDefault("healthcheck.frequency", "60s")
+
 	viper.SetDefault("capacity", -1)
 	viper.SetDefault("read_price", 0.0)
 	viper.SetDefault("write_price", 0.0)
@@ -107,6 +109,8 @@ type Config struct {
 	ColdStorageDeleteLocalCopy   bool
 	ColdStorageDeleteCloudCopy   bool
 
+	HealthCheckWorkerFreq time.Duration
+
 	MinioStart      bool
 	MinioWorkerFreq int64
 	MinioUseSSL     bool

code/go/0chain.net/blobbercore/handler/protocol.go

@@ -3,7 +3,6 @@ package handler
 import (
 	"context"
 	"errors"
-	"log"
 	"sync"
 	"time"
 
@@ -104,8 +103,13 @@ func RegisterBlobber(ctx context.Context) error {
 		return nil
 	}
 
-	return SendHealthCheck()
+	txnHash, err := SendHealthCheck()
+	if err != nil {
+		logging.Logger.Error("Failed to send healthcheck transaction", zap.String("txn_hash", txnHash))
+		return err
+	}
 
+	return nil
 }
 
 // UpdateBlobber update blobber
@@ -239,17 +243,12 @@ func WalletRegister() error {
 }
 
 // SendHealthCheck send heartbeat to blockchain
-func SendHealthCheck() error {
-	log.Println("SendHealthCheck")
+func SendHealthCheck() (string, error) {
 	txnHash, err := BlobberHealthCheck()
 	if err != nil {
-		return err
+		return txnHash, err
 	}
 	_, err = TransactionVerify(txnHash)
-	if err != nil {
-		logging.Logger.Error("Failed to verify blobber health check", zap.Any("err", err), zap.String("txn.Hash", txnHash))
-		return err
-	}
 
-	return nil
+	return txnHash, err
 }

config/0chain_blobber.yaml

@@ -1,7 +1,7 @@
 version: "1.0"
 
 logging:
-  level: "error"
+  level: "info"
   console: true # printing log to console is only supported in development mode
 
 info:
@@ -93,6 +93,10 @@ challenge_response:
   frequency: 10
   num_workers: 5
   max_retries: 20
+
+healthcheck: 
+  frequency: 60s # send healthcheck to miners every 60 seconds
+
 pg:
   user: postgres
   password: postgres