Implement observer map sync based on chainParams

zeta-chain · Jul 19, 2024 · f71991c · f71991c
1 parent 1d5206b
commit f71991c
Show file tree

Hide file tree

Showing 5 changed files with 407 additions and 198 deletions.
diff --git a/zetaclient/chains/base/observer.go b/zetaclient/chains/base/observer.go
@@ -138,7 +138,7 @@ func (ob *Observer) Start() bool {
 
 // Stop notifies all goroutines to stop and closes the database.
 func (ob *Observer) Stop() {
-	ob.logger.Chain.Info().Msgf("observer is stopping for chain %d", ob.Chain().ChainId)
+	ob.logger.Chain.Info().Msgf("Stopping observer for chain %d", ob.Chain().ChainId)
 	close(ob.stop)
 
 	ob.mu.Lock()

diff --git a/zetaclient/chains/bitcoin/observer/observer.go b/zetaclient/chains/bitcoin/observer/observer.go
@@ -200,9 +200,6 @@ func (ob *Observer) GetChainParams() observertypes.ChainParams {
 
 // Start starts the Go routine processes to observe the Bitcoin chain
 func (ob *Observer) Start(ctx context.Context) {
-	ob.Mu().Lock()
-	defer ob.Mu().Unlock()
-
 	if noop := ob.Observer.Start(); noop {
 		ob.Logger().Chain.Info().Msgf("observer is already started for chain %d", ob.Chain().ChainId)
 		return