fix bugs (cosmostation#65)

Author: Jeongseup

internal/common/indexer/repository/vigilante_info.go

@@ -68,7 +68,7 @@ func (repo *MetaRepository) InsertVigilanteInfoList(VigilanteInfoList []model.Vi
 		ExcludeColumn("id").
 		Exec(ctx)
 	if err != nil {
-		return errors.Wrapf(err, "failed to insert validator info list")
+		return err
 	}
 
 	return nil

internal/packages/babylon/btc-lightclient/indexer/sync.go

@@ -102,7 +102,7 @@ func (idx *BTCLightClientIndexer) batchSync(lastIndexPoint int64) (
 
 	// if there are new hex address in current block, collect their validator hex address to save in database
 	isNewReporter := false
-	newRepoterInfoList := make([]indexermodel.VigilanteInfo, 0)
+	newReporterMap := make(map[string]indexermodel.VigilanteInfo, 0)
 	for _, bie := range bieSummaryList {
 		if bie.skip {
 			continue
@@ -113,23 +113,29 @@ func (idx *BTCLightClientIndexer) batchSync(lastIndexPoint int64) (
 			_, exist := idx.Vim[e.ReporterAddress]
 			if !exist {
 				idx.Debugf("the reporter %s address isn't in current validator info table, the address will be added into the meta table", e.ReporterAddress)
-				newRepoterInfoList = append(newRepoterInfoList, indexermodel.VigilanteInfo{
+
+				newReporterMap[e.ReporterAddress] = indexermodel.VigilanteInfo{
 					ChainInfoID:     idx.ChainInfoID,
 					OperatorAddress: e.ReporterAddress,
 					Moniker:         "Babylon Vigilante Repoter",
-				})
+				}
 				isNewReporter = true
 			}
 		}
 	}
 
 	// this logic will be progressed only when there are new tendermint validators in this block
 	if isNewReporter {
-		idx.Debugf("insert new vigilante reporters: %d", len(newRepoterInfoList))
+		idx.Debugf("insert new vigilante reporters: %d", len(newReporterMap))
+		newRepoterInfoList := make([]indexermodel.VigilanteInfo, 0)
+		for _, v := range newReporterMap {
+			newRepoterInfoList = append(newRepoterInfoList, v)
+		}
 		err := idx.InsertVigilanteInfoList(newRepoterInfoList)
 		if err != nil {
 			// NOTE: fetch again validator_info list, actually already inserted the list by other indexer service
 			idx.FetchValidatorInfoList()
+			idx.Errorf("new reporter list: %v", newRepoterInfoList)
 			return lastIndexPoint, errors.Wrap(err, "failed to insert new reporter list")
 		}
 

internal/packages/babylon/covenant-committee/indexer/batch_sync.go

@@ -1,7 +1,6 @@
 package indexer
 
 import (
-	"fmt"
 	"time"
 
 	"sync"
@@ -212,7 +211,7 @@ func (idx *CovenantSignatureIndexer) batchSync(lastIndexPointerHeight, newIndexP
 
 		// exit loop
 		if closedCh1 && closedCh2 {
-			fmt.Println("All channels closed. Exiting loop.")
+			idx.Debugln("All channels closed. Exiting loop.")
 			break
 		}
 	}

internal/packages/block-data-analytics/indexer/sync.go

@@ -206,6 +206,7 @@ func (idx *BDAIndexer) batchSync(lastIndexPoint int64) (
 
 	newIndexPointer := summaryList[endHeight].BlockHeight
 	newIndexPointerTime := summaryList[endHeight].Timestamp
+
 	err := idx.InsertBlockDataList(idx.ChainInfoID, newIndexPointer, modelList1, modelList2)
 	if err != nil {
 		return lastIndexPoint, errors.Wrapf(err, "failed to insert from %d to %d height", startHeight, endHeight)

internal/packages/block-data-analytics/repository/repository.go

@@ -65,12 +65,14 @@ func (repo *BDAIndexerRepository) InsertBlockDataList(
 				return errors.Wrapf(err, "failed to insert data")
 			}
 
-			_, err = tx.NewInsert().
-				Model(&blockMessageList).
-				ExcludeColumn("id").
-				Exec(ctx)
-			if err != nil {
-				return errors.Wrapf(err, "failed to insert data")
+			if len(blockMessageList) > 0 {
+				_, err = tx.NewInsert().
+					Model(&blockMessageList).
+					ExcludeColumn("id").
+					Exec(ctx)
+				if err != nil {
+					return errors.Wrapf(err, "failed to insert data")
+				}
 			}
 
 			_, err = tx.