fix: don't let the stats block the main logic (#94)

This commit makes the functions that main logic calls to send information to
stats non-blocking. When the stats is not ready, the information is dropped.

Author: minh-bq

stats/bridge_stats.go

@@ -6,7 +6,6 @@ import (
 	"net/http"
 	"strings"
 	"sync"
-	"sync/atomic"
 	"time"
 
 	bridgeCore "github.com/axieinfinity/bridge-core"
@@ -127,7 +126,6 @@ type Service struct {
 	processedBlockCh chan processedBlockMessage
 	quitCh           chan struct{}
 	store            stores.TaskStore
-	isReady          atomic.Bool
 }
 
 func NewService(node, chainId, operator, host, secret string, db *gorm.DB) {
@@ -299,8 +297,6 @@ func (s *Service) report(conn *connWrapper) error {
 func (s *Service) readLoop(conn *connWrapper) {
 	// If the read loop exits, close the connection
 	defer conn.Close()
-	// set isReady to true
-	s.isReady.Store(true)
 	log.Info("[Bridge stats] Start read loop")
 	for {
 		// Exit the function when receiving the quit signal
@@ -352,17 +348,17 @@ func (s *Service) setProcessedBlock(listener string, block uint64) error {
 }
 
 func (s *Service) SendError(listener, err string) {
-	if !s.isReady.Load() {
-		log.Info("Stats is not ready to broadcast error")
-		return
+	select {
+	case s.errCh <- errorMessage{Listener: listener, Err: err}:
+	default:
+		log.Debug("Stats is not ready to broadcast error")
 	}
-	s.errCh <- errorMessage{Listener: listener, Err: err}
 }
 
 func (s *Service) SendProcessedBlock(listener string, block uint64) {
-	if !s.isReady.Load() {
-		log.Info("Stats is not ready to broadcast processed block")
-		return
+	select {
+	case s.processedBlockCh <- processedBlockMessage{Listener: listener, ProcessedBlock: block}:
+	default:
+		log.Debug("Stats is not ready to broadcast processed block")
 	}
-	s.processedBlockCh <- processedBlockMessage{Listener: listener, ProcessedBlock: block}
 }