refactor: integrated base Observer structure into existing EVM/BTC observers

changelog.md

@@ -52,6 +52,7 @@
 * [2340](https://github.com/zeta-chain/node/pull/2340) - add ValidateInbound method for cctx orchestrator
 * [2344](https://github.com/zeta-chain/node/pull/2344) - group common data of EVM/Bitcoin signer and observer using base structs
 * [2357](https://github.com/zeta-chain/node/pull/2357) - integrate base Signer structure into EVM/Bitcoin Signer
+* [2359](https://github.com/zeta-chain/node/pull/2359) - integrate base Observer structure into EVM/Bitcoin Observer
 * [2375](https://github.com/zeta-chain/node/pull/2375) - improve & speedup code formatting
 
 ### Tests

cmd/zetaclientd/debug.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"strconv"
 	"strings"
-	"sync"
 
 	"github.com/btcsuite/btcd/rpcclient"
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -86,9 +85,7 @@ func DebugCmd() *cobra.Command {
 
 			// get ballot identifier according to the chain type
 			if chains.IsEVMChain(chain.ChainId) {
-				evmObserver := evmobserver.Observer{
-					Mu: &sync.Mutex{},
-				}
+				evmObserver := evmobserver.Observer{}
 				evmObserver.WithZetacoreClient(client)
 				var ethRPC *ethrpc.EthRPC
 				var client *ethclient.Client
@@ -164,9 +161,7 @@ func DebugCmd() *cobra.Command {
 				}
 				fmt.Println("CoinType : ", coinType)
 			} else if chains.IsBitcoinChain(chain.ChainId) {
-				btcObserver := btcobserver.Observer{
-					Mu: &sync.Mutex{},
-				}
+				btcObserver := btcobserver.Observer{}
 				btcObserver.WithZetacoreClient(client)
 				btcObserver.WithChain(*chains.GetChainFromChainID(chainID))
 				connCfg := &rpcclient.ConnConfig{

cmd/zetaclientd/utils.go

@@ -1,12 +1,16 @@
 package main
 
 import (
+	"fmt"
+
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	ethcommon "github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/ethclient"
 
 	"github.com/zeta-chain/zetacore/zetaclient/authz"
 	"github.com/zeta-chain/zetacore/zetaclient/chains/base"
 	btcobserver "github.com/zeta-chain/zetacore/zetaclient/chains/bitcoin/observer"
+	btcrpc "github.com/zeta-chain/zetacore/zetaclient/chains/bitcoin/rpc"
 	btcsigner "github.com/zeta-chain/zetacore/zetaclient/chains/bitcoin/signer"
 	evmobserver "github.com/zeta-chain/zetacore/zetaclient/chains/evm/observer"
 	evmsigner "github.com/zeta-chain/zetacore/zetaclient/chains/evm/signer"
@@ -116,32 +120,75 @@ func CreateChainObserverMap(
 	logger base.Logger,
 	ts *metrics.TelemetryServer,
 ) (map[int64]interfaces.ChainObserver, error) {
+	zetacoreContext := appContext.ZetacoreContext()
 	observerMap := make(map[int64]interfaces.ChainObserver)
 	// EVM observers
 	for _, evmConfig := range appContext.Config().GetAllEVMConfigs() {
 		if evmConfig.Chain.IsZetaChain() {
 			continue
 		}
-		_, found := appContext.ZetacoreContext().GetEVMChainParams(evmConfig.Chain.ChainId)
+		chainParams, found := zetacoreContext.GetEVMChainParams(evmConfig.Chain.ChainId)
 		if !found {
 			logger.Std.Error().Msgf("ChainParam not found for chain %s", evmConfig.Chain.String())
 			continue
 		}
-		co, err := evmobserver.NewObserver(appContext, zetacoreClient, tss, dbpath, logger, evmConfig, ts)
+
+		// create EVM client
+		evmClient, err := ethclient.Dial(evmConfig.Endpoint)
+		if err != nil {
+			logger.Std.Error().Err(err).Msgf("error dailing endpoint %s", evmConfig.Endpoint)
+			continue
+		}
+
+		// create EVM chain observer
+		observer, err := evmobserver.NewObserver(
+			evmConfig,
+			evmClient,
+			*chainParams,
+			zetacoreContext,
+			zetacoreClient,
+			tss,
+			dbpath,
+			logger,
+			ts,
+		)
 		if err != nil {
 			logger.Std.Error().Err(err).Msgf("NewObserver error for evm chain %s", evmConfig.Chain.String())
 			continue
 		}
-		observerMap[evmConfig.Chain.ChainId] = co
+		observerMap[evmConfig.Chain.ChainId] = observer
 	}
+
 	// BTC observer
+	_, chainParams, found := zetacoreContext.GetBTCChainParams()
+	if !found {
+		return nil, fmt.Errorf("bitcoin chains params not found")
+	}
+
+	// create BTC chain observer
 	btcChain, btcConfig, enabled := appContext.GetBTCChainAndConfig()
 	if enabled {
-		co, err := btcobserver.NewObserver(appContext, btcChain, zetacoreClient, tss, dbpath, logger, btcConfig, ts)
+		btcClient, err := btcrpc.NewRPCClient(btcConfig)
 		if err != nil {
-			logger.Std.Error().Err(err).Msgf("NewObserver error for bitcoin chain %s", btcChain.String())
+			logger.Std.Error().Err(err).Msgf("error creating rpc client for bitcoin chain %s", btcChain.String())
 		} else {
-			observerMap[btcChain.ChainId] = co
+			// create BTC chain observer
+			observer, err := btcobserver.NewObserver(
+				btcChain,
+				btcClient,
+				*chainParams,
+				zetacoreContext,
+				zetacoreClient,
+				tss,
+				dbpath,
+				logger,
+				ts,
+			)
+			if err != nil {
+				logger.Std.Error().Err(err).Msgf("NewObserver error for bitcoin chain %s", btcChain.String())
+			} else {
+				observerMap[btcChain.ChainId] = observer
+			}
 		}
 	}
 

testutil/sample/crypto.go

@@ -7,6 +7,7 @@ import (
 	"strconv"
 	"testing"
 
+	"github.com/btcsuite/btcd/chaincfg/chainhash"
 	"github.com/cometbft/cometbft/crypto/secp256k1"
 	"github.com/cosmos/cosmos-sdk/crypto/keys/ed25519"
 	cryptotypes "github.com/cosmos/cosmos-sdk/crypto/types"
@@ -60,6 +61,11 @@ func Hash() ethcommon.Hash {
 	return EthAddress().Hash()
 }
 
+// BtcHash returns a sample btc hash
+func BtcHash() chainhash.Hash {
+	return chainhash.Hash(Hash())
+}
+
 // PubKey returns a sample account PubKey
 func PubKey(r *rand.Rand) cryptotypes.PubKey {
 	seed := []byte(strconv.Itoa(r.Int()))